Combined join and state transfer

• US 8,312,084 B2
• Filed: 02/28/2008
• Issued: 11/13/2012
• Est. Priority Date: 02/28/2008
• Status: Active Grant

• Current Assignee: Red Hat, Inc. (International Business Machines Corporation)
• Original Assignee: Red Hat, Inc. (International Business Machines Corporation)
• Inventors: Blagojevic, Vladimir, Ban, Bela
• Primary Examiner(s): Whipple, Brian P
• Application Number:
  US12/074,089
• Publication Number:
  US 20090219945A1
• Time in Patent Office: 1,720 Days
• Field of Search: 709204-206
• US Class Current: 709/205
• CPC Class Codes: H04L 12/1822 Conducting the conference, e.g. admission, detection, selection or grouping of participants, correlating users to one or more conference sessions, prioritising transmission
• CPC Class Codes: H04L 12/185 with management of multicast group membership

Abstract

A method and apparatus for processing messages is described. In one embodiment, an application programming interface provides for a flush protocol to force members of a group to send all of their pending messages prior to a predetermined event. A client sends a request to a coordinator of the group to join the group and to transfer a state of the group to the client. The application programming interface performs a single flush operation on the group in response to the request.

Claims

1. A computer-implemented method comprising:

configuring a flush protocol to force members of a group to send all of their pending messages prior to a predetermined event;

receiving a request from a client to both join the group and transfer a state of the group to the client;

intercepting the request to transfer the state of the group;

replacing the request to transfer the state of the group with a request to join the group without performing a flush operation in response to the request to transfer the state of the group; and

performing a single flush operation on the group in response to the request to join the group.

2. The computer-implemented method of claim 1 further comprising

identifying members of the group and a coordinator associated with the group,

wherein the client requests the coordinator to perform the single flush operation upon joining the group.

3. The computer-implemented method of claim 2 wherein the request to transfer the state of the group includes a request to see a same set of messages in a same view prior to installing a new view.

4. The computer-implemented method of claim 3 wherein said performing the single flush operation comprises running a messages exchange phase that makes sure that all members of the group have seen the same set of messages in the same view prior to installing the new view.

5. The computer-implemented method of claim 4, wherein said running the messages exchange phase is completed before the completion of the single flush operation, and wherein said running the messages exchange phase comprises multicasting all messages received from other members of the group before multicasting an indication of the completion of the single flush operation.

6. The computer-implemented method of claim 4, wherein said running the messages exchange phase is completed before the completion of the single flush operation, and wherein said running the messages exchange phase comprises:

exchanging digests with highest sequence numbers seen for all members of the group; and

multicasting only the missing messages.

7. The computer-implemented method of claim 2 wherein the request to join the group includes a flush flag parameter, the flush flag parameter including a boolean operator corresponding to the single flush operation.

8. The computer-implemented method of claim 7 further comprising:

generating a new view upon joining the client with the group;

sending the new view to the members of the group; and

receiving an acknowledgment from the members of the group of the new view.

9. The computer-implemented method of claim 8 wherein each members of the group includes a Java-based object.

10. A non-transitory computer-readable medium containing data and instructions to cause a programmable processor to perform operations comprising:

configuring a flush protocol to force members of a group to send all of their pending messages prior to a predetermined event;

receiving a request from a client to both join the group and transfer a state of the group to the client;

intercepting the request to transfer the state of the group;

replacing the request to transfer the state of the group with a request to join the group without performing a flush operation in response to the request to transfer the state of the group; and

performing a single flush operation on the group in response to the request to join the group.

11. The non-transitory computer-readable medium of claim 10 wherein the method further comprises

identifying members of the group and a coordinator associated with the group,

wherein the client requests the coordinator to perform the single flush operation upon joining the group.

12. The non-transitory computer-readable medium of claim 11 wherein the request to transfer the state of the group includes a request to see a same set of messages in a same view prior to installing a new view.

13. The non-transitory computer-readable medium of claim 12 wherein said performing the single flush operation comprises running a messages exchange phase that makes sure that all members of the group have seen the same set of messages in the same view prior to installing the new view.

14. The non-transitory computer-readable medium of claim 13, wherein said running the messages exchange phase is completed before the completion of the single flush operation, and wherein said running the messages exchange phase comprises multicasting all messages received from other members of the group before multicasting an indication of the completion of the single flush operation.

15. The non-transitory computer-readable medium of claim 13, wherein said running the messages exchange phase is completed before the completion of the single flush operation, and wherein said running the messages exchange phase comprises:

exchanging digests with highest sequence numbers seen for all members of the group; and

multicasting only the missing messages.

16. The non-transitory computer-readable medium of claim 11 wherein the request to join the group includes a flush flag parameter, the flush flag parameter including a boolean operator corresponding to the single flush operation.

17. The non-transitory computer-readable medium of claim 16 wherein the method further comprises:

generating the new view upon joining the client with the group;

sending the new view to the members of the group; and

receiving an acknowledgment from the members of the group of the new view.

18. The non-transitory computer-readable medium of claim 17 wherein each members of the group includes a Java-based object.

19. A system comprising:

a memory;

a processing device coupled to the memory, the processing device comprising a combining module and a coordinator module,

wherein the combining module is configured to receive a request from a client to both join a group and transfer a state of the group to the client, the combining module comprising an interceptor to intercept the client'"'"'s request to transfer the state of the group, and to replace the client'"'"'s request to transfer the state of the group with a request to join the group without the coordinator having to perform a flush operation in response to the request to transfer the state of the group;

wherein the coordinator associated with the group is to configure a flush protocol to force members of the group to send all of their pending messages prior to a predetermined event and to perform a single flush operation on the group on behalf of the client in response to the request to join the group.

20. The system of claim 19 wherein the request to transfer the state of the group includes a request to see a same set of messages in a same view prior to installing a new view.

21. The system of claim 20 wherein the request to join the group includes a flush flag parameter, the flush flag parameter including a boolean operator corresponding to the single flush operation.

22. The system of claim 21 wherein the coordinator is to generate a new view upon joining the client with the group, to send the new view to the members of the group, and to receive an acknowledgment from the members of the group of the new view.

23. The system of claim 22 wherein each members of the group includes a Java-based object.

24. The system of claim 20 wherein the coordinator is configured to run a messages exchange phase that makes sure that all members of the group have seen the same set of messages in the same view prior to installing the new view.

25. The system of claim 24 wherein the coordinator is configured to complete the messages exchange phase before completion of the single flush operation, and to multicast all messages received from other members of the group before multicasting an indication of the completion of the single flush operation when running the messages exchange phase.

26. The system of claim 24 wherein the coordinator is configured to complete the messages exchange phase before completion of the single flush operation, and to exchange digests with highest sequence numbers seen for all members of the group and multicast only the missing messages when running the messages exchange phase.