Methods, systems and computer program products for kernel based transaction processing

• US 20030023767A1
• Filed: 07/26/2001
• Published: 01/30/2003
• Est. Priority Date: 07/26/2001
• Status: Active Grant

• Current Assignee: International Business Machines Corporation
• Original Assignee: International Business Machines Corporation
• Inventors: Brabson, Roy Frank, Huynh, Lap Thiet
• Granted Patent: US 6,832,260 B2
• Time in Patent Office: Days
• US Class Current: 719/313
• CPC Class Codes: G06F 9/544 Buffers; Shared memory; Pipes
• CPC Class Codes: H04L 67/1001 for accessing one among a plurality of replicated servers
• CPC Class Codes: H04L 67/1008 based on parameters of servers, e.g. available memory or workload monitoring of computer activity G06F11/30
• CPC Class Codes: H04L 67/1014 based on the content of a request
• CPC Class Codes: H04L 69/16 Implementation or adaptation of Internet protocol [IP], of transmission control protocol [TCP] or of user datagram protocol [UDP]
• CPC Class Codes: H04L 69/161 Implementation details of TCP/IP or UDP/IP stack architecture; Specification of modified or new header fields
• CPC Class Codes: H04L 69/163 In-band adaptation of TCP data exchange; In-band control procedures

Abstract

Methods, systems and computer program products are provided for transferring a Transmission Control Protocol (TCP) connection with a client device between data processing systems in a cluster of data processing systems. An operating system kernel of a first data processing system obtains application level information from a transaction received from the client over the connection. In addition, application state information associated with the connection may be obtained from the first application. A second application at a second data processing system is selected for transfer of the connection based on the obtained information and the connection is transferred to the second data processing system. The transfer includes providing to the second data processing system the associated state information of the first communication protocol stack and, optionally, the obtained application state information associated with the connection from the first application. Selection operations for transfers may be initiated responsive to a notification from the first application of completion of a transaction.

Claims

1. A method of transferring a Transmission Control Protocol (TCP) connection with a client device between data processing systems in a cluster of data processing systems, the method comprising:

establishing a connection between the client device and a routing node coupled to the cluster of data processing systems utilizing a communication protocol stack at the routing node, the protocol stack having associated state information;

wherein an operating system kernel of the routing node carries out the following;

obtaining application level information from an initial transaction received from the client over the connection, the transaction including at least one request;

selecting a target application at a first data processing system of the cluster of data processing systems for transfer of the connection based on the obtained information; and

transferring the connection to a target communication protocol stack on the first data processing system associated with the selected target application including providing the associated state information of the communication protocol stack of the routing node; and

wherein the target communication protocol stack carries out the following;

accepting the connection from the routing node based on the provided associated state information of the communication protocol stack of the routing node so as to, transparently to the client, establish communications between the client and the target application;

receiving a notification of completion of the transaction from the target application; and

making the connection available to a routing device for selection of a next target application to receive the connection responsive to receipt of the notification of completion of the transaction.

2. The method of claim 1 wherein the routing device comprises either the routing node or the first data processing system.

3. The method of claim 1 wherein the step of receiving a notification of completion of the transaction from the target application comprises receiving the notification from the target application at the target communication protocol stack over the connection as data which is detectable by the target communication protocol stack as being directed to the target communication protocol stack rather than the client.

4. The method of claim 3 wherein the step of receiving the notification from the target application at the target communication protocol stack comprises receiving the data as ancillary data of a sendmsg socket call.

5. The method of claim 4 wherein the data further comprises application state information associated with the connection from the target application and wherein the method further comprises providing the application state information to the routing device for use in transferring the connection to the next target application and wherein a communication protocol stack associated with the next target application receives the application state information and the notification as ancillary data of a recvmsg socket call.

6. The method of claim 5 further comprising providing associated state information of the target communication protocol stack to the routing device for use in transferring the connection to the next target application.

7. The method of claim 6 wherein the application state information is a null set.

8. The method of claim 6 further comprising the following carried out by an operating system kernel of the routing device:

obtaining application level information from a next transaction received from the client over the connection, the next transaction including at least one request;

selecting the next target application at a data processing system of the cluster of data processing systems for transfer of the connection based on the obtained application level information from a next transaction; and

transferring the connection to the communication protocol stack associated with the next target application including providing the associated state information of the target communication protocol stack and the application state information associated with the connection to the communication protocol stack associated with the next target application.

