Frame based data replication in a cloud computing environment

• US 9,436,750 B2
• Filed: 11/06/2013
• Issued: 09/06/2016
• Est. Priority Date: 11/06/2013
• Status: Active Grant

• Current Assignee: Verizon Patent and Licensing Incorporated (Verizon Communications Inc.)
• Original Assignee: Verizon Patent and Licensing Incorporated (Verizon Communications Inc.)
• Inventors: Iannicelli, Alex, Chitrapu, Kishore, Bloom, Jeffrey M., Curtis, Paul M.
• Primary Examiner(s): Alam, Shahid
• Assistant Examiner(s): Antoine, Alicia
• Application Number:
  US14/072,988
• Publication Number:
  US 20150127605A1
• Time in Patent Office: 1,035 Days
• Field of Search: 709/25, 711/112, 707/610, 707/638
• US Class Current: 1/1
• CPC Class Codes: G06F 16/10 File systems; File servers
• CPC Class Codes: G06F 16/20 of structured data, e.g. relational data
• 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/93 Document management systems

Abstract

A device may receive information associated with a write operation to be performed on a storage volume included in a cloud computing environment, and may divide the information into a group of write frames. Each write frame may include a respective portion of the information. The device may determine information that identifies members of a replication set associated with the storage volume. The device may provide each write frame to each member. The device may receive a reply frame, associated with a write frame, from a member. The device may determine that the reply frame is a last reply frame associated with the write frame and may modify source information to form a modified reply frame. The device may provide the modified reply frame. The modified reply frame may be provided to indicate that the portion of the write operation, associated with the write frame, has been successfully performed.

Claims

1. A device, comprising:

one or more processors to;

receive information associated with a write operation to be performed on a storage volume included in a cloud computing environment;

divide the information associated with the write operation into a plurality of write frames,

each write frame, of the plurality of write frames, including a respective portion of the information associated with the write operation;

determine information that identifies members of a replication set associated with the storage volume;

provide each write frame to each member of the replication set;

receive a first reply frame, associated with a write frame of the plurality of write frames, from a first member of the replication set;

determine that the first reply frame is not a last reply frame associated with the write frame of the plurality of write frames;

drop the first reply frame based on determining that the first reply frame is not the last reply frame associated with the write frame of the plurality of write frames,

the first reply frame being dropped such that the first reply frame is deleted by the storage volume, and

the first reply frame being dropped to indicate that the write operation, associated with the write frame, is incomplete;

receive a second reply frame, associated with the write frame of the plurality of write frames, from a second member of the replication set,

the second member of the replication set being different from the first member of the replication set;

determine that the second reply frame is the last reply frame associated with the write frame of the plurality of write frames;

modify source information, included in the last reply frame, to form a modified reply frame,

the modified reply frame identifying the storage volume as a source of the modified reply frame rather than the second member of the replication set as the source of the modified reply frame; and

provide the modified reply frame,

the modified reply frame being provided to indicate that a portion of the write operation, corresponding to the write frame, has been successfully performed, and

the modified reply frame being provided to permit a determination that that write operation has been successfully performed.

2. The device of claim 1, where the one or more processors are further to:

receive information associated with an agreement between a user and a service provider of the cloud computing environment;

store the information associated with agreement; and

where the one or more processors, when determining the information that identifies the members of the replication set, are to;

determine the information that identifies the members of the replication set based on the stored information.

3. The device of claim 1, where the one or more processors are further to:

create a first copy of each write frame of the plurality of write frames;

modify the first copy of each write frame to include information that identifies the first member of the replication set;

create a second copy of each write frame of the plurality of write frames;

modify the second copy of each write frame to include information that identifies the second member of the replication set; and

where the one or more processors when providing each write frame to each member of the replication set, are to;

provide the modified first copy of each write frame to the first member of the replication set; and

provide the modified second copy of each write frame to the second member of the replication set.

4. The device of claim 1, where the one or more processors are further to:

store reply count information associated with each write frame based on providing each write frame to each member of the replication set,

the reply count information including a quantity of reply counts equal to a quantity of the plurality of write frames,

