Method and system for time sensitive processing of TCP segments into application layer messages

A Field Programmable Gate Array (FPGA) configured to execute instructions for method and system for time sensitive processing of TCP segments into application layer messages, wherein the FPGA is configured to:

• receive a plurality of inputs, from a client, wherein the plurality of inputs comprises a plurality of Transmission Control Protocol (TCP) segments, wherein,
• each of the plurality of TCP segments is a random sequence of a plurality of messages, wherein the plurality of messages is a combination of (a) a plurality of partial message, and (b) a plurality of complete message,
• each of the messages from the plurality of messages is associated with a session-based information, where the session-based information includes a connection_id, a message length, and a head pointer, and
• the message length is associated with a start of message (SOM) and an end of a message (EOM), wherein the SOM indicates beginning of a message and the EOM indicates end of the message;
• analyze each message of the plurality of TCP segment based on the session-based information and re-assembling the plurality of messages in a time-sensitive queue, wherein the process of analyzing and re-assembling comprises:
• identifying the message as one of a partial message or a complete message using the session-based information;
• and based on the identification of the message, performing:
• upon identifying the message as a partial message, searching for a similar partial message using the session-based information, and based on search, performing:
• upon not identifying the similar partial message, saving the partial message in a Message descriptor (MDS) pool and a connection table and waiting for the similar partial message to be received;
• and
• upon identifying the similar partial message, appending the partial message to the similar partial message to obtain a complete message and saving the complete message as an application layer message in the time-sensitive queue, wherein when the TCP segment arrives from a TCP Offload Engine (TOE), a message writer (MW) locates the last MDS in the MDS pool, in list of MDS's associated with the connection table and if the last MDS is not found, a new MDS is removed from the MDS pool and associated with the connection table, wherein the TCP segment is copied into a buffer space of the MDS pool,
• wherein the step of copying is repeated till the entire TCP segment is copied into the buffer space of the MDS pool while appending each MDS to the list as captured in the step of saving the partial message upon not identifying the similar partial message and the step of appending the partial message to the similar partial message to obtain a complete message upon identifying the similar partial message;
• upon identifying the message as the complete message, saving the complete message as the application layer message in the time-sensitive queue, wherein the MR reads from tail of the time-sensitive queue, locates the MDS buffers in a sequence of the MDS list and copies message contents from the MDS buffers to the application when it indicates readiness to read a next message;
• and
• retrieve the application layer message in the time sensitive order, wherein the application layer messages are retrieved in the time-sensitive order based on the detection of the EOM;
• wherein the time sensitive processing of TCP segments into application layer messages includes processing the messages of the plurality of TCP segments in an order in which they appear on a physical network interface before they are received at the TOE.

One or more non-transitory machine readable information storage mediums comprising one or more instructions which when executed by one or more hardware processors cause:

• receiving a plurality of inputs, from a client, wherein the plurality of inputs comprises a plurality of Transmission Control Protocol (TCP) segments, wherein,
• each of the plurality of TCP segments is a random sequence of a plurality of messages, wherein the plurality of messages is a combination of (a) a plurality of partial message, and (b) a plurality of complete message,
• each of the messages from the plurality of messages is associated with a session-based information, where the session-based information includes a connection_id, a message length, and a head pointer, and
• the message length is associated with a start of message (SOM) and an end of a message (EOM), wherein the SOM indicates beginning of a message and the EOM indicates end of the message;
• analyzing each message of the plurality of TCP segment based on the session-based information and re-assembling the plurality of messages in a time-sensitive queue, wherein the process of analyzing and re-assembling comprises:
• identifying the message as one of a partial message or a complete message using the session-based information;
• and based on the identification of the message, performing:
• upon identifying the message as a partial message, searching for a similar partial message using the session-based information, and based on search, performing:
• upon not identifying the similar partial message, saving the partial message in a Message descriptor (MDS) pool and a connection table and waiting for the similar partial message to be received;
• and
• upon identifying the similar partial message, appending the partial message to the similar partial message to obtain a complete message and saving the complete message as an application layer message in the time-sensitive queue, wherein when the TCP segment arrives from a TCP Offload Engine (TOE), a message writer (MW) locates the last MDS in the MDS pool, in list of MDS's associated with the connection table and if the last MDS is not found, a new MDS is removed from the MDS pool and associated with the connection table, wherein the TCP segment is copied into a buffer space of the MDS pool,
• wherein the step of copying is repeated till the entire TCP segment is copied into the buffer space of the MDS pool while appending each MDS to the list as captured in the step of saving the partial message upon not identifying the similar partial message and the step of appending the partial message to the similar partial message to obtain a complete message upon identifying the similar partial message;
• upon identifying the message as the complete message, saving the complete message as the application layer message in the time-sensitive queue, wherein the MR reads from tail of the time-sensitive queue, locates the MDS buffers in a sequence of the MDS list and copies message contents from the MDS buffers to the application when it indicates readiness to read a next message;
• and
• retrieving the application layer message in the time sensitive order, wherein the application layer messages are retrieved in the time-sensitive order based on the detection of the EOM:
• wherein the time sensitive processing of TCP segments into application layer messages includes processing the messages of the plurality of TCP segments in an order in which they appear on a physical network interface before they are received at the TOE.