Synchronous peer-to-peer multipoint database synchronization

• US 7,366,743 B2
• Filed: 08/02/2005
• Issued: 04/29/2008
• Est. Priority Date: 03/06/2002
• Status: Expired due to Term

• Current Assignee: Callahan Cellular LLC (Intellectual Ventures LLC)
• Original Assignee: Colligo Networks, Inc. (Olbia Software Inc.)
• Inventors: Sawadsky, Nicholas Justin, Shi, Daniel (Yilin), Block, Andrew Edward, Blackstock, Michael Anthony, Spaay, Henricus Gerardus, Rodriguez, Desiree Paula
• Primary Examiner(s): Le, Miranda
• Assistant Examiner(s): Lu, Kuen S
• Application Number:
  US11/196,567
• Publication Number:
  US 20060015546A1
• Time in Patent Office: 1,001 Days
• Field of Search: 707/204, 707/201, 707/203, 707/1, 707/200
• US Class Current: 1/1
• CPC Class Codes: G06F 16/275 Synchronous replication
• CPC Class Codes: Y10S 707/99953 Recoverability
• CPC Class Codes: Y10S 707/99955 Archiving or backup

Abstract

A method of synchronizing databases between multiple users in a peer-to-peer network is disclosed. The method comprises extracting changes from a source database of one of the users. Next, the changes are compressed and sent to the other users in the peer-to-peer network in parallel. Finally, the changes are decompressed and replicated on the database of each of the other users. In this respect, the databases of the other users will contain all changes from the source database.

Claims

1. A method for database synchronization, the method comprising:

extracting changes from a source database of a first computer of a peer-to-peer network to generate an extracted database,

said peer-to-peer network comprising a plurality of computers,

each of said plurality of computers configured to initiate and perform parallel synchronization of respective databases on each of said plurality of computers without mediation by a server and without asynchronous storage of interim reference data sets;

transferring said extracted database from said first computer to a second computer of said peer-to-peer network; and

replicating said source database on a target database of said second computer from said extracted database in order to synchronize said target database with said source database,

wherein said extracting, said transferring, and said replicating occur without mediation by a server and without asynchronous storage of interim reference data sets.

2. The method of claim 1, further comprising:

compressing said extracted database to generate a compressed extracted database subsequent to said extracting; and

decompressing said compressed extracted database on said second computer to generate a decompressed extracted database subsequent to said transferring.

3. The method of claim 2, further comprising expunging said extracted database from said first computer after said compressed extracted database is generated.

4. The method of claim 2, further comprising expunging said compressed extracted database from said first computer after said transferring from said first computer to said second computer.

5. The method of claim 2, further comprising expunging said extracted database on said second computer after said decompressed database has been generated.

6. The method of claim 2, further comprising expunging said decompressed database on said second computer after it has been replicated on said target database.

7. The method of claim 2, wherein said decompressing comprises decompressing said compressed extracted database in a manner complementary to said compressing.

8. The method of claim 1, wherein said peer-to-peer network comprises a wireless network.

9. The method of claim 1, wherein said peer-to-peer network comprises a wired network.

10. The method of claim 1, further comprising:

extracting changes from said target database of said target computer to generate an extracted target database;

transferring said extracted target database from said second computer to said first computer; and

replicating said target database on said source database of said first computer from said extracted target database in order to synchronize said source database with said target database.

11. The method of claim 10, further comprising:

compressing said extracted target database to generate a compressed extracted target database subsequent to said extracting changes from said target database; and

decompressing said compressed extracted target database on said first computer to generate a decompressed target database subsequent to said transferring said extracted target database from said second computer.

12. The method of claim 1 wherein

said plurality of computers comprises an initiating computer;

and

said extracting is responsive to receiving a synchronization request from said initiating computer.

13. A method for database synchronization, the method comprising:

extracting changes from a respective database of each of a plurality of users in a peer-to-peer network, said peer-to-peer network comprising a plurality of computers,

each of said plurality of computers configured to initiate and perform parallel synchronization of respective databases on each of said plurality of computers without mediation by a server and without asynchronous storage of interim reference data sets, one of said plurality of users being an initiating user;

sending said changes from each of said users to said initiating user;

replicating said changes from each of said users onto said database of said initiating user;

sending said changes on said database of said initiating user to each of said other users; and

replicating said changes on a respective database of each user in order to synchronize said databases of all of said users,

wherein said extracting, said sending said changes from each of said users, said replicating said changes from each of said users, said sending said changes on said database, and

said replicating said changes on a respective database occur without mediation by a server and without asynchronous storage of interim reference data sets.

14. The method of claim 13, further comprising compressing said changes prior to sending them and decompressing said changes after being received.

15. The method of claim 13 wherein:

said extracting further comprises creating a transferred database from said changes to each respective database of said users;

said sending said changes from each of said users further comprises compressing and sending said transferred database as said changes to said initiating user; and

said replicating said changes from each of said users further comprises decompressing said transferred database in order to replicate said changes to said database of said initiating user.

16. The method of claim 13 wherein:

