Prioritization of messages of a dispersed storage network
First Claim
1. A method for execution by a computing device, the method comprises:
- storing a plurality of sets of messages in a set of queues corresponding to a set of storage nodes, wherein a set of messages of the plurality of sets of messages is associated with a set of encoded data slices, wherein a data segment of data is encoded using a dispersed storage error coding function to produce the set of encoded data slices and wherein a queue of the set of queues stores a group of messages that includes a message from each of at least some of the plurality of sets of messages for a particular storage unit of the set of storage nodes;
on a queue by queue basis, prioritizing the group of messages based on a queue prioritization scheme;
as the plurality of sets of messages are processed by the set of storage nodes, updating, on the queue by queue basis, the prioritizing of the group of messages based on the processing of the plurality of sets of messages by the set of storage nodes;
for a message of a first group of messages, sending the message of the first group of messages to a first storage node of the set of storage nodes in accordance with the prioritizing of the group of messages for the first storage node; and
for a message of a second group of messages, sending the message of the second group of messages to a second storage node of the set of storage nodes in accordance with the prioritizing of the group of messages for the second storage node.
5 Assignments
0 Petitions
Accused Products
Abstract
A method begins by a dispersed storage (DS) processing module generating a set of messages regarding a set of encoded data slices. For a first message of the set of messages, the method continues with the DS processing module determining a first message priority based on system-level message processing information and message processing status of a first storage node. For a second message of the set of messages, the method continues with the DS processing module determining a second message priority based on the system-level message processing information and message processing status of a second storage node. The method continues with the DS processing module sending the first message of the set of messages to the first storage node in accordance with the first message priority and sending the second message of the set of messages to the second storage node in accordance with the second message priority.
97 Citations
18 Claims
-
1. A method for execution by a computing device, the method comprises:
-
storing a plurality of sets of messages in a set of queues corresponding to a set of storage nodes, wherein a set of messages of the plurality of sets of messages is associated with a set of encoded data slices, wherein a data segment of data is encoded using a dispersed storage error coding function to produce the set of encoded data slices and wherein a queue of the set of queues stores a group of messages that includes a message from each of at least some of the plurality of sets of messages for a particular storage unit of the set of storage nodes; on a queue by queue basis, prioritizing the group of messages based on a queue prioritization scheme; as the plurality of sets of messages are processed by the set of storage nodes, updating, on the queue by queue basis, the prioritizing of the group of messages based on the processing of the plurality of sets of messages by the set of storage nodes; for a message of a first group of messages, sending the message of the first group of messages to a first storage node of the set of storage nodes in accordance with the prioritizing of the group of messages for the first storage node; and for a message of a second group of messages, sending the message of the second group of messages to a second storage node of the set of storage nodes in accordance with the prioritizing of the group of messages for the second storage node. - View Dependent Claims (2, 3, 4, 5, 6, 7, 8, 9)
-
-
10. A dispersed storage (DS) hardware module comprises:
-
a first hardware module, when operable within a computing device, causes the computing device to; store a plurality of sets of messages in a set of queues corresponding to a set of storage nodes, wherein a set of messages of the plurality of sets of messages is associated with a set of encoded data slices, wherein a data segment of data is encoded using a dispersed storage error coding function to produce the set of encoded data slices and wherein a queue of the set of queues stores a group of messages that includes a message from each of at least some of the plurality of sets of messages for a particular storage unit of the set of storage nodes; a second module, when operable within the computing device, causes the computing device to; on a queue by queue basis, prioritizing the group of messages based on a queue prioritization scheme; and as the plurality of sets of messages are processed by the set of storage nodes, updating, on the queue by queue basis, the prioritizing of the group of messages based on the processing of the plurality of sets of messages by the set of storage nodes; a fourth module, when operable within the computing device, causes the computing device to; for a message of a first group of messages, send the message of the first group of messages to a first storage node of the set of storage nodes in accordance with the prioritizing of the group of messages for the first storage node; and for a message of a second group of messages, send the message of the second group of messages to a second storage node of the set of storage nodes in accordance with the prioritizing of the group of messages for the second storage node. - View Dependent Claims (11, 12, 13, 14, 15, 16, 17, 18)
-
Specification