ZERO DATA LOSS TRANSFER PROTOCOL

• US 20150378845A1
• Filed: 07/29/2014
• Published: 12/31/2015
• Est. Priority Date: 06/26/2014
• Status: Active Grant

• Current Assignee: Sybase Incorporated (SAP SE)
• Original Assignee: Sybase Incorporated (SAP SE)
• Inventors: Shang, Heping, Lo, Ming-Chen, Lora-Gallardo, Elena, Dai, Xia-ge
• Granted Patent: US 10,423,498 B2
• Time in Patent Office: Days
• US Class Current: 1/1
• CPC Class Codes: G06F 11/1471 involving logging of persistent data for recovery
• CPC Class Codes: G06F 11/1474 in transactions G06F16/20 takes precedence
• CPC Class Codes: G06F 11/165 with continued operation after detection of the error
• CPC Class Codes: G06F 11/2012 and using different communication protocols
• CPC Class Codes: G06F 11/2082 Data synchronisation
• CPC Class Codes: G06F 11/2094 Redundant storage or storage space G06F11/2056 takes precedence
• CPC Class Codes: G06F 16/1865 Transactional file systems
• CPC Class Codes: G06F 16/2308 Concurrency control transaction processing G06F9/466
• CPC Class Codes: G06F 2201/80 Database-specific techniques
• CPC Class Codes: G06F 2201/84 Using snapshots, i.e. a logical point-in-time copy of the data
• CPC Class Codes: G06F 2201/85 Active fault masking without idle spares active fault masking without idle spare hardware where processing functionality is redundant G06F11/2035

Abstract

A method for reliable data synchronization within a network is disclosed. The producer system stories data in a persistent data store and produces one or more data updates. The producer system simultaneously transmits the data updates to a consumer system and initiating storage of the data updates at the producer system. When storage of the data updates at the producer system is complete, the producer system transmits a first acknowledgment to the consumer system. The producer system determines whether a second acknowledgment has been received from the consumer system, wherein the second acknowledgment indicates that the consumer system has successfully stored the data updates at the consumer system. In accordance with a determination that the second acknowledgment has been received from the consumer system, the producer system changes the temporary status of the data updates stored at the producer system to a permanent status.

Claims

1. A method comprising:

storing data in a persistent data store of a producer system;

producing, using one or more processors at the producer system, one or more data updates;

simultaneously transmitting the data updates to a consumer system and initiating storage of the data updates at the producer system, wherein the data updates are initially stored with a temporary status;

when storage of the data updates at the producer system is complete, transmitting a first acknowledgment to the consumer system indicating that the data updates have been stored successfully in the persistent data storage associated with the producer system;

determining whether a second acknowledgment has been received from the consumer system, wherein the second acknowledgment indicates that the consumer system has successfully stored the data updates at the consumer system; and

in accordance with a determination that the second acknowledgment has been received from the consumer system, changing the temporary status of the data updates stored at the producer system to a permanent status.

2. The method of claim 1, wherein prior to receiving the second acknowledgment from the consumer system, receiving a third acknowledgement from the consumer system, wherein the third acknowledgement indicates receipt of the data updates.

3. The method of claim 1, wherein the persistent storage associated with the producer system includes a case transaction log.

4. The method of claim 1, wherein the persistent storage associated with the consumer system includes a simple persistent queue.

5. The method of claim 1, wherein, if the producer system detects failure of the consumer system prior to receiving the second acknowledgement, the producer system retransmits the data updates to the consumer system.

6. The method of claim 1, wherein the producer system interacts with a plurality of consumer systems and continues to interact with the plurality of consumer systems while waiting for the second acknowledgement from the consumer system.

7. The method of claim 1, wherein the one or more data updates include an updated version of the one or more data items stored in the persistent data storage of the producer system.

8. The method of claim 1, further including:

storing a transaction log at the producer system, wherein the transaction log includes a list of changes made to the data stored on the producer system.

9. The method of claim 8, wherein the produced data updates include a log of changes made to the data stored on the producer system.

10. The method of claim 9, wherein storing the data updates at the producer system further includes:

storing the data updates to a data storage associated with the producer system; and

storing the list of changes associated with the data updates to the transaction log stored at producer system.

11. The method of claim 9, wherein transmitting the data updates to a consumer system further includes transmitting a list of changes to the data at the consumer system.

12. A system comprising:

one or more processors;

memory; and

one or more programs stored in the memory, the one or more programs comprising instructions for;

storing data in a persistent data storage of a producer system;

producing, at one or more processors at the producer system, one or more data updates;

simultaneously transmitting the data updates to a consumer system and initiating storage of the data updates in a change log associated with the producer system;

when storage of the data updates in the change log associated with the producer system is complete, transmitting a first acknowledgment to the consumer;

determining whether a second acknowledgment has been received from the consumer system, wherein the second acknowledgment indicates that the consumer system has successfully stored the data updates in a change log associated with the consumer system;

in accordance with a determination that the second acknowledgment has been received from the consumer system, permanently store the data updates in the persistent data storage.

13. The system of claim 12, wherein prior to receiving the second acknowledgment from the consumer system, receiving a third acknowledgement from the consumer system, wherein the third acknowledgement indicates receipt of the data updates.

14. The system of claim 12, wherein the change associated with the producer system includes a case transaction log.

15. The system of claim 12, wherein the change log associated with the consumer system includes a simple persistent queue.

16. The system of claim 12, wherein, if the producer system detects failure of the consumer system prior to receiving the second acknowledgement, the producer system retransmits the data updates to the consumer system.

17. A non-transitory computer readable storage medium storing one or more programs for execution by one or more processors, the one or more programs comprising instructions for:

storing one or more data items in a persistent data storage of a producer system;

producing, at one or more processors at the producer system, one or more data updates;

simultaneously transmitting a log of the data updates to a consumer system and initiating storage of the data updates in the persistent storage associated with the producer system;

when storage of the data updates in the persistent storage associated with the producer system is complete, transmitting a first acknowledgment to the consumer system;

determining whether a second acknowledgment has been received from the consumer system, wherein the second acknowledgment indicates that the consumer system has successfully stored the log of the data updates in a change log associated with the consumer system; and

in accordance with a determination that the second acknowledgment has been received from the consumer system, permanently store the data updates in the persistent data storage.

18. The non-transitory computer readable storage medium of claim 17, wherein prior to receiving the second acknowledgment from the consumer system, receiving a third acknowledgement from the consumer system, wherein the third acknowledgement indicates receipt of the log of the data updates.

19. The non-transitory computer readable storage medium of claim 17, wherein the persistent storage associated with the producer system includes a case transaction log.

20. The non-transitory computer readable storage medium of claim 17, wherein the change associated with the consumer system includes a simple persistent queue.