each reply count being based on a quantity of members of the replication set.

5. The device of claim 1, where the one or more processors, are further to:

decrement a reply count, associated with the write frame, based on receiving the second reply frame associated with the write frame; and

where the one or more processors, when determining that the second reply frame is the last reply frame associated with the write frame, are to;

determine that the second reply frame is the last reply frame based on the decremented reply count.

6. The device of claim 1, where the one or more processors are further to:

identify the storage volume as a destination associated with the write operation; and

where the one or more processors, when modifying the source information included in the last reply frame to form the modified reply frame that identifies the storage volume as a source of the modified reply frame, are to;

modify the source information to include the information that identifies the storage volume based on identifying the storage volume as the destination associated with the write operation.

7. The device of claim 1, where the one or more processors are further to:

determine that the write operation, associated with the storage volume, has been successfully performed; and

provide information that indicates that the write operation has been successfully performed.

8. A non-transitory computer-readable medium storing instructions, the instructions comprising:

one or more instructions that, when executed by one or more processors, cause the one or more processors to;

receive information associated with a write operation to be performed on a storage volume included in a cloud computing environment;

divide the information associated with the write operation into a plurality of write frames,

each write frame, of the plurality of write frames, including a respective portion of the information associated with the write operation;

determine information that identifies members of a replication set associated with the storage volume;

provide each write frame to each member of the replication set;

receive a first reply frame, associated with a write frame of the plurality of write frames, from a first member of the replication set;

determine that the first reply frame is not a last reply frame associated with the write frame of the plurality of write frames;

drop the first reply frame based on determining that the first reply frame is not the last reply frame associated with the write frame of the plurality of write frames,

the first reply frame being dropped such that the first reply frame is deleted by the storage volume, and

the first reply frame being dropped to indicate that the write operation, associated with the write frame, is incomplete;

receive a second reply frame, associated with the write frame of the plurality of write frames, from a second member of the replication set;

determine that the second reply frame is the last reply frame associated with the write frame of the plurality of write frames,

the second member of the replication set being different from the first member of the replication set;

modify source information, included in the last reply frame, to form a modified reply frame,

the modified reply frame identifying the storage volume as a source of the modified reply frame rather than the second member of the replication set as the source of the modified reply frame; and

provide the modified reply frame,

the modified reply frame being provided to indicate that a portion of the write operation, corresponding to the write frame, has been successfully performed, and

the modified reply frame being provided to permit a determination that that write operation has been successfully performed.

9. The non-transitory computer-readable medium of claim 8, where the one or more instructions, when executed by the one or more processors, further cause the one or more processors to:

receive information associated with an agreement between a user and a service provider of the cloud computing environment;

store the information associated with agreement; and

where the one or more instructions, that cause the one or more processors to determine the information that identifies the members of the replication set, cause the one or more processors to;

determine the information that identifies the members of the replication set based on the stored information.

10. The non-transitory computer-readable medium of claim 8, where the one or more instructions, when executed by the one or more processors, further cause the one or more processors to:

create a first copy of each write frame of the plurality of write frames;

modify the first copy of each write frame to include information that identifies the first member of the replication set;

create a second copy of each write frame of the plurality of write frames;

modify the second copy of each write frame to include information that identifies second member of the replication set; and

where the one or more instructions, that cause the one or more processors to provide each write frame to each member of the replication set, cause the one or more processors to;

provide the modified first copy of each write frame to the first member of the replication set; and

provide the modified second copy of each write frame to the second member of the replication set.

11. The non-transitory computer-readable medium of claim 8, where the one or more instructions, when executed by the one or more processors, further cause the one or more processors to:

store reply count information associated with each write frame based on providing each write frame to each member of the replication set,

the reply count information including a quantity of reply counts equal to a quantity of the plurality of write frames,

each reply count being based on a quantity of members of the replication set.

12. The non-transitory computer-readable medium of claim 8, where the one or more instructions, when executed by the one or more processors, further cause the one or more processors to:

decrement a reply count, associated with the write frame, based on receiving the second reply frame associated with the write frame; and