said sending said changes on said database further comprises creating a transferred database from said changes to said database of said initiating user and then compressing and sending said transferred database as said changes to each of said databases of each of said users; and

said replicating said changes on a respective database further comprises decompressing said transferred database by each of said users in order to replicate said changes of all said users on each of said user'"'"'s databases.

17. The method of claim 13 wherein said sending said changes on said database further comprises transferring said changes on said database in parallel to each of said users.

18. The method of claim 13 wherein said extracting is responsive to receiving a synchronization request from said initiating user.

19. A memory comprising processing information for database synchronization, the processing information operable to, when executed by a computer, cause the computer to:

extract changes from a source database of a first computer of a peer-to-peer network to generate an extracted database,

said peer-to-peer network comprising a plurality of computers,

each of said plurality of computers configured to initiate and perform parallel synchronization of respective databases on each of said plurality of computers without mediation by a server and without asynchronous storage of interim reference data sets;

transfer said extracted database from said first computer to a second computer of said peer-to-peer network; and

replicate said source database on a target database of said second computer from said extracted database in order to synchronize said target database with said source database,

wherein said extracting, said transferring, and said replicating occur without mediation by a server and without asynchronous storage of interim reference data sets.

20. The memory of claim 19 wherein said processing information further operable to, when executed by the computer, cause the computer to:

compress said extracted database to generate a compressed extracted database subsequent to said extracting; and

decompress said compressed extracted database on said second computer to generate a decompressed extracted database subsequent to said transferring.

21. The memory of claim 20 wherein said processing information is further operable to, when executed by the computer, cause the computer to expunge said extracted database from said first computer after said compressed extracted database is generated.

22. The memory of claim 20 wherein said processing information is further operable to, when executed by the computer, cause the computer to expunge said compressed extracted database from said first computer after said transferring from said first computer to said second computer.

23. The memory of claim 20 wherein said processing information is further operable to, when executed by the computer, cause the computer to expunge said extracted database on said second computer after said decompressed database has been generated.

24. The memory of claim 20 wherein said processing information is further operable to, when executed by the computer, cause the computer to expunge said decompressed database on said second computer after it has been replicated on said target database.

25. The memory of claim 20 wherein said processing information is further operable to, when executed by the computer, cause the computer to decompress said compressed extracted database in a manner complementary to said compressing.

26. The memory of claim 19 wherein said peer-to-peer network comprises a wireless network.

27. The memory of claim 19 wherein said peer-to-peer network comprises a wired network.

28. The memory of claim 19 wherein said processing information is further operable to, when executed by the computer, cause the computer to:

extract changes from said target database of said target computer to generate an extracted target database;

transfer said extracted target database from said second computer to said first computer; and

replicate said target database on said source database of said first computer from said extracted target database in order to synchronize said source database with said target database.

29. The memory of claim 28 wherein said processing information is further operable to, when executed by the computer, cause the computer to:

compress said extracted target database to generate a compressed extracted target database subsequent to said extracting changes from said target database; and

decompress said compressed extracted target database on said first computer to generate a decompressed target database subsequent to said transferring said extracted target database from said second computer.

30. The memory of claim 19 wherein said plurality of computers comprises an initiating computer;

and said extracting is responsive to receiving a synchronization request from said initiating computer.

31. A memory comprising processing information for database synchronization, the processing information operable to, when executed by a computer, cause the computer to:

extract changes from a respective database of each of a plurality of users in a peer-to-peer network,

said peer-to-peer network comprising a plurality of computers, each of said plurality of computers configured to initiate and perform parallel synchronization of respective databases on each of said plurality of computers without mediation by a server and without asynchronous storage of interim reference data sets, one of said plurality of

users being an initiating user;

send said changes from each of said users to said initiating user;

replicate said changes from each of said users onto said database of said initiating user;

send said changes on said database of said initiating user to each of said other users; and

replicate said changes on a respective database of each user in order to synchronize said databases of all of said users,

wherein said extracting, said sending said changes from each of said users,

said replicating said changes from each of said users,

said sending said changes on said database, and

said replicating said changes on a respective database occur without mediation by a server and without asynchronous storage of interim reference data sets.

32. The memory of claim 31 wherein said processing information is further operable to, when executed by the computer, cause the computer to compress said changes prior to sending them and decompress said changes after being received.

33. The memory of claim 31 wherein said processing information is further operable to, when executed by the computer, cause the computer to:

create a transferred database from said changes to each respective database of said users;

compress and send said transferred database as said changes to said initiating user; and

decompress said transferred database in order to replicate said changes to said database of said initiating user.

34. The memory of claim 31 wherein said processing information is further operable to, when executed by the computer, cause the computer to:

create a transferred database from said changes to said database of said initiating user and then compressing and sending said transferred database as said changes to each of said databases of each of said users; and

decompress said transferred database by each of said users in order to replicate said changes of all said users on each of said user'"'"'s databases.

35. The memory of claim 31 wherein said processing information is further operable to, when executed by the computer, cause the computer to transfer said changes on said database in parallel to each of said users.

