USER INITIATED REPLICATION IN A SYNCHRONIZED OBJECT REPLICATION SYSTEM

• US 20130325803A1
• Filed: 06/05/2012
• Published: 12/05/2013
• Est. Priority Date: 06/05/2012
• Status: Active Grant

• Current Assignee: International Business Machines Corporation
• Original Assignee: International Business Machines Corporation
• Inventors: BACHAR, Yariv, AKIRAV, Shay, EDELSTEIN, Ron, LEVY, Asaf, SONIN, Oded
• Granted Patent: US 9,430,542 B2
• Time in Patent Office: Days
• US Class Current: 707/634
• CPC Class Codes: G06F 11/1451 by selection of backup contents
• CPC Class Codes: G06F 11/1464 for networked environments
• CPC Class Codes: G06F 16/2246 Trees, e.g. B+trees
• CPC Class Codes: G06F 16/27 Replication, distribution or synchronisation of data between databases or within a distributed database system; Distributed database system architectures therefor
• CPC Class Codes: G06F 16/273 Asynchronous replication or reconciliation
• CPC Class Codes: G06F 16/275 Synchronous replication

Abstract

A snapshot of selected objects in a source repository is created in response to the user-initiated replication. The snapshot is designated as a snapshot replication job. The snapshot replication job is added to the end of a replication queue to await execution for the synchronized object replication. Unsynchronized objects in a target destination are detected by comparing a state of the selected objects in the snapshot with a current state of the target destination at the time of execution of the snapshot replication job. The unsynchronized objects in the target destination are synchronized based upon the comparison of the state of the selected objects in the snapshot with the current state of the target destination at the time of execution of the snapshot replication job.

Claims

1. A method for user initiated replication in a synchronized object replication system in a computing environment using a processor device, comprising:

creating a snapshot of selected objects in a source repository in response to the user initiated replication, wherein the snapshot is designated as a snapshot replication job;

adding the snapshot replication job to an end of a replication queue to await execution for the synchronized object replication; and

detecting unsynchronized objects in a target destination by comparing a state of the selected objects in the snapshot with a current state of the target destination at the time of execution of the snapshot replication job, wherein the unsynchronized objects in the target destination are synchronized based upon the comparison of the state of the selected objects in the snapshot with the current state of the target destination at the time of execution of the snapshot replication job.

2. The method of claim 1, further including, performing one of:

if an operation occurs prior to the creating, replicating the operation prior to replication the snapshot replication job, and

if an operation occurs after the creating, replicating the operation after replicating the snapshot replication job.

3. The method of claim 2, further including, separating the operation into a data operation and a metadata operation, wherein the data operation is one of a write new data and deletion of old data, and the metadata operation is one of changing metadata of a node and changing a tree structure.

4. The method of claim 1, wherein the comparing includes comparing a lightweight representation of the selected objects rather than all data in a set of the selected objects.

5. The method of claim 1, further including, in conjunction with the comparison, traversing the snapshot by comparing at least one of a tree structure, data, and metadata of the snapshot with objects in the target destination.

6. The method of claim 1, further including, in conjunction with the execution of the snapshot replication job, performing one of:

retrieving in an ordered manner at least one object of the selected objects from the snapshot,

sending an object identification (ID) and a state ID of the at least one object to the target destination,

searching for the object ID in the target destination, wherein if the object ID is located, the state ID of the at least one object is compared with a current state ID of the target destination, and

if neither the object ID exists in the target destination and the state ID of the at least one object and the current state ID of the target destination do not match, replication tasks are opened for replicating data and metadata of the at least one object to the target destination.

7. The method of claim 1, further including, in conjunction with the user initiated replication of the selected objects, replicating the selected objects independent of an actual synchronized state of the selected objects.

8. The method of claim 1, further including, in conjunction with the user initiated replication of the selected objects, replicating the selected objects independent of at least one of a replication procedure, a protocol, a file system layout, and an implementation.

9. A system for user initiated replication in a synchronized object replication system in a computing environment, comprising:

at least one processor device operable in the computing environment, wherein the at least one processor device is adapted for;

creating a snapshot of selected objects in a source repository in response to the user initiated replication, wherein the snapshot is designated as a snapshot replication job,

adding the snapshot replication job to an end of a replication queue to await execution for the synchronized object replication, and

detecting unsynchronized objects in a target destination by comparing a state of the selected objects in the snapshot with a current state of the target destination at the time of execution of the snapshot replication job, wherein the unsynchronized objects in the target destination are synchronized based upon the comparison of the state of the selected objects in the snapshot with the current state of the target destination at the time of execution of the snapshot replication job.

