Repeatable barrier synchronization object
A method is disclosed comprising: detecting an event that is generated within a storage system; identifying a plurality of barrier objects that are associated with the event, each of the plurality of barrier objects being associated with a different respective set function, each of the plurality of barrier objects being associated with a different respective wait function, and each of the plurality of barrier objects being associated with a different respective release function; calling the respective set function of each of the barrier objects; calling the respective wait function of each of the barrier objects, wherein at least one of the respective wait functions is called before another one of the respective wait functions has returned; reconfiguring the storage system after all of the respective wait functions have returned; and calling the respective release function of each of the barrier objects.
1. A method for use in a storage system, comprising:
detecting an event that is generated within the storage system;
identifying a plurality of barrier objects that are associated with the event, each of the plurality of barrier objects being associated with a different respective set function, each of the plurality of barrier objects being associated with a different respective wait function, and each of the plurality of barrier objects being associated with a different respective release function;
calling the respective set function of each of the barrier objects;
calling the respective wait function of each of the barrier objects, wherein at least one of the respective wait functions is called before another one of the respective wait functions has returned;
reconfiguring the storage system after all of the respective wait functions have returned; and
calling the respective release function of each of the barrier objects,
wherein at least one of the plurality of barrier objects includes: (i) a queue that identifies one or more threads that are executed when the storage system is reconfigured and/or (ii) a counter identifying a count of pending events that are being processed by using the given barrier object, the counter being decremented by the respective release function of the given barrier object when the respective release function of the barrier object is executed.
2. The method of claim 1 , wherein the respective set function of any given one of the barrier objects is configured to prevent one or more threads from accessing a resource of the storage system that is associated with the given barrier object.
3. The method of claim 1 , wherein the respective release function of any given one of the barrier objects is configured to enable one or more threads to access a resource of the storage system that is associated with the given barrier object.
4. The method of claim 1 , wherein the respective wait function of any given one of the barrier objects is configured to return only after a completion of all thread critical sections that are accessing a resource associated with the given barrier object when the respective wait function is called.
5. The method of claim 1 , wherein the respective release function of the given barrier object is configured to detect whether the count of pending events is equal to zero after decrementing the counter and, when the counter is equal to zero, transition the given barrier object from a set state to a released state.
6. A system comprising:
a memory; and
one or more processors operatively coupled to the memory, the one or more processors being configured to perform the operations of:
detecting an event that is generated within a storage system;
identifying a plurality of barrier objects that are associated with the event, each of the plurality of barrier objects being associated with a different respective set function, each of the plurality of barrier objects being associated with a different respective wait function, and each of the plurality of barrier objects being associated with a different respective release function;
calling the respective set function of each of the barrier objects;
calling the respective wait function of each of the barrier objects, wherein at least one of the respective wait functions is called before another one of the respective wait functions has returned;
reconfiguring the storage system after all of the respective wait functions have returned; and
calling the respective release function of each of the barrier objects,
wherein at least one of the plurality of barrier objects includes: (i) a queue that identifies one or more threads that are executed when the storage system is reconfigured and/or (ii) a counter identifying a count of pending events that are being processed by using the given barrier object, the counter being decremented by the respective release function of the given barrier object when the respective release function of the barrier object is executed.
7. The system of claim 6 , wherein the respective set function of any given one of the barrier objects is configured to prevent one or more threads from accessing a resource of the storage system that is associated with the given barrier object.
8. The system of claim 6 , wherein the respective release function of any given one of the barrier objects is configured to enable one or more threads to access a resource of the storage system that is associated with the given barrier object.
9. The system of claim 6 , wherein the respective wait function of any given one of the barrier objects is configured to return only after a completion of all thread critical sections that are accessing a resource associated with the given barrier object when the respective wait function is called.
10. The system of claim 6 , wherein the respective release function of the given barrier object is configured to detect whether the count of pending events is equal to zero after decrementing the counter and, when the counter is equal to zero, transition the given barrier object from a set state to a released state.
11. A non-transitory computer-readable medium storing one or more processor-executable instructions, which when executed by one or more processors cause the one or more processors to perform the operations of:
detecting an event that is generated within a storage system;
identifying a plurality of barrier objects that are associated with the event, each of the plurality of barrier objects being associated with a different respective set function, each of the plurality of barrier objects being associated with a different respective wait function, and each of the plurality of barrier objects being associated with a different respective release function;
calling the respective set function of each of the barrier objects;
calling the respective wait function of each of the barrier objects, wherein at least one of the respective wait functions is called before another one of the respective wait functions has returned;
reconfiguring the storage system after all of the respective wait functions have returned; and
calling the respective release function of each of the barrier objects,
wherein at least one of the plurality of barrier objects includes: (i) a queue that identifies one or more threads that are executed when the storage system is reconfigured and/or (ii) a counter identifying a count of pending events that are being processed by using the given barrier object, the counter being decremented by the respective release function of the given barrier object when the respective release function of the barrier object is executed.
12. The non-transitory computer-readable medium of claim 11 , wherein the respective set function of any given one of the barrier objects is configured to prevent one or more threads from accessing a resource of the storage system that is associated with the given barrier object.
13. The non-transitory computer-readable medium of claim 11 , wherein the respective release function of any given one of the barrier objects is configured to enable one or more threads to access a resource of the storage system that is associated with the given barrier object.
14. The non-transitory computer-readable medium of claim 11 , wherein the respective wait function of any given one of the barrier objects is configured to return only after a completion of all thread critical sections that are accessing a resource associated with the given barrier object when the respective wait function is called.