System and method for a pluggable protocol handler

• US 7,966,412 B2
• Filed: 07/19/2005
• Issued: 06/21/2011
• Est. Priority Date: 07/19/2005
• Status: Active Grant

• Current Assignee: SAP SE
• Original Assignee: SAP AG (SAP SE)
• Inventors: Galchev, Galin, Luik, Oliver
• Primary Examiner(s): Bates; Kevin
• Assistant Examiner(s): RECEK, JASON D
• Application Number:
  US11/185,199
• Publication Number:
  US 20070067469A1
• Time in Patent Office: 2,163 Days
• Field of Search: 709/213, 709/230, 709/250, 370/465, 707/4, 719/311
• US Class Current: 709/230
• CPC Class Codes: H04L 67/34 involving the movement of software or configuration parameters network booting or remote initial program loading [RIPL] G06F9/4416
• CPC Class Codes: H04L 69/18 Multiprotocol handlers, e.g. single devices capable of handling multiple protocols

Abstract

Embodiments of the invention are generally directed to a system and method for pluggable protocol handlers to route message traffic between communication partners. In an embodiment, a protocol independent connection manager receives a message from a communication partner over a network connection. The connection manager calls a dynamically loadable protocol handler to process and route the received message to a subsequent communication partner. In one embodiment, the network connection is a multiplexed network connection.

Claims

1. An application server comprising:

a protocol independent connection manager, the connection manager to receive messages in accordance with a plurality of protocols including a first protocol and a second protocol, the connection manager to receive a message from a first client on a first network connection of the connection manager, the connection manager utilizing the first protocol or the second protocol for reception of the received message;

a plurality of dynamically loadable communication protocol handlers to handle messages, the plurality of dynamically loadable communication protocol handlers including a first dynamically loadable communication protocol handler to handle messages received via the first protocol and a second dynamically loadable communication protocol handler to handle messages received via the second protocol, wherein in response to receiving the message the connection manager is to choose the first dynamically loadable communication protocol handler or the second dynamically loadable communication protocol handler based one of the plurality of protocols utilized for reception of the received message;

a computer memory, the computer memory including a shared memory region that can be accessed by each of a first plurality of worker nodes associated with the first protocol or a second plurality of worker nodes associated with the second protocol for a transfer of received messages; and

a plurality of notification queues each to notify one of the first and second plurality of worker nodes that data is available in the shared memory region,

wherein the chosen dynamically loadable communication protocol handler is to select a first worker node of the plurality of worker nodes associated with one of the plurality of protocols of the chosen dynamically loadable communication protocol handler to handle the received message and is to forward the received message to the first worker node via the shared memory, the first worker node to access the received message in the shared memory,

wherein the chosen dynamically loadable communication protocol handler is loaded at runtime.

2. The application server of claim 1, wherein the first network connection is a multiplexed network connection, the multiplexed network connection multiplexing messages for a plurality of clients, and

wherein the connection manager is to monitor a status of a number of network connection endpoints.

3. The application server of claim 2, wherein the chosen dynamically loadable communication protocol handler implements, at least in part, a standards-based communication protocol.

4. The application server of claim 3, wherein the standards-based communication protocol is the Internet Inter-Object Request Broker Protocol.

5. The application server of claim 2, wherein the chosen dynamically loadable communication protocol handler implements, at least in part, a proprietary communication protocol.

6. The application server of claim 5, wherein the proprietary communication protocol is the proprietary P4 protocol of SAP AG.

7. The application server of claim 2, wherein the connection manager is to receive a response message from the first worker node, and wherein the chosen dynamically loadable communication protocol handler is to select the first client as an appropriate client of the plurality of clients to receive the response.

8. The application server of claim 7, wherein the chosen dynamically loadable communication protocol handler is to forward the response message to the first client, wherein the dynamically loadable communication protocol handler is an application programming interface to process and route messages.

9. The application server of claim 2, wherein the multiplexed network connection is implemented with a connection oriented shared memory, wherein the connection oriented shared memory includes:

a first shared memory region to store request and response data transfers for the first protocol;

a second shared memory region to store session objects including data fields and procedures for the request and response data transfers; and

a third shared memory region to store session state information relating to a flow management of the request and response data transfers.

10. The application server of claim 1, wherein the plurality of notification queues enables the application server to transfer work among the first and second plurality of worker nodes for fault tolerance and load balancing.

11. The application server of claim 10, wherein the application server to use the plurality of notification queues to implement fail protection mechanism by transferring a session from a first worker node to a second worker node on failure of the first worker node.

12. The application server of claim 1, wherein at least one of the plurality of dynamically loadable communication protocol handlers is to register an input/output function with a multiplex select thread for a multiplexed connection to call the input/output function on occurrence of an event.

13. The method of claim 12, wherein the function implements a multiplex select thread, and wherein the at least one of the number of network connection endpoints is a socket to a worker node of the first and second plurality of worker nodes.

14. The application server of claim of 13, wherein the multiplex select thread determines to accept a connection request when resources are available for a connection.

15. The application server of claim 14, wherein at least two of the plurality of dynamically loadable communication protocol handlers have access to the multiplex select thread.