9. The method of claim 8 wherein the step of selecting a target application is carried out by a policy-based engine of the operating system kernel of the routing node.

10. The method of claim 1 further comprising the following carried out by an operating system kernel of the routing device:

obtaining application level information from a next transaction received from the client over the connection, the next transaction including at least one request;

selecting the next target application at a data processing system of the cluster of data processing systems for transfer of the connection based on the obtained application level information from the next transaction; and

transferring the connection to a communication protocol stack associated with the next target application including providing associated communication protocol stack state information for the routing device to the communication protocol stack associated with the next target application.

11. The method of claim 10 wherein the routing device comprises either the routing node or the first data processing system.

12. The method of claim 1 wherein the step of selecting a target application is carried out by a policy-based engine of the operating system kernel of the routing node.

13. The method of claim 1 wherein obtaining application level information further comprises obtaining sufficient application level information to identify the initial transaction.

14. The method of claim 1 wherein obtaining application level information further comprises executing application-specific exits within the operating kernel of the routing node to examine data associated with the transaction to identify the transaction to the operating kernel of the routing node.

15. The method of claim 1 further comprising making the communication protocol stack of routing node available after the connection is transferred.

16. The method of claim 1 wherein the connection is an encrypted connection and wherein the provided associated state information includes encryption information.

17. A method of transferring a Transmission Control Protocol (TCP) connection with a client device between data processing systems in a cluster of data processing systems, the method comprising:

establishing a connection between the client device and a first application at a first data processing system of the cluster of data processing systems utilizing a first communication protocol stack associated with the first application, the first communication protocol stack having associated state information;

wherein an operating system kernel of the first data processing system carries out the following;

obtaining application level information from a transaction received from the client over the connection, the transaction including at least one request;

obtaining application state information associated with the connection from the first application;

selecting a second application at a second data processing system of the cluster of data processing systems for transfer of the connection based on the obtained application level information; and

transferring the connection to a second communication protocol stack on the second data processing system associated with the selected second application including providing to the second data processing system the associated state information of the first communication protocol stack and the obtained application state information associated with the connection from the first application.

18. The method of claim 17 wherein the second communication protocol stack carries out the following:

accepting the connection from the first data processing system based on the provided associated state information of the first communication protocol stack and the obtained application state information so as to, transparently to the client, establish communications between the client and the second application.

19. The method of claim 18 wherein the step of accepting the connection further comprises providing the obtained application state information to the second application.

20. The method of claim 19 wherein the step of providing the obtained application state information further comprises providing the obtained application state information to the second application as ancillary data of a recvmsg socket call.

21. The method of claim 20 wherein the step of obtaining application state information associated with the connection from the first application further comprises receiving the application state information from the first application as ancillary data of a sendmsg socket call.

22. The method of claim 19 wherein the step of obtaining application level information from an initial transaction received from the client over the connection further comprises executing application-specific exits within the operating kernel of the first data processing system to examine data associated with the transaction to identify the transaction to the operating kernel of the first data processing system.

23. The method of claim 19 further comprising the following performed by the operating system kernel of the first data processing system:

receiving a notification of completion of the transaction from the first application; and

wherein the step of selecting a second application further comprises making the connection available to a routing device for selection of the second application responsive to receipt of the notification of completion of the transaction.

24. The method of claim 23 wherein the routing devices comprises either the first data processing system or a routing node shared by ones of the cluster of data processing systems.

25. The method of claim 19 wherein the step of accepting the connection from the first data processing system further comprises setting a state of the connection at the second data processing system to a state specified by the provided associated state information of the first communication protocol stack and the obtained application state information to provide a transferred connection to the second application;

and

wherein the second application carries out communicating with the client utilizing the transferred connection.

26. A system for transferring a Transmission Control Protocol (TCP) connection with a client device between data processing systems in a cluster of data processing systems, the system comprising:

means for establishing a connection between the client device and a routing node coupled to the cluster of data processing systems utilizing a communication protocol stack at the routing node, the protocol stack having associated state information;

an operating system kernel of the routing node, the operating system kernel of the routing node comprising;

means for obtaining application level information from an initial transaction received from the client over the connection, the transaction including at least one request;

means for selecting a target application at a first data processing system of the cluster of data processing systems for transfer of the connection based on the obtained information; and

