Method and apparatus for processing an event notification in a concurrent processing system

A method for processing a notification, comprising:

• receiving the notification, wherein a source of said notification is at least one of:
• a first processing element comprising a first monitor module, or a second processing element comprising a second monitor module, wherein said first processing element and said second processing element are deployed in a concurrent processing system, wherein said notification indicates an event detected by one of said first monitor module, or said second monitor module, and wherein said event is derived from an assertion specifying a condition that must always be true;
• and
• processing said notification to determine whether at least one recovery action instruction is to be issued to said first processing element or said second processing element, wherein said at least one recovery action specifies a remedial action that is implemented by said first processing element or said second processing element, and
• wherein said at least one recovery action instruction is tailored to address a particular problem caused by said event without having to reset said source;
• wherein said at least one recovery action instruction is provided to a first recover module within said first processing element or a second recover module within said second processing element;
• wherein said first recover module or said second recover module implements said remedial action responsive to said at least one recovery action instruction;
• and
• wherein the remedial action is ignoring a current input value and awaiting another input value.

A non-transitory computer-readable medium having stored thereon a plurality of instructions, the plurality of instructions including instructions which, when executed by a processor, cause the processor to perform a method for processing a notification, comprising:

• receiving the notification, wherein a source of said notification is at least one of:
• a first processing element comprising a first monitor module, or a second processing element comprising a second monitor module, wherein said first processing element and said second processing element are deployed in a concurrent processing system, wherein said notification indicates an event detected by one of said first monitor module, or said second monitor module, and wherein said event is derived from an assertion specifying a condition that must always be true;
• and
• processing said notification to determine whether at least one recovery action instruction is to be issued to said first processing element or said second processing element, wherein said at least one recovery action specifies a remedial action that is implemented by said first processing element or said second processing element, and wherein said at least one recovery action instruction is tailored to address a particular problem caused by said event without having to reset said source;
• wherein said at least one recovery action instruction is provided to a first recover module within said first processing element or a second recover module within said second processing element;
• wherein said first recover module or said second recover module implements said remedial action responsive to said at least one recovery action instruction;
• and
• wherein the remedial action is ignoring a current input value and awaiting another input value.