System and Method for Managing Replicas of Objects In A Distributed Storage System

• US 20110196830A1
• Filed: 02/07/2011
• Published: 08/11/2011
• Est. Priority Date: 02/09/2010
• Status: Active Grant

• Current Assignee: Google LLC (Alphabet Inc.)
• Original Assignee: Google Inc. (Alphabet Inc.)
• Inventors: Kessleman, Alexander, Datuashvili, George, Zunger, Yonatan, Drobychev, Alexandre, Vickrey, Rebekah C., Dachille, Frank C.
• Granted Patent: US 8,352,424 B2
• Time in Patent Office: Days
• US Class Current: 707/624
• CPC Class Codes: G06F 11/2094 Redundant storage or storage space G06F11/2056 takes precedence
• CPC Class Codes: G06F 11/3457 Performance evaluation by simulation
• CPC Class Codes: G06F 13/10 Program control for peripheral devices G06F13/14 - G06F13/42 take precedence
• CPC Class Codes: G06F 16/1748 De-duplication implemented within the file system, e.g. based on file segments de-duplication techniques in storage systems for the management of data blocks G06F3/0641
• CPC Class Codes: G06F 16/1844 Management specifically adapted to replicated file systems
• CPC Class Codes: G06G 7/62 for electric systems or apparatus G06G7/78 takes precedence
• CPC Class Codes: H04L 67/1095 Replication or mirroring of data, e.g. scheduling or transport for data synchronisation between network nodes
• CPC Class Codes: H04L 67/1097 for distributed storage of data in networks, e.g. transport arrangements for network file system [NFS], storage area networks [SAN] or network attached storage [NAS]

Abstract

A system and method for generating replication requests for objects in a distributed storage system is provided. Replication requests for objects in a distributed storage system are generated based at least in part on replication policies for the objects and a current state of the distributed storage system, wherein a respective replication request for a respective object instructs a respective instance of the distributed storage system to replicate the respective object so as to at least partially satisfy a replication policy for the respective object, wherein a respective replication policy includes criteria specifying at least storage device types on which replicas of object are to be stored. At least a subset of the replication requests is then distributed to the respective instances of the distributed storage system for execution.

Claims

1. A computer-implemented method for generating replication requests for objects in a distributed storage system, comprising:

at a computer system including one or more processors and memory storing one or more programs, for execution by the one or more processors;

generating replication requests for objects in a distributed storage system based at least in part on replication policies for the objects and a current state of the distributed storage system, wherein a respective replication request for a respective object instructs a respective instance of the distributed storage system to replicate the respective object so as to at least partially satisfy a replication policy for the respective object, wherein a respective replication policy includes criteria specifying at least storage device types on which replicas of object are to be stored; and

distributing at least a subset of the replication requests to the respective instances of the distributed storage system for execution.

2. The method of claim 1, wherein prior to distributing at least the subset of the replication requests to the respective instances of the distributed storage system for execution, the method further comprises partitioning the replication requests into groups of respective replication requests corresponding to respective instances of the distributed storage system at which the respective replication requests are to be performed.

3. The method of claim 2, wherein prior to distributing the at least the subset of the replication requests to the respective instances of the distributed storage system, the method further comprises:

calculating priorities of the replication requests; and

for a respective group of replication requests, sorting the replication requests in the group of replication requests by priority to produce a sorted group of replication requests.

4. The method of claim 3, wherein calculating a priority of a respective replication request includes calculating the priority of the respective replication request as a difference between a metric corresponding to a benefit of performing the respective replication request and a metric corresponding to a cost of performing the respective replication request.

5. The method of claim 3, wherein prior to distributing a respective subset of replication requests for a respective group of replication requests to a respective instance of the distributed storage system for execution, the method further comprises determining the respective subset of replication requests for the respective group that can be completed within a predetermined time interval.

6. The method of claim 5, wherein the predetermined time interval is the time interval between iterations of the generating, the partitioning, and the distributing.

7. The method of claim 5, further comprising discarding replication requests for the respective group of replication requests that are not included in the subset of replication requests for the respective group of replication requests.

8. The method of claim 3, wherein distributing a respective subset of replication requests for a respective group of replication requests to a respective instance of the distributed storage system for execution includes distributing a respective sorted group of replication requests to the respective instance of the distributed storage system.

9. The method of claim 1, wherein the current state of the distributed storage system includes:

a current network state;

current user quotas for storage space in the distributed storage system;

storage space in the distributed storage system that are currently used by users;

current storage space available at instances of the distributed storage system;

current statuses of replication queues at instances of the distributed storage system;

current planned maintenance operations zones; and

a list of current replicas of objects in the distributed storage system.

10. The method of claim 1, wherein a replication policy for an object includes criteria selected from the group consisting of:

a minimum number of replicas of the object that must be present in the distributed storage system;

a maximum number of the replicas of the object that are allowed to be present in the distributed storage system;

storage device types on which the replicas of the object are to be stored;

locations at which the replicas of the object may be stored;

locations at which the replicas of the object may not be stored; and

a range of ages for the object during which the replication policy for the object applies.

11. A system for generating replication requests for objects in a distributed storage system, comprising:

one or more processors;

memory; and

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

generate replication requests for objects in a distributed storage system based at least in part on replication policies for the objects and a current state of the distributed storage system, wherein a respective replication request for a respective object instructs a respective instance of the distributed storage system to replicate the respective object so as to at least partially satisfy a replication policy for the respective object, wherein a respective replication policy includes criteria specifying at least storage device types on which replicas of object are to be stored; and

