Channel bundling

• US 7,984,173 B2
• Filed: 05/30/2007
• Issued: 07/19/2011
• Est. Priority Date: 05/30/2007
• Status: Active Grant

• Current Assignee: Red Hat, Inc. (International Business Machines Corporation)
• Original Assignee: Red Hat, Inc. (International Business Machines Corporation)
• Inventors: Ban, Bela
• Primary Examiner(s): Hamza; Faruk
• Application Number:
  US11/809,270
• Publication Number:
  US 20080298395A1
• Time in Patent Office: 1,511 Days
• Field of Search: 709/200, 709204-207, 709227-230, 709/238, 370/464, 370/474
• US Class Current: 709/230
• CPC Class Codes: H04L 12/185 with management of multicast group membership
• CPC Class Codes: H04L 61/2503 Translation of Internet protocol [IP] addresses
• CPC Class Codes: H04L 69/32 Architecture of open systems interconnection [OSI] 7-layer type protocol stacks, e.g. the interfaces between the data link level and the physical level
• CPC Class Codes: H04L 69/326 in the transport layer [OSI layer 4] H04L69/16 takes precedence

Abstract

A method and apparatus for processing message is described. In one embodiment, a channel layer is configured to form a channel with a corresponding process. The channel is associated with a group. A plurality of sockets is formed in a transport layer of a group communication protocol. Traffic of messages to and from the processes is distributed across the plurality of sockets in the transport layer.

Claims

1. A computer-implemented method for processing messages, the method comprising:

forming a channel with a corresponding process at a channel layer module of a processing device, wherein channels with a same name form a group of member processes;

forming a plurality of sockets for the corresponding process in a transport layer of a group communication protocol;

distributing a traffic of messages to and from the processes across the plurality of sockets in the transport layer;

forming a logical address upon a creation of a channel of the group communication protocol;

storing an association of the logical address with a message received with a sender'"'"'s address in a cache of a member of the group; and

dissolving the logical address when the channel is to be closed or disconnected.

2. The method of claim 1 further comprising:

receiving packets from a plurality of senders with the transport layer, the transport layer comprising a multicast receiver thread, a unicast receiver thread, and a connection table.

3. The method of claim 2 further comprising:

processing a packet with a thread from a thread pool.

4. The method of claim 3 further comprising:

forming another thread to process the packet when all threads from the thread pool are busy.

5. The method of claim 3 wherein the thread sends the packets up the transport layer to a corresponding channel of a channel layer, a building block layered on top of the channel layer, and an application programming interface layered on top of the building block.

6. The method of claim 1 wherein the logical address is formed independently of an IP address and a port of a receiver socket.

7. The method of claim 1 wherein the logical address is selected by a user on channel creation.

8. The method of claim 1 wherein the logical address is selected such that it cannot be reused after a corresponding channel is closed or disconnected.

9. A non-transitory computer-accessible storage medium including data that, when accessed by a computer system, cause the computer system to perform a method comprising:

forming a channel with a corresponding process at a channel layer module of a processing device, wherein channels with a same name form a group of member processes;

forming a plurality of sockets for the corresponding process in a transport layer of a group communication protocol;

distributing a traffic of messages to and from the processes across the plurality of sockets in the transport layer;

forming a logical address upon a creation of a channel of a group communication protocol;

storing an association of the logical address with a message received with a sender'"'"'s address in a cache of a member of the group; and

dissolving the logical address when the channel is to be closed or disconnected.

10. The non-transitory computer-accessible storage medium of claim 9 wherein the method further comprises:

receiving packets from a plurality of senders with the transport layer, the transport layer comprising a multicast receiver thread, a unicast receiver thread, and a connection table.

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

processing a packet with a thread from a thread pool.

12. The non-transitory computer-accessible storage medium of claim 11 wherein the method further comprises:

forming another thread to process the packet when all threads from the thread pool are busy.

13. The non-transitory computer-accessible storage medium of claim 11 wherein the thread sends the packets up the transport layer to a corresponding channel of a channel layer, a building block layered on top of the channel layer, and an application programming interface layered on top of the building block.

14. The non-transitory computer-accessible storage medium of claim 9 wherein the logical address is formed independently of an IP address and a port of a receiver socket.

15. The non-transitory computer-accessible storage medium of claim 9 wherein the logical address is selected by a user on channel creation.

16. The non-transitory computer-accessible storage medium of claim 9 wherein the logical address is selected such that it cannot be reused after a corresponding channel is closed or disconnected.

17. An apparatus for processing messages comprising:

an application programming interface for receiving and sending messages;

a building block layer coupled to the application programming interface;

a channel layer coupled to the building block layer; and

a transport protocol stack coupled to the channel layer for implementing properties specified by the channel layer,

wherein the channel layer is configured to form a channel with a corresponding process, wherein channels with a same name form a group of member processes, to form a plurality of sockets for the corresponding process in a transport layer of a group communication protocol, to distribute a traffic of messages to and from the processes across the plurality of sockets in the transport layer, to form a logical address upon a creation of a channel of the group communication protocol, to store an association of the logical address with a message received with a sender'"'"'s address in a cache of a member of the group, and to dissolve the logical address when the channel is to be closed or disconnected.

18. The apparatus of claim 17 wherein the channel layer is to further receive packets from a plurality of senders with the transport layer, the transport layer comprising a multicast receiver thread, a unicast receiver thread, and a connection table.

19. The apparatus of claim 17 wherein the channel layer is to further process a packet with a thread from a thread pool.

20. The apparatus of claim 17 wherein the channel layer is to further form another thread to process the packet when all threads from the thread pool are busy.

21. The apparatus of claim 17 wherein the thread sends the packets up the transport layer to a corresponding channel of a channel layer, a building block layered on top of the channel layer, and an application programming interface layered on top of the building block.

22. The apparatus of claim 17 wherein the logical address is formed independently of an IP address and a port of a receiver socket.

23. The apparatus of claim 17 wherein the logical address is selected by a user on channel creation.

24. The method of claim 17 wherein the logical address is selected such that it cannot be reused after a corresponding channel is closed or disconnected.