36. The memory of claim 31 wherein said processing information is further operable to, when executed by the computer, cause the computer to extract said changes in response to receiving a synchronization request from said initiating user.

37. An apparatus for database synchronization, the apparatus comprising:

means for extracting changes from a source database of a first computer of a peer-to-peer network to generate an extracted database;

means for transferring said extracted database from said first computer to a second computer of said peer-to-peer network; and

means for replicating said source database on a target database of said second computer from said extracted database in order to synchronize said target database with said source database,

wherein said extracting, said transferring, and said replicating occur without mediation by a server and without asynchronous storage of interim reference data sets.

38. The apparatus of claim 37, further comprising:

means for compressing said extracted database to generate a compressed extracted database subsequent to said extracting; and

means for decompressing said compressed extracted database on said second computer to generate a decompressed extracted database subsequent to said transferring.

39. The apparatus of claim 38, further comprising means for expunging said extracted database from said first computer after said compressed extracted database is generated.

40. The apparatus of claim 38, further comprising means for expunging said compressed extracted database from said first computer after said transferring from said first computer to said second computer.

41. The apparatus of claim 38, further comprising means for expunging said extracted database on said second computer after said decompressed database has been generated.

42. The apparatus of claim 38, further comprising means for expunging said decompressed database on said second computer after it has been replicated on said target database.

43. The apparatus of claim 38 wherein said means for decompressing comprises means for decompressing said compressed extracted database in a manner complementary to said compressing.

44. The apparatus of claim 37 wherein said peer-to-peer network comprises a wireless network.

45. The apparatus of claim 37 wherein said peer-to-peer network comprises a wired network.

46. The apparatus of claim 37, further comprising:

means for extracting changes from said target database of said target computer to generate an extracted target database;

means for transferring said extracted target database from said second computer to said first computer; and

means for replicating said target database on said source database of said first computer from said extracted target database in order to synchronize said source database with said target database.

47. The apparatus of claim 46, further comprising:

means for compressing said extracted target database to generate a compressed extracted target database subsequent to said extracting changes from said target database; and

means for decompressing said compressed extracted target database on said first computer to generate a decompressed target database subsequent to said transferring said extracted target database from said second computer.

48. The apparatus of claim 37 wherein

said plurality of computers comprises an initiating computer;

and

said means for extracting is responsive to receiving a synchronization request from said initiating computer.

49. An apparatus for database synchronization, the apparatus comprising:

means for extracting changes from a respective database of each of said a plurality of users in a peer-to-peer network, one of said plurality of users being an initiating user;

means for sending said changes from each of said users to said initiating user;

means for replicating said changes from each of said users onto said database of said initiating user;

means for sending said changes on said database of said initiating user to each of said other users; and

means for replicating said changes on a respective database of each user in order to synchronize said databases of all of said users,

wherein said extracting, said sending said changes from each of said users,

said replicating said changes from each of said users,

said sending said changes on said database, and

said replicating said changes on a respective database occur without mediation by a server and without asynchronous storage of interim reference data sets.

50. The apparatus of claim 49, further comprising means for compressing said changes prior to sending them and decompressing said changes after being received.

51. The apparatus of claim 49 wherein:

said means for extracting further comprises means for creating a transferred database from said changes to each respective database of said users;

said means for sending said changes from each of said users further comprises means for compressing and sending said transferred database as said changes to said initiating user; and

said means for replicating said changes from each of said users further comprises means for decompressing said transferred database in order to replicate said changes to said database of said initiating user.

52. The apparatus of claim 49 wherein:

said means for sending said changes on said database further comprises means for creating a transferred database from said changes to said database of said initiating user and then compressing and sending said transferred database as said changes to each of said databases of each of said users; and

said means for replicating said changes on a respective database further comprises means for decompressing said transferred database by each of said users in order to replicate said changes of all said users on each of said user'"'"'s databases.

53. The apparatus of claim 49 wherein said means for sending said changes on said database further comprises means for transferring said changes on said database in parallel to each of said users.

54. The apparatus of claim 49 wherein said means for extracting is responsive to receiving a synchronization request from said initiating user.

55. A system for database synchronization, the system comprising:

a plurality of computers in a peer-to-peer network,

wherein one of said computers is designated an initiating computer,

each of said plurality of computers configured to initiate and perform parallel synchronization of respective databases on each of said plurality of computers,

each of said plurality of computers having a database and configured to,

without mediation by a server and without asynchronous storage of interim reference data sets;

extract changes from a source database of each computer of said users;

send changes from each of said user'"'"'s computers in said peer-to-peer network to said initiating replicate said changes from each of said databases of said user'"'"'s computers onto said database of said initiating computer;

extract all of said changes from said database of said initiating computer; and

replicate said changes on a respective database of each of said users in order to synchronize all databases.

56. The system of claim 55 wherein each of said plurality of computers is configured to send said changes to said other users in parallel.

57. The system of claim 55 wherein each of said plurality of computers is further configured to extract said changes from said source database in response to receiving a synchronization request from said initiating computer.