where the one or more instructions, that cause the one or more processors to determine that the second reply frame is the last reply frame associated with the write frame, cause the one or more processors to;

determine that second the reply frame is the last reply frame based on the decremented reply count.

13. The non-transitory computer-readable medium of claim 8, where the one or more instructions, when executed by the one or more processors, further cause the one or more processors to:

identify the storage volume as a destination associated with the write operation; and

where the one or more instructions, that cause the one or more processors to modify the source information included in the last reply frame to form the modified reply frame that identifies the storage volume as a source of the modified reply frame, cause the one or more processors to;

modify the source information to include the information that identifies the storage volume based on identifying the storage volume as the destination associated with the write operation.

14. The non-transitory computer-readable medium of claim 8, where the one or more instructions, when executed by the one or more processors, further cause the one or more processors to:

determine that the write operation, associated with the storage volume, has been successfully performed; and

provide information that indicates that the write operation has been successfully performed.

15. A method, comprising:

receiving, by a device, information associated with a write operation to be performed on a storage volume included in a cloud computing environment;

dividing, by the device, the information associated with the write operation into a plurality of write frames,

each write frame, of the plurality of write frames, including a respective portion of the information associated with the write operation;

determining, by the device, information that identifies members of a replication set associated with the storage volume;

providing, by the device, each write frame to each member of the replication set;

receiving, by the device, a first reply frame, associated with a write frame of the plurality of write frames, from a first member of the replication set;

determining, by the device, that the first reply frame is not a last reply frame associated with the write frame of the plurality of write frames;

dropping, by the device, the first reply frame based on determining that the first reply frame is not the last reply frame associated with the write frame of the plurality of write frames,

the first reply frame being dropped such that the first reply frame is deleted by the storage volume, and

the first reply frame being dropped to indicate that the write operation, associated with the write frame, is incomplete;

receiving, by the device, a second reply frame, associated with the write frame of the plurality of write frames, from a second member of the replication set,

the second member of the replication set being different from the first member of the replication set;

determining, by the device, that the second reply frame is the last reply frame associated with the write frame of the plurality of write frames;

modifying, by the device, source information, included in the last reply frame, to form a modified reply frame,

the modified reply frame identifying the storage volume as a source of the modified reply frame rather than the second member of the replication set as the source of the modified reply frame; and

providing, by the device, the modified reply frame,

the modified reply frame being provided to indicate that a portion of the write operation, corresponding to the write frame, has been successfully performed, and

the modified reply frame being provided to permit a determination that that write operation has been successfully performed.

16. The method of claim 15, further comprising:

receiving information associated with an agreement between a user and a service provider of the cloud computing environment;

storing the information associated with agreement; and

where determining the information that identifies the members of the replication set comprises;

determining the information that identifies the members of the replication set based on the stored information.

17. The method of claim 15, further comprising:

creating a first copy of each write frame of the plurality of write frames;

modifying the first copy of each write frame to include information that identifies the first member of the replication set;

creating a second copy of each write frame of the plurality of write frames;

modifying the second copy of each write frame to include information that identifies the second member of the replication set; and

where providing each write frame to each member of the replication set comprises;

providing the modified first copy of each write frame to the first member of the replication set; and

providing the modified second copy of each write frame to the second member of the replication set.

18. The method of claim 15, further comprising:

storing reply count information associated with each write frame based on providing each write frame to each member of the replication set,

the reply count information including a quantity of reply counts equal to a quantity of the plurality of write frames,

each reply count being based on a quantity of members of the replication set.

19. The method of claim 15, further comprising:

decrementing a reply count, associated with the write frame, based on receiving the second reply frame associated with the write frame; and

where determining that the second reply frame is the last reply frame associated with the write frame comprises;

determining that the second reply frame is the last reply frame based on the decremented reply count.

20. The method of claim 15, further comprising:

identifying the storage volume as a destination associated with the write operation; and

where modifying the source information included in the last reply frame to form the modified reply frame that identifies the storage volume as a source of the modified reply frame comprises;

modifying the source information to include the information that identifies the storage volume based on identifying the storage volume as the destination associated with the write operation.