means for transferring the connection to a target communication protocol stack on the first data processing system associated with the selected target application including providing the associated state information of the communication protocol stack of the routing node;

wherein the target communication protocol stack comprises;

means for accepting the connection from the routing node based on the provided associated state information of the communication protocol stack of the routing node so as to, transparently to the client, establish communications between the client and the target application;

means for receiving a notification of completion of the transaction from the target application; and

means for making the connection available to a routing device for selection of a next target application to receive the connection responsive to receipt of the notification of completion of the transaction.

27. The system of claim 26 wherein the routing device comprises either the routing node or the first data processing system.

28. The system of claim 26 wherein the means for receiving a notification of completion of the transaction from the target application comprises means for receiving the notification from the target application at the target communication protocol stack over the connection as data which is detectable by the target communication protocol stack as being directed to the target communication protocol stack rather than the client.

29. The system of claim 28 wherein the means for receiving the notification from the target application at the target communication protocol stack comprises means for receiving the data as ancillary data of a sendmsg socket call.

30. The system of claim 29 wherein the data further comprises application state information associated with the connection from the target application and wherein the system further comprises means for providing the application state information to the routing device for use in transferring the connection to the next target application;

and

a communication protocol stack associated with the next target application that receives the application state information and the notification as ancillary data of a recvmsg socket call.

31. The system of claim 30 wherein the means for selecting a target application comprises a policy-based engine of the operating system kernel of the routing node.

32. The system of claim 26 wherein the means for obtaining application level information further comprises executable application-specific exits within the operating kernel of the routing node configured to examine data associated with the transaction to identify the transaction to the operating kernel of the routing node.

33. The system of claim 26 wherein the connection is an encrypted connection and wherein the provided associated state information includes encryption information.

34. A system for transferring a Transmission Control Protocol (TCP) connection with a client device between data processing systems in a cluster of data processing systems, the system comprising:

means for establishing a connection between the client device and a first application at a first data processing system of the cluster of data processing systems utilizing a first communication protocol stack associated with the first application, the first communication protocol stack having associated state information;

an operating system kernel of the first data processing system, the operating system kernel of the first data processing system further comprising;

means for obtaining application level information from a transaction received from the client over the connection, the transaction including at least one request;

means for obtaining application state information associated with the connection from the first application;

means for selecting a second application at a second data processing system of the cluster of data processing systems for transfer of the connection based on the obtained application level information; and

means for transferring the connection to a second communication protocol stack on the second data processing system associated with the selected second application including providing to the second data processing system the associated state information of the first communication protocol stack and the obtained application state information associated with the connection from the first application.

35. The system of claim 34 wherein the second communication protocol stack further comprises:

means for accepting the connection from the first data processing system based on the provided associated state information of the first communication protocol stack and the obtained application state information so as to, transparently to the client, establish communications between the client and the second application.

36. The system of claim 35 wherein the means for accepting the connection further comprises means for providing the obtained application state information to the second application.

37. The system of claim 36 wherein the means for providing the obtained application state information further comprises means for providing the obtained application state information to the second application as ancillary data of a recvmsg socket call.

38. The system of claim 37 wherein the means for obtaining application state information associated with the connection from the first application further comprises means for receiving the application state information from the first application as ancillary data of a sendmsg socket call.

39. The system of claim 36 wherein the means for obtaining application level information from an initial transaction received from the client over the connection further comprises executable application-specific exits within the operating kernel of the first data processing system that examine data associated with the transaction to identify the transaction to the operating kernel of the first data processing system.

40. The system of claim 36 wherein the operating system kernel of the first data processing system further comprises:

means for receiving a notification of completion of the transaction from the first application; and

wherein means for selecting a second application further comprises means for making the connection available to a routing device for selection of the second application responsive to receipt of the notification of completion of the transaction.

41. The system of claim 40 wherein the routing device comprises either the first data processing system or a routing node shared by ones of the cluster of data processing systems.

42. The system of claim 36 wherein the means for accepting the connection from the first data processing system further comprises means for setting a state of the connection at the second data processing system to a state specified by the provided associated state information of the first communication protocol stack and the obtained application state information to provide a transferred connection to the second application;

and

wherein the second application comprise means for communicating with the client utilizing the transferred connection.

43. A computer program product for transferring a Transmission Control Protocol (TCP) connection with a client device between data processing systems in a cluster of data processing systems, comprising:

a computer-readable storage medium having computer-readable program code embodied in said medium, said computer-readable program code comprising;

