Connection manager for handling message oriented protocol-based requests

• US 7,500,133 B2
• Filed: 12/28/2004
• Issued: 03/03/2009
• Est. Priority Date: 12/28/2004
• Status: Active Grant

• Current Assignee: SAP SE
• Original Assignee: SAP AG (SAP SE)
• Inventors: Kilian, Frank, Galchev, Galin, Luik, Oliver
• Primary Examiner(s): Le; Dieu-Minh
• Application Number:
  US11/024,498
• Publication Number:
  US 20060143619A1
• Time in Patent Office: 1,526 Days
• Field of Search: 719/312, 719/313, 714/4, 714/38, 714/1, 709/203, 709/213, 709/223, 709/224, 709/227
• US Class Current: 714/4.4
• CPC Class Codes: G06F 9/5033 considering data affinity

Abstract

A connection manager includes a dispatcher that dispatches requests to worker nodes in an application server. The connection manager receives client requests and dispatches the requests on different channels multiplexed over the same session to worker nodes coupled by a request/response shared memory to the connection manager.

Claims

1. An application server comprising:

a connection manager to receive a request from a network, the connection manager including a dispatcher to dispatch the request for processing;

a worker node to establish a session having a plurality of logical channels with the connection manager and to receive the dispatched request over one of the logical channels, the session and the one logical channel identified by a session identifier and channel identifier specified in the request; and

a request/response shared memory coupled to the connection manager and the worker node, the dispatcher to transfer the request to a memory location in the request/response shared memory from which the worker node can receive the request, the memory location allocated on the basis of the session identifier and channel identifier specified in the request, wherein the request/response shared memory is accessible to the worker node to transport request/response data between the connection in manager and the worker node to perform one or more of running a normal operation of the session without having a failure of the worker node, and managing a failure of the session resulting from a crash of the worker node.

2. The application server of claim 1, wherein the connection manager comprises a session multiplexing protocol handler to receive the request from the network.

3. The application server of claim 1, wherein the dispatcher to select the worker node from among a plurality of worker nodes to which to dispatch the request on the basis of the session identifier and channel identifier.

4. The application server of claim 1 further comprising a session table shared memory having an entry comprising the session identifier, channel identifier, a request notification queue associated with the worker node, and an allocated to the session and channel and via which to transfer the request to the worker node.

5. The application server of claim 4, wherein the request notification queue to queue a request notification to the selected worker node that a request is to be processed, and to specify the memory location in the request/response shared memory at which the request is to be read by the selected worker node to process the request.

6. A method in an application server comprising:

receiving a request from a network coupled to the application server;

identifying from a session identifier and channel identifier in a header of the request a session and channel over which to transfer the request to one of a plurality of worker nodes to process the request;

selecting one of the worker nodes to process the request;

submitting the request into a memory location in a request/response shared memory, the memory location allocated to the session and channel in which to store the request;

notifying the selected worker node of the request, including providing the memory location in the request/response shared memory at which to receive the request; and

receiving the notification at the selected worker node and retrieving the request from the memory location in the request/response shared memory, wherein the request/response shared memory is accessible to the worker node to transport request/response data between the connection manager and the worker node to perform one or more of running a normal operation of the session without having a failure of the worker node, and managing a failure of the session resulting from a crash of the worker node.

7. The method of claim 6, further comprising generating a response at the worker node to the request, and writing the response to the request/response shared memory.

8. The method of claim 7, wherein writing the response to the request/response shared memory comprises writing the response to a memory location allocated to the session and channel in which to store the response.

9. The method of claim 8, further comprising retrieving the response at the connection manager from the memory location in the request/response shared memory allocated to store the response.

10. The method of claim 9, further comprising the connection manager forwarding the response over the network to a client from which the request was received.

11. An article of manufacture, comprising:

a machine readable storage medium comprising instructions that when executed, cause a machine to;

receive a request from a network coupled to the application server;

identify from a session identifier and channel identifier in a header of the request a session and channel over which to transfer the request to one of a plurality of worker nodes to process the request;

select one of the worker nodes to process the request;

submit the request into a memory location in a request/response shared memory, the memory location allocated to the session and channel in which to store the request;

notify the selected worker node of the request, including providing the memory location in the request/response shared memory at which to receive the request; and

receive the notification at the selected worker node and retrieving the request from the memory location in the request/response shared memory, wherein the request/response shared memory is accessible to the worker node to transport request/response data between the connection manager and the worker node to perform one or more of running a normal operation of the session without having a failure of the worker node, and managing a failure of the session resulting from a crash of the worker node.

12. The article of manufacture of claim 11, the machine readable storage medium further comprising instructions that when executed generate a response at the worker node to the request, and write the response to the request/response shared memory.

13. The article of manufacture of claim 12, wherein the instruction that write the response to the request/response shared memory comprise instructions that write the response to a memory location allocated to the session and channel in which to store the response.

14. The article of manufacture of claim 13, further comprising instructions that retrieve the response at the connection manager from the memory location in the request/response shared memory allocated to store the response.

15. The article of manufacture of claim 14, further comprising instructions that cause the connection manager to forward the response over the network to a client from which the request was received.