Management of transmission control blocks (TCBs) supporting TCP connection requests in multiprocessing environments

• US 10,212,259 B2
• Filed: 12/01/2014
• Issued: 02/19/2019
• Est. Priority Date: 12/01/2014
• Status: Active Grant

• Current Assignee: Oracle International Corporation (Oracle Corporation)
• Original Assignee: Oracle International Corporation (Oracle Corporation)
• Inventors: Narasimhamurthy, Giridhar
• Primary Examiner(s): Chea, Philip J
• Assistant Examiner(s): Ahmed, Mohammed
• Application Number:
  US14/556,274
• Publication Number:
  US 20160156747A1
• Time in Patent Office: 1,541 Days
• CPC Class Codes: H04L 67/141 Setup of application sessions admission control or resource allocation in data switching networks H04L47/70
• CPC Class Codes: H04L 69/03 Protocol definition or specification protocol conformance testing H04L1/244
• CPC Class Codes: H04L 69/163 In-band adaptation of TCP data exchange; In-band control procedures

Abstract

A source system executing applications in a multiprocessing environment supports transmission control protocol (TCP) connections. In an embodiment, the source system maintains a corresponding list of transmission control blocks (TCBs) for each processing entity. When an application executing on a first processing entity in the source system requests a new TCP connection to a destination system, an open TCP connection request is transmitted to said destination system on a network. A first TCB for the new TCP connection may be formed, indicating that the connection is in the process of being established. The connection may be allocated to a second processing entity, and the first TCB may be migrated as a second TCB, which is included in a list of TCBs associated with the second processing entity.

Claims

1. A method of supporting transmission control protocol (TCP) connections in a source system enabled to communicate over an IP (Internet Protocol) network, said method comprising:

maintaining a corresponding list of transmission control blocks (TCBs) for each processing entity of a plurality of processing entities executing an application as multi-processing environment;

receiving a call from said application to provide a new TCP connection to a destination system, said call being received while said application is being executed by a first processing entity of said plurality of processing entities, wherein said plurality of processing entities are implemented by one or more processing units provided in said source system;

transmitting by said first processing entity, in response to said call, an open TCP connection request to said destination system on said IP network at a first time instance;

forming a first TCB representing that said new TCP connection is in the process of being established, in response to receiving said call;

receiving, at a second time instance, an indication that processing of data stream of said new TCP connection is allocated to a second processing entity, wherein said second time instance is after said first time instance;

completing establishing of said new TCP connection;

including a second TCB in a list of TCBs associated with said second processing entity in response to said indication, wherein said second TCB indicates that said TCP connection is established to said destination system for said application, wherein said including is performed associated with establishing of said new TCP connection in response to said call to provide said new TCP connection;

receiving TCP segments on said new TCP connection upon completion of establishing of said new TCP connection; and

delivering said TCP segments received on said new TCP connection to said second processing entity in view of said second TCB being associated with said second processing entity,

wherein said application is an end point in said source system for said new TCP connection, wherein said application executed by said second processing entity receives and processes said TCP segments.

2. The method of claim 1, wherein said first TCB indicates that said application is said end point of said new TCP connection and that said new TCP connection is in the process of being established,

wherein said including comprises copying from said first TCB to said second TCB, data indicating that said new TCP connection has said end point at said application.

3. The method of claim 2, further comprising receiving a packet on said IP network in response to said transmitting of said open TCP connection request, wherein said packet contains an acknowledgement flag set by said destination system acknowledging receipt of said open TCP connection request,

wherein a network interface card (NIC) of said source system allocates processing of said packet to said second processing entity,

wherein said indication is generated upon said NIC allocating processing of said packet to said second processing entity, wherein said data stream comprises a sequence of packets received after said second time instance.

4. The method of claim 3, wherein said packet further comprises a SYN flag set by said destination system, said completing further comprises sending, by said second processing entity, another packet to said destination system, with said acknowledgement flag being set to acknowledge receipt of said SYN flag.

5. The method of claim 1, wherein each of said list of TCBs is maintained as a corresponding data structure of TCBs accessible only by corresponding processing entity such that a first data structure of TCBs is accessible only by said first processing entity and a second data structure of TCBs is accessible only by said second processing entity,

wherein said first TCB is maintained in a common data structure which contains respective TCBs for connections in the process of being established by any of said plurality of processing entities,

wherein said common data structure is locked prior to insertion and deletion of said first TCB, wherein said first TCB is deleted after said including.

6. The method of claim 5, wherein said one or more processing units comprises one or more processors in said source system, wherein said first processing entity is a first processor of said one or more processors and said second processing entity is a second processor of said one or more processors, wherein each of said data structure is a corresponding linked list.

7. The method of claim 6, wherein said application and TCP logic is executed by all of said plurality of processing entities, including said first processor and said second processor.

8. A non-transitory machine readable medium storing one or more sequences of instructions for enabling a source system to support transmission control protocol (TCP) connections over an IP (Internet Protocol) network, wherein execution of said one or more instructions by one or more processors contained in said source system enables said source system to perform the actions of:

maintaining a corresponding list of transmission control blocks (TCBs) for each processing entity of a plurality of processing entities executing an application as multi-processing environment;

receiving a call from said application to provide a new TCP connection to a destination system, said call being received while said application is being executed by a first processing entity of said plurality of processing entities, wherein said plurality of processing entities are implemented by one or more processing units provided in said source system;

transmitting by said first processing entity, in response to said call, an open TCP connection request to said destination system on said IP network at a first time instance;

forming a first TCB representing that said new TCP connection is in the process of being established, in response to receiving said call;

receiving, at a second time instance, an indication that processing of data stream of said new TCP connection is allocated to a second processing entity, wherein said second time instance is after said first time instance;