10. The system of claim 9, wherein the at least one processor device is further adapted for performing one of:

if an operation occurs prior to the creating, replicating the operation prior to replication the snapshot replication job, and

if an operation occurs after the creating, replicating the operation after replicating the snapshot replication job.

11. The system of claim 10, wherein the at least one processor device is further adapted for separating the operation into a data operation and a metadata operation, wherein the data operation is one of a write new data and deletion of old data, and the metadata operation is one of changing metadata of a node and changing a tree structure.

12. The system of claim 9, wherein the at least one processor device is further adapted for, in conjunction with the comparison, comparing a lightweight representation of the selected objects rather than all data in a set of the selected objects.

13. The system of claim 9, wherein the at least one processor device is further adapted for, in conjunction with the comparison, traversing the snapshot by comparing at least one of a tree structure, data, and metadata of the snapshot with objects in the target destination.

14. The system of claim 9, wherein the at least one processor device is further adapted for, in conjunction with the execution of the snapshot replication job, performing one of:

retrieving in an ordered manner at least one object of the selected objects from the snapshot,

sending an object identification (ID) and a state ID of the at least one object to the target destination,

searching for the object ID in the target destination, wherein if the object ID is located, the state ID of the at least one object is compared with a current state ID of the target destination, and

if neither the object ID exists in the target destination and the state ID of the at least one object and the current state ID of the target destination do not match, replication tasks are opened for replicating data and metadata of the at least one object to the target destination.

15. The system of claim 9, wherein the at least one processor device is further adapted for, in conjunction with the user initiated replication of the selected objects, replicating the selected objects independent of an actual synchronized state of the selected objects.

16. The system of claim 9, wherein the at least one processor device is further adapted for, in conjunction with the user initiated replication of the selected objects, replicating the selected objects independent of at least one of a replication procedure, a protocol, a file system layout, and an implementation.

17. A computer program product for user initiated replication in a synchronized object replication system in a computing environment using a processor device, the computer program product comprising a computer-readable storage medium having computer-readable program code portions stored therein, the computer-readable program code portions comprising:

a first executable portion for creating a snapshot of selected objects in a source repository in response to the user initiated replication, wherein the snapshot is designated as a snapshot replication job;

a second executable portion for adding the snapshot replication job to an end of a replication queue to await execution for the synchronized object replication; and

a third executable portion for detecting unsynchronized objects in a target destination by comparing a state of the selected objects in the snapshot with a current state of the target destination at the time of execution of the snapshot replication job, wherein the unsynchronized objects in the target destination are synchronized based upon the comparison of the state of the selected objects in the snapshot with the current state of the target destination at the time of execution of the snapshot replication job.

18. The computer program product of claim 17, further including a fourth executable portion for, performing one of:

if an operation occurs prior to the creating, replicating the operation prior to replication the snapshot replication job, and

if an operation occurs after the creating, replicating the operation after replicating the snapshot replication job.

19. The computer program product of claim 18, further including a fifth executable portion for separating the operation into a data operation and a metadata operation, wherein the data operation is one of writing new data and deleting old data, and the metadata operation is one of changing metadata of a node and changing a tree structure.

20. The computer program product of claim 17, further including a fourth executable portion for, in conjunction with the comparison, comparing a lightweight representation of the selected objects rather than all data in a set of the selected objects.

21. The computer program product of claim 17, further including a fourth executable portion for, in conjunction with the comparison, traversing the snapshot by comparing at least one of a tree structure, data, and metadata of the snapshot with objects in the target destination.

22. The computer program product of claim 17, further including a fourth executable portion for, in conjunction with the execution of the snapshot replication job, performing one of:

retrieving in an ordered manner at least one object of the selected objects from the snapshot,

sending an object identification (ID) and a state ID of the at least one object to the target destination,

searching for the object ID in the target destination, wherein if the object ID is located, the state ID of the at least one object is compared with a current state ID of the target destination, and

if neither the object ID exists in the target destination and the state ID of the at least one object and the current state ID of the target destination do not match, replication tasks are opened for replicating data and metadata of the at least one object to the target destination.

23. The computer program product of claim 17, further including a fourth executable portion for, in conjunction with the user initiated replication of the selected objects, replicating the selected objects independent of an actual synchronized state of the selected objects.

24. The computer program product of claim 17, further including a fourth executable portion for, in conjunction with the user initiated replication of the selected objects, replicating the selected objects independent of at least one of a replication procedure, a protocol, a file system layout, and an implementation.