distribute at least a subset of the replication requests to the respective instances of the distributed storage system for execution.

12. The system of claim 11, wherein prior to the instructions to distribute at least the subset of the replication requests to the respective instances of the distributed storage system for execution, the system includes instructions to partition the replication requests into groups of respective replication requests corresponding to respective instances of the distributed storage system at which the respective replication requests are to be performed.

13. The system of claim 12, wherein prior to the instructions to distribute the at least the subset of the replication requests to the respective instances of the distributed storage system, the system includes instructions to:

calculate priorities of the replication requests; and

for a respective group of replication requests, sort the replication requests in the group of replication requests by priority to produce a sorted group of replication requests.

14. The system of claim 13, wherein the instructions to calculate a priority of a respective replication request include instructions to calculate the priority of the respective replication request as a difference between a metric corresponding to a benefit of performing the respective replication request and a metric corresponding to a cost of performing the respective replication request.

15. The system of claim 13, wherein prior to the instructions to distribute a respective subset of replication requests for a respective group of replication requests to a respective instance of the distributed storage system for execution, the system includes instructions to determine the respective subset of replication requests for the respective group that can be completed within a predetermined time interval.

16. The system of claim 15, wherein the predetermined time interval is the time interval between iterations of the generating, the partitioning, and the distributing.

17. The system of claim 15, further comprising instructions to discard replication requests for the respective group of replication requests that are not included in the subset of replication requests for the respective group of replication requests.

18. The system of claim 13, wherein the instructions to distribute a respective subset of replication requests for a respective group of replication requests to a respective instance of the distributed storage system for execution include instructions to distribute a respective sorted group of replication requests to the respective instance of the distributed storage system.

19. The system of claim 11, wherein the current state of the distributed storage system includes:

a current network state;

current user quotas for storage space in the distributed storage system;

storage space in the distributed storage system that are currently used by users;

current storage space available at instances of the distributed storage system;

current statuses of replication queues at instances of the distributed storage system;

current planned maintenance operations zones; and

a list of current replicas of objects in the distributed storage system.

20. The system of claim 11, wherein a replication policy for an object includes criteria selected from the group consisting of:

a minimum number of replicas of the object that must be present in the distributed storage system;

a maximum number of the replicas of the object that are allowed to be present in the distributed storage system;

storage device types on which the replicas of the object are to be stored;

locations at which the replicas of the object may be stored;

locations at which the replicas of the object may not be stored; and

a range of ages for the object during which the replication policy for the object applies.

21. A non-transitory computer readable storage medium storing one or more programs configured for execution by a computer, the one or more programs comprising instructions to:

generate replication requests for objects in a distributed storage system based at least in part on replication policies for the objects and a current state of the distributed storage system, wherein a respective replication request for a respective object instructs a respective instance of the distributed storage system to replicate the respective object so as to at least partially satisfy a replication policy for the respective object, wherein a respective replication policy includes criteria specifying at least storage device types on which replicas of object are to be stored; and

distribute at least a subset of the replication requests to the respective instances of the distributed storage system for execution.

22. The computer readable storage medium of claim 21, wherein prior to the instructions to distribute at least the subset of the replication requests to the respective instances of the distributed storage system for execution, the system includes instructions to partition the replication requests into groups of respective replication requests corresponding to respective instances of the distributed storage system at which the respective replication requests are to be performed.

23. The computer readable storage medium of claim 22, wherein prior to the instructions to distribute the at least the subset of the replication requests to the respective instances of the distributed storage system, the system includes instructions to:

calculate priorities of the replication requests; and

for a respective group of replication requests, sort the replication requests in the group of replication requests by priority to produce a sorted group of replication requests.

24. The computer readable storage medium of claim 23, wherein the instructions to calculate a priority of a respective replication request include instructions to calculate the priority of the respective replication request as a difference between a metric corresponding to a benefit of performing the respective replication request and a metric corresponding to a cost of performing the respective replication request.

25. The computer readable storage medium of claim 23, wherein prior to the instructions to distribute a respective subset of replication requests for a respective group of replication requests to a respective instance of the distributed storage system for execution, the system includes instructions to determine the respective subset of replication requests for the respective group that can be completed within a predetermined time interval.

26. The computer readable storage medium of claim 25, wherein the predetermined time interval is the time interval between iterations of the generating, the partitioning, and the distributing.

27. The computer readable storage medium of claim 25, further comprising instructions to discard replication requests for the respective group of replication requests that are not included in the subset of replication requests for the respective group of replication requests.

28. The computer readable storage medium of claim 23, wherein the instructions to distribute a respective subset of replication requests for a respective group of replication requests to a respective instance of the distributed storage system for execution include instructions to distribute a respective sorted group of replication requests to the respective instance of the distributed storage system.

29. The computer readable storage medium of claim 21, wherein the current state of the distributed storage system includes:

a current network state;

current user quotas for storage space in the distributed storage system;

storage space in the distributed storage system that are currently used by users;

current storage space available at instances of the distributed storage system;

current statuses of replication queues at instances of the distributed storage system;

current planned maintenance operations zones; and

a list of current replicas of objects in the distributed storage system.

30. The computer readable storage medium of claim 21, wherein a replication policy for an object includes criteria selected from the group consisting of:

a minimum number of replicas of the object that must be present in the distributed storage system;

a maximum number of the replicas of the object that are allowed to be present in the distributed storage system;

storage device types on which the replicas of the object are to be stored;

locations at which the replicas of the object may be stored;

locations at which the replicas of the object may not be stored; and

a range of ages for the object during which the replication policy for the object applies.