completing establishing of said new TCP connection;

including a second TCB in a list of TCBs associated with said second processing entity in response to said indication, wherein said second TCB indicates that said TCP connection is established to said destination system for said application, wherein said including is performed associated with establishing of said new TCP connection in response to said call to provide said new TCP connection; and

receiving TCP segments on said new TCP connection upon completion of establishing of said new TCP connection;

delivering said TCP segments received on said new TCP connection to said second processing entity in view of said second TCB being associated with said second processing entity,

wherein said application is an end point in said source system for said new TCP connection, wherein said application executed by said second processing entity receives and processes said TCP segments.

9. The non-transitory machine readable medium of claim 8, wherein said first TCB indicates that said application is said end point of said new TCP connection and that said new TCP connection is in the process of being established,

wherein said including comprises copying from said first TCB to said second TCB, data indicating that said new TCP connection has said end point at said application.

10. The non-transitory machine readable medium of claim 9, further comprising receiving a packet on said IP network in response to said transmitting of said open TCP connection request, wherein said packet contains an acknowledgement flag set by said destination system acknowledging receipt of said open TCP connection request,

wherein a network interface card (NIC) of said source system allocates processing of said packet to said second processing entity,

wherein said indication is generated upon said NIC allocating processing of said packet to said second processing entity, wherein said data stream comprises a sequence of packets received after said second time instance.

11. The non-transitory machine readable medium of claim 10, wherein said packet further comprises a SYN flag set by said destination system, said completing further comprises sending, by said second processing entity, another packet to said destination system, with said acknowledgement flag being set to acknowledge receipt of said SYN flag.

12. The non-transitory machine readable medium of claim 8, wherein each of said list of TCBs is maintained as a corresponding data structure of TCBs accessible only by corresponding processing entity such that a first data structure of TCBs is accessible only by said first processing entity and a second data structure of TCBs is accessible only by said second processing entity,

wherein said first TCB is maintained in a common data structure which contains respective TCBs for connections in the process of being established by any of said plurality of processing entities,

wherein said common data structure is locked prior to insertion and deletion of said first TCB, wherein said first TCB is deleted after said including.

13. The non-transitory machine readable medium of claim 12, wherein said one or more processing units comprises one or more processors in said source system, wherein said first processing entity is a first processor of said one or more processors and said second processing entity is a second processor of said one or more processors, wherein each of said data structure is a corresponding linked list.

14. The non-transitory machine readable medium of claim 13, wherein said application and TCP logic is executed by all of said plurality of processing entities, including said first processor and said second processor.

15. A digital processing system comprising:

one or more processing units; and

a random access memory (RAM) to store instructions,

wherein said one or more processing units retrieve said instructions and execute said instructions, wherein execution of said instructions causes said digital processing system to perform the actions of;

maintaining a corresponding list of transmission control blocks (TCBs) for each processing entity of a plurality of processing entities executing an application as multi-processing environment;

receiving a call from said application to provide a new TCP connection to a destination system, said call being received while said application is being executed by a first processing entity of said plurality of processing entities, wherein said plurality of processing entities are implemented by one or more processing units provided in said source system;

transmitting by said first processing entity, in response to said call, an open TCP connection request to said destination system over an IP (Internet Protocol) network at a first time instance;

forming a first TCB representing that said new TCP connection is in the process of being established, in response to receiving said call;

receiving, at a second time instance, an indication that processing of data stream of said new TCP connection is allocated to a second processing entity, wherein said second time instance is after said first time instance;

completing establishing of said new TCP connection;

including a second TCB in a list of TCBs associated with said second processing entity in response to said indication, wherein said second TCB indicates that said TCP connection is established to said destination system for said application, wherein said including is performed associated with establishing of said new TCP connection in response to said call to provide said new TCP connection;

receiving TCP segments on said new TCP connection upon completion of establishing of said new TCP connection; and

delivering said TCP segments received on said new TCP connection to said second processing entity in view of said second TCB being associated with said second processing entity,

wherein said application is an end point in said source system for said new TCP connection, wherein said application executed by said second processing entity receives and processes said TCP segments.

16. The digital processing system of claim 15, wherein said first TCB indicates that said application is said end point of said new TCP connection and that said new TCP connection is in the process of being established,

wherein said including comprises copying from said first TCB to said second TCB, data indicating that said new TCP connection has said end point at said application.

17. The digital processing system of claim 16, further comprising receiving a packet on said IP network in response to said transmitting of said open TCP connection request, wherein said packet contains an acknowledgement flag set by said destination system acknowledging receipt of said open TCP connection request,

wherein a network interface card (NIC) of said source system allocates processing of said packet to said second processing entity,

wherein said indication is generated upon said NIC allocating processing of said packet to said second processing entity, wherein said data stream comprises a sequence of packets received after said second time instance.

18. The digital processing system of claim 17, wherein said packet further comprises a SYN flag set by said destination system, said completing further comprises sending, by said second processing entity, another packet to said destination system, with said acknowledgement flag being set to acknowledge receipt of said SYN flag.

19. The digital processing system of claim 15, wherein each of said list of TCBs is maintained as a corresponding data structure of TCBs accessible only by corresponding processing entity such that a first data structure of TCBs is accessible only by said first processing entity and a second data structure of TCBs is accessible only by said second processing entity,

wherein said first TCB is maintained in a common data structure which contains respective TCBs for connections in the process of being established by any of said plurality of processing entities,

wherein said common data structure is locked prior to insertion and deletion of said first TCB, wherein said first TCB is deleted after said including.

20. The digital processing system of claim 19, wherein said one or more processing units comprises one or more processors in said source system, wherein said first processing entity is a first processor of said one or more processors and said second processing entity is a second processor of said one or more processors, wherein each of said data structure is a corresponding linked list.