Cluster-wide visible work coordination system using system B-trees

1 . A method, comprising:

implementing, by a system comprising a processor, an exclusive lock in a lock domain that identifies a data structure representative of a system B-tree (SBT) of an SBT system;

updating, by the system, an SBT generation number associated with the SBT, resulting in a first version of the SBT generation number;

executing, by the system, in response to execution of a lock loss call back at the SBT, a comparison of the first version of the SBT generation number with a second version of the SBT generation number to determine a change of version of the SBT generation number; and

identifying, by the system, a work assignment associated with the change of version of the SBT generation number.

2 . The method of claim 1 , further comprising:

generating, by the system, a notification that the work assignment has been selected for execution by a claiming entity.

3 . The method of claim 1 , further comprising:

updating, by the system, the first version of the SBT generation number to the second version of the SBT generation number in response to insertion of the work assignment into the data structure representative of the SBT.

4 . The method of claim 1 , further comprising:

releasing, by the system, an exclusive lock in the lock domain causing the execution of the lock loss call back at the SBT.

5 . The method of claim 1 , further comprising:

enabling subscription, by the system, by a client entity to the SBT; and

enabling observation, by the system, by the client entity of the data structure representative of the SBT for any change of version of the SBT generation number associated with the SBT.

6 . The method of claim 5 , further comprising:

in response to the change of version of the SBT generation number, flashing, by the service manager, a lock associated with the SBT;

storing, by the service manager, second information in the data structure, wherein the second information is representative of a status associated with the work assignment; and

comparing, by the service manager, the second information with first information having already been obtained regarding the work assignment.

7 . The method of claim 6 , further comprising:

generating, by an evaluator of the system, a log of progress of the work assignment, based on the second information and the first information, wherein the log is disposed external to the SBT system.

8 . The method of claim 1 , further comprising:

subscribing, by an evaluator of the system, to the SBT;

observing, by the evaluator, the data structure representative of the SBT for any change of version of the SBT generation number associated with the SBT;

obtaining, by the evaluator, an exclusive lock associated with the SBT; and

marking, by the evaluator, in the data structure representative of the SBT, the work assignment as expired.

9 . A system, comprising:

a processor, and a memory that stores executable instructions that, when executed by the processor, facilitate performance of operations, comprising:

obtaining information associated with a work assignment that is available for execution;

writing data to an envelope of a leaf, of a system B-tree (SBT) of an SBT system, comprising the information associated with the work assignment, wherein the envelope is comprised by a cache associated with the leaf, and wherein the writing data to the envelope comprises updating an SBT generation number associated with the leaf; and

generating a notification that the work assignment is available.

10 . The system of claim 9 , wherein the operations further comprise:

monitoring the SBT system for changes to SBT generation numbers associated with the SBTs; and

identifying a change in the SBT generation number of the SBT generation numbers.

11 . The system of claim 10 , wherein the operations further comprise:

flashing a lock associated with the leaf; and

in response to flashing the lock, obtaining read access to the leaf.

12 . The system of claim 9 , wherein the operations further comprise:

making a configuration change comprising indicating, at the envelope, that the work assignment has been claimed.

13 . The system of claim 9 , wherein the writing the data to the envelope comprises writing the data as a key/value pair.

14 . The system of claim 13 , wherein higher order bytes of the key/value pair comprise a device identifier (ID) of a node being addressed by the work assignment, and wherein lower order bytes of the key/value pair comprise the SBT generation number.

15 . The system of claim 9 , wherein the operations further comprise:

monitoring states of work assignments associated with the SBT system, comprising the work assignment; and

based on the monitoring, generating a log of work assignments, wherein the log is accessible external to the SBT system.

16 . The system of claim 15 , wherein the operations further comprise:

flashing a lock associated with one of the SBTs that is associated with a failed work assignment, other than the work assignment; and

marking the failed work assignment as expired at a respective envelope of the one of the SBTs that is associated with the failed work assignment.

17 . A non-transitory machine-readable medium, comprising executable instructions that, when executed by a processor facilitate performance of operations, comprise:

based on a subscription to a system B-tree (SBT) of an SBT system, monitoring the SBT for a change to a generation number associated with the SBT; and

assigning a work assignment to a work node based on determining that the change to the generation number associated with the SBT has occurred.

18 . The non-transitory machine-readable medium of claim 17 , wherein the operations further comprise:

caching information from the SBT associated with the work assignment in response to the determining that the change to the generation number associated with the SBT has occurred.

19 . The non-transitory machine-readable medium of claim 17 , wherein the operations further comprise:

in response to determining that the change to the generation number associated with the SBT has occurred, flashing a lock associated with the SBT and subsequently reading information of a key/value pair associated with the work assignment.

20 . The non-transitory machine-readable medium of claim 19 , wherein first bytes of a first order of the key/value pair comprise a device ID of a node being addressed by the work assignment and second bytes of a second order of the key/value pair comprise a generation number of the SBT.