SYSTEM AND METHOD FOR SUPPORTING OUT-OF-ORDER MESSAGE PROCESSING IN A DISTRIBUTED DATA GRID

• US 20140108533A1
• Filed: 11/07/2012
• Published: 04/17/2014
• Est. Priority Date: 10/15/2012
• Status: Active Grant

• Current Assignee: Oracle International Corporation (Oracle Corporation)
• Original Assignee: Oracle International Corporation (Oracle Corporation)
• Inventors: Falco, Mark, Gleyzer, Gene
• Granted Patent: US 9,083,614 B2
• Time in Patent Office: Days
• US Class Current: 709/204
• CPC Class Codes: G06F 11/16 Error detection or correction of the data by redundancy in hardware
• CPC Class Codes: G06F 11/2041 with more than one idle spare processing component
• CPC Class Codes: G06F 11/2048 where the redundant components share neither address space nor persistent storage
• CPC Class Codes: G06F 11/2097 maintaining the standby controller/processing unit updated initialisation or re-synchronisation thereof G06F11/1658 and subgroups
• CPC Class Codes: G06F 16/10 File systems; File servers
• CPC Class Codes: G06F 16/2365 Ensuring data consistency and integrity
• CPC Class Codes: G06F 2201/82 Solving problems relating to consistency
• CPC Class Codes: H04L 41/0668 by dynamic selection of recovery network elements, e.g. replacement by the most appropriate element after failure
• CPC Class Codes: H04L 43/0811 by checking connectivity
• CPC Class Codes: H04L 67/1095 Replication or mirroring of data, e.g. scheduling or transport for data synchronisation between network nodes

Abstract

A system and method can support out-of-order message processing in a distributed data grid. A cluster node in the distributed data grid can receive a plurality of messages at a cluster node in the distributed data grid. The distributed data grid allows each message in the plurality of messages to determine whether it needs to be handled in a particular order on a first thread. The cluster node can dispatch one or more of said messages that do not need to be handled in the particular order on the first thread to one or more different threads.

Claims

1. A method for supporting out-of-order message processing in a distributed data grid operating on one or more microprocessors, comprising:

receiving a plurality of messages at a cluster node in the distributed data grid;

allowing each message in the plurality of messages to determine whether it needs to be handled in a particular order on a first thread; and

dispatching one or more said messages that do not need to be handled in the particular order on the first thread to one or more different threads.

2. The method according to claim 1, further comprising:

using an underlying transporting mechanism to transfer the plurality of messages, wherein the underlying transporting mechanism is based on a message transporting protocol.

3. The method according to claim 2, further comprising:

allowing the cluster node to separate data grid service functionalities out from the underlying message transfer layer.

4. The method according to claim 1, further comprising:

allowing each said message to provide a callback function in a message structure, wherein the callback function is adaptive to be used by the cluster node to determine whether it needs to handle the message on the first thread.

5. The method according to claim 4, further comprising:

setting a flag in the callback function in each said message.

6. The method according to claim 1, further comprising:

processing one or more said messages in the particular order using a queue on the first thread.

7. The method according to claim 1, further comprising:

processing one or more said messages on the one or more different threads in parallel.

8. The method according to claim 1, further comprising:

receiving at least one message in the plurality of messages at another cluster node in the distributed data grid.

9. The method according to claim 8, further comprising:

allowing the another cluster node in the distributed data grid to process said at least one message differently.

10. The method according to claim 1, further comprising:

allowing at least one message in the plurality of messages to be a result message.

11. A system for supporting out-of-order message processing in a distributed data grid, comprising:

one or more microprocessors;

a cluster node in the distributed data grid running on the one or more microprocessors, wherein the cluster node operates to perform the steps of

receiving a plurality of messages at a cluster node in the distributed data grid;

allowing each message in the plurality of messages to determine whether it needs to be handled in a particular order on a first thread; and

dispatching one or more said messages that do not need to be handled in the particular order on the first thread to one or more different threads.

12. The system according to claim 11, wherein:

an underlying transporting mechanism is used to transfer the plurality of messages, wherein the underlying transporting mechanism is based on a message transporting protocol.

13. The system according to claim 12, wherein:

the cluster node separates data grid service functionalities out from the underlying message transfer layer.

14. The system according to claim 11, wherein:

each said message operates to provide a callback function in a message structure, wherein the callback function is adaptive to be used by the cluster node to determine whether it needs to handle the message on the first thread.

15. The system according to claim 14, wherein:

a flag is set in the callback function in each said message.

16. The system according to claim 11, wherein:

the cluster node operates to process one or more said messages in the particular order using a queue on the first thread.

17. The system according to claim 11, wherein:

the cluster node operates to process one or more said messages on the one or more different threads in parallel.

18. The system according to claim 11, further comprising:

at another cluster node in the distributed data grid operates to receive at least one message in the plurality of messages.

19. The system according to claim 18, further comprising:

the another cluster node in the distributed data grid operates to process said at least one message differently.

20. A non-transitory machine readable storage medium having instructions stored thereon that when executed cause a system to perform the steps of:

receiving a plurality of messages at a cluster node in the distributed data grid;

allowing each message in the plurality of messages to determine whether it needs to be handled in a particular order on a first thread; and

dispatching one or more said messages that do not need to be handled in the particular order on the first thread to one or more different threads.