computer-readable program code which establishes a connection between the client device and a routing node coupled to the cluster of data processing systems utilizing a communication protocol stack at the routing node, the protocol stack having associated state information;

computer-readable program code for execution in an operating system kernel of the routing node which obtains application level information from an initial transaction received from the client over the connection, the transaction including at least one request;

computer-readable program code for execution in an operating system kernel of the routing node which selects a target application at a first data processing system of the cluster of data processing systems for transfer of the connection based on the obtained information;

computer-readable program code for execution in an operating system kernel of the routing node which transfers the connection to a target communication protocol stack on the first data processing system associated with the selected target application including providing the associated state information of the communication protocol stack of the routing node;

computer-readable program code which accepts the connection from the routing node based on the provided associated state information of the communication protocol stack of the routing node so as to, transparently to the client, establish communications between the client and the target application;

computer-readable program code which receives a notification of completion of the transaction from the target application; and

computer-readable program code which makes the connection available to a routing device for selection of a next target application to receive the connection responsive to receipt of the notification of completion of the transaction.

44. The computer program product of claim 43 wherein the computer-readable program code which receives a notification of completion of the transaction from the target application comprises computer-readable program code which receives the notification from the target application at the target communication protocol stack over the connection as data which is detectable by the target communication protocol stack as being directed to the target communication protocol stack rather than the client.

45. The computer program product of claim 44 wherein the computer-readable program code which receives the notification from the target application at the target communication protocol stack comprises computer-readable program code which receives the data as ancillary data of a sendmsg socket call.

46. The computer program product of claim 45 wherein the data further comprises application state information associated with the connection from the target application and wherein the computer program product further comprises:

computer-readable program code which provides the application state information to the routing device for use in transferring the connection to the next target application; and

computer-readable program code which receives the application state information and the notification as ancillary data of a recvmsg socket call.

47. The computer program product of claim 43 wherein the computer-readable program code which obtains application level information further comprises application-specific exit computer-readable program code for execution within the operating kernel of the routing node which examines data associated with the transaction to identify the transaction to the operating kernel of the routing node.

48. The computer program product of claim 43 wherein the connection is an encrypted connection and wherein the provided associated state information includes encryption information.

49. A computer program product for transferring a Transmission Control Protocol (TCP) connection with a client device between data processing systems in a cluster of data processing systems, comprising:

a computer-readable storage medium having computer-readable program code embodied in said medium, said computer-readable program code comprising;

computer-readable program code which establishes a connection between the client device and a first application at a first data processing system of the cluster of data processing systems utilizing a first communication protocol stack associated with the first application, the first communication protocol stack having associated state information;

computer-readable program code for execution in an operating system kernel of the routing node which obtains application level information from a transaction received from the client over the connection, the transaction including at least one request;

computer-readable program code for execution in an operating system kernel of the routing node which obtains application state information associated with the connection from the first application;

computer-readable program code for execution in an operating system kernel of the routing node which selects a second application at a second data processing system of the cluster of data processing systems for transfer of the connection based on the obtained application level information; and

computer-readable program code for execution in an operating system kernel of the routing node which transfers the connection to a second communication protocol stack on the second data processing system associated with the selected second application including providing to the second data processing system the associated state information of the first communication protocol stack and the obtained application state information associated with the connection from the first application.

50. The computer program product of claim 49 wherein further comprising:

computer-readable program code which accepts the connection from the first data processing system based on the provided associated state information of the first communication protocol stack and the obtained application state information so as to, transparently to the client, establish communications between the client and the second application.

51. The computer program product of claim 50 wherein the computer-readable program code which accepts the connection further comprises computer-readable program code which provides the obtained application state information to the second application.

52. The computer program product of claim 51 wherein the computer-readable program code which provides the obtained application state information further comprises computer-readable program code which provides the obtained application state information to the second application as ancillary data of a recvmsg socket call.

53. The computer program product of claim 52 wherein the computer-readable program code which obtains application state information associated with the connection from the first application further comprises computer-readable program code which receives the application state information from the first application as ancillary data of a sendmsg socket call.

54. The computer program product of claim 51 wherein the computer-readable program code which obtains application level information from an initial transaction received from the client over the connection further comprises application-specific exit computer-readable program code within the operating kernel of the first data processing system which examines data associated with the transaction to identify the transaction to the operating kernel of the first data processing system.