System and method for processing event predicates

• US 7,346,603 B2
• Filed: 12/22/2005
• Issued: 03/18/2008
• Est. Priority Date: 12/30/2004
• Status: Expired due to Fees

• Current Assignee: Technology Financial LLC
• Original Assignee: Technology Financial LLC
• Inventors: Wyman, Robert Mark, Werner, Duncan
• Primary Examiner(s): ALAM, SHAHID AL
• Application Number:
  US11/318,000
• Publication Number:
  US 20060161580A1
• Time in Patent Office: 817 Days
• Field of Search: 707/2, 707/3, 707/10, 707/101, 707/102, 707/104.1, 707/5, 707/6
• US Class Current: 707/745
• CPC Class Codes: G06Q 10/06 Resources, workflows, human or project management; Enterprise or organisation planning; Enterprise or organisation modelling
• CPC Class Codes: G06Q 10/10 Office automation; Time management
• CPC Class Codes: G06Q 30/08 Auctions
• CPC Class Codes: G06Q 40/04 Trading; Exchange, e.g. stocks, commodities, derivatives or currency exchange
• CPC Class Codes: G06Q 40/06 Asset management; Financial planning or analysis
• CPC Class Codes: Y10S 707/99932 Access augmentation or optimizing
• CPC Class Codes: Y10S 707/99935 Query augmenting and refining, e.g. inexact access
• CPC Class Codes: Y10S 707/99936 Pattern matching access
• CPC Class Codes: Y10S 707/99943 Generating database or data structure, e.g. via user interface

Abstract

Described is a method comprising initializing a first set of bits corresponding to a first plurality of predicate indices to a first value, and initializing a second set of bits corresponding to a second plurality of predicate indices to a second value. A subscription is processed. The subscription includes a plurality of subscription predicates, each of the subscription predicates associated with corresponding predicate indices in one of the first and second pluralities. An event is processed. The event includes an event predicate. When the event predicate matches a first predicate index in the first plurality, a first bit associated with the first predicate index is toggled to the second value. When the event predicate matches a second predicate index in the second plurality, a second bit associated with the second predicate index is toggled to the first value. When each bit associated with the corresponding predicate indices is the second value, the event is outputted to a source of the subscription.

Claims

1. A method, comprising:

initializing a first set of bits corresponding to a first plurality of predicate indices to a first value;

initializing a second set of bits corresponding to a second plurality of predicate indices to a second value;

processing a subscription, the subscription including a plurality of subscription predicates, each of the subscription predicates associated with corresponding predicate indices in one of the first and second pluralities;

processing an event, the event including an event predicate;

when the event predicate matches a first predicate index in the first plurality, toggling a first bit associated with the first predicate index to the second value;

when the event predicate matches a second predicate index in the second plurality, toggling a second bit associated with the second predicate index to the first value;

when each bit associated with the corresponding predicate indices is the second value, outputting the event to a source of the subscription;

comparing each of the subscription predicates to the first and second pluralities;

when any of the subscription predicates is absent from the first and second pluralities, generating, for the absent subscription predicate, a corresponding predicate index; and

inserting the corresponding predicate index into one of the first and second pluralities.

2. The method of claim 1, wherein the first plurality is an equals predicate index and the second plurality is a not-equals predicate index.

3. The method of claim 1, further comprising:

assigning an identifier to each of the predicate indices.

4. The method of claim 3, further comprising:

summarizing the subscription using the identifier of each of the corresponding predicate indices.

5. The method of claim 3, wherein the identifier is a bitvector offset.

6. The method of claim 1, wherein the first value is 0 and the second value is 1.

7. The method of claim 1, wherein the initializing steps are performed using a bulk bit-setting operation.

8. A device, comprising:

a processor initializing a first set of bits corresponding to a first plurality of predicate indices to a first value and initializing a second set of bits corresponding to a second plurality of predicate indices to a second value; and

a communications arrangement receiving an event and a subscription, the event including an event predicate, the subscription including a plurality of subscription predicates, each of the subscription predicates associated with corresponding predicate indices in one of the first and second pluralities,

wherein, when the event predicate matches a first predicate index in the first plurality, the processor toggles a first bit associated with the first predicate index to the second value,

wherein, when the event predicate matches a second predicate index in the second plurality, the processor toggles a second bit associated with the second predicate index to the first value,

wherein, when each bit associated with the corresponding predicate indices is the second value, the processor outputs the event to a source of the subscription, and

wherein the processor compares each of the subscription predicates to the first and and second pluralities, and, when any of the subscription predicates is absent from the first and second pluralities, the processor generates, for the absent subscription predicate, a corresponding predicate index, the processor inserting the corresponding predicate index into one of the first and second pluralities.

9. The device of claim 8, wherein the device includes at least one of a server and a mainframe.

10. The device of claim 8, wherein the source includes at least one of a PC, a PDA, a tablet, a cell phone and a network interface card.

11. The device of claim 8, wherein the first plurality is an equals predicate index and the second plurality is a not-equals predicate index.

12. The device of claim 8, wherein the processor assigns an identifier to each of the predicate indices.

13. The device of claim 8, wherein the processor summarizes the subscription using the identifier of each of the corresponding predicate indices.

14. The device of claim 13, wherein the identifier is a bitvector offset.

15. The device of claim 8, wherein the first value is 0 and the second value is 1.

16. The device of claim 8, wherein the processor executes a bulk bit-setting operation to initialize the first and second sets of bits.

17. A computer-readable storage medium storing a set of instructions, the set of instructions capable of being executed by a processor, the set of instructions performing the steps of:

initializing a first set of bits corresponding to a first plurality of predicate indices to a first value;

initializing a second set of bits corresponding to a second plurality of predicate indices to a second value;

processing a subscription, the subscription including a plurality of subscription predicates, each of the subscription predicates associated with corresponding predicate indices in one of the first and second pluralities;

processing an event, the event including an event predicate;

when the event predicate matches a first predicate index in the first plurality, toggling a first bit associated with the first predicate index to the second value;

when the event predicate matches a second predicate index in the second plurality, toggling a second bit associated with the second predicate index to the first value;

when each bit associated with the corresponding predicate indices is the second value, outputting the event to a source of the subscription;

comparing each of the subscription predicates to the first and second pluralities;

when any of the subscription predicates is absent from the first and second pluralities, generating, for the absent subscription predicate, a corresponding predicate index; and

inserting the corresponding predicate index into one of the first and second pluralities.