16. The application server of claim 1, wherein each of the plurality of dynamically loadable communication protocol handlers is registered with the protocol independent connection manager.

17. A method comprising:

receiving a message at a connection manager of an application server from a first client, the connection manager being independent of message protocols, the message being received in accordance with a first message protocol;

dynamically loading a first dynamically loadable communication protocol handler in the connection manager, the first communication protocol handler and a second communication protocol handler being included in a plurality of communication protocol handlers, the first communication protocol handler being compatible with the first message protocol and the second communication protocol handler being compatible with a second message protocol;

receiving at the first communication protocol handler an indication that a network connection endpoint is available for an input/output function for the received message;

performing the input/output function of the first communication protocol handler responsive, at least in part, to receiving the indication that the network connection endpoint is available, wherein performing the input/output function includes selecting a first worker node of a first plurality of worker nodes associated with the first message protocol to handle the received message and forwarding the received message to the first worker node via a shared memory, the shared memory being accessible to the first plurality of worker nodes and to a second plurality of worker nodes associated with the second message protocol; and

generating notifications at a plurality of notification queues, wherein each notification is to notify one of the first and second plurality of worker nodes that data is available in a shared memory region

wherein dynamically loading a first dynamically loadable communication protocol handler in the connection manager occurs at runtime.

18. The method of claim 17, further comprising:

registering one or more input/output functions of the first communication protocol handler with the connection manager, the one or more input/output functions to allow the connection manager to call the first communication protocol handler.

19. The method of claim 17, wherein the network connection endpoint is a multiplexed network connection endpoint, and

wherein the method further comprises monitoring a status of a number of network connection endpoints.

20. The method of claim 17, wherein receiving at the first communication protocol handler the indication that the network connection endpoint is available for an input/output function comprises:

receiving a handle from a select thread indicating that the network connection endpoint is available for an input/output function, and

monitoring a status of a number of network connection endpoints using a multiplex of select threads.

21. The method of claim 20, wherein receiving the handle includes receiving a handle for a read function and further comprising:

reading at least part of a message from the network connection endpoint.

22. The method of claim 21, wherein reading at least part of the message from the network connection comprises:

reading at least a part of a message header associated with the message; and

determining the first worker node as a destination for the message based, at least in part, on the message header.

23. The method of claim 22, wherein the message header is based, at least in part, on one of:

a standards-based communication protocol; and

a proprietary communication protocol.

24. The method of claim 23, wherein the standards-based communication protocol is the Internet Inter-Object Request Broker Protocol (HOP).

25. The method of claim 20, further comprising:

receiving a request from a worker node of the first and second plurality of worker nodes; and

accessing one of the plurality of notification queues associated with the worker node.

26. The method of claim 20, wherein monitoring the status further comprises accessing a function to determine the status of at least one of the number of network connection endpoints.

27. The method of claim 17, further comprising:

receiving a response message from the first worker node;

performing one or more input/output functions of the first communication protocol handler, the functions including selecting the first client as a destination for the response message and forwarding the response message to the first client.

28. An article of manufacturer comprising a non-transitory computer readable medium providing instructions that, when executed by a processor, cause the processor to:

receive a message at a connection manager of an application server from a first client, the connection manager being independent of message protocols, the message being received in accordance with a first message protocol;

dynamically load a first dynamically loadable communication protocol handler in the connection manager, the first communication protocol handler and a second communication protocol handler being included in a plurality of communication protocol handlers, the first communication protocol handler being compatible with the first message protocol and the second communication protocol handler being compatible with a second message protocol;

receive at the first communication protocol handler an indication that a network connection endpoint is available for an input/output function for the received message;

perform the input/output function of the first communication protocol handler responsive, at least in part, to receiving the indication that the network connection endpoint is available, wherein performing the input/output function includes selecting a first worker node of a first plurality of worker nodes associated with the first message protocol to handle the received message and forwarding the received message to the first worker node via a shared memory, the shared memory being accessible to the first plurality of worker nodes and to a second plurality of worker nodes associated with the second message protocol; and

generate notifications at a plurality of notification queues, wherein each notification is to notify one of the first and second plurality of worker nodes that data is available in a shared memory region

wherein dynamically loading a first dynamically loadable communication protocol handler in the connection manager occurs at runtime.

29. The article of manufacture of claim 28, wherein the computer readable medium provides further instructions that, when executed by the processor, cause the processor to:

register one or more input/output functions of the first communication protocol handler with the connection manager, the one or more input/output functions to allow the connection manager to call the first communication protocol handler.

30. The article of manufacture of claim 28, wherein the instructions that, when executed by the processor, cause the processor to receive at the first communication protocol handler the indication that the network connection endpoint is available for an input/output function cause the processor to:

receive a handle from a select thread indicating that the network connection endpoint is available for an input/output function.

31. The article of manufacture of claim 28, wherein the computer readable medium provides further instructions that, when executed by the processor, cause the processor to:

receive a response message from the first worker node;

perform one or more input/output functions of the first communication protocol handler, the functions including selecting the first client as a destination for the response message and forwarding the response message to the first client.