Application-controlled network packet classification

• US 8,838,817 B1
• Filed: 11/07/2007
• Issued: 09/16/2014
• Est. Priority Date: 11/07/2007
• Status: Active Grant

• Current Assignee: NetApp, Inc.
• Original Assignee: NetApp, Inc.
• Inventors: Biswas, Anumita
• Primary Examiner(s): Dharia, Rupal
• Assistant Examiner(s): MCADAMS, BRAD
• Application Number:
  US11/936,141
• Time in Patent Office: 2,505 Days
• Field of Search: 370/395, 709/211, 709/230, 709/250
• US Class Current: 709/230
• CPC Class Codes: H04L 45/38 Flow based routing
• CPC Class Codes: H04L 47/22 Traffic shaping
• CPC Class Codes: H04L 47/2475 for supporting traffic characterised by the type of applications
• CPC Class Codes: H04L 47/32 by discarding or delaying data units, e.g. packets or frames
• CPC Class Codes: H04L 49/90 Buffering arrangements

Abstract

Embodiments of the present invention provide a system, method, and computer program product that enables applications transferring data packets over a network to a multi-processing system to choose how the data packets are going to be processed by, e.g., allowing the applications to pre-assign connections to a particular network thread and migrate a connection from one network thread to another network thread without putting the connection into an inconsistent state.

Claims

1. A method for enabling applications to flexibly distribute data packets in a multiprocessing system, the method comprising:

maintaining a plurality of connection data structures, each connection data structure corresponding to a network thread executed in the multiprocessing system;

using a plurality of algorithms provided by an application to distribute the data packets to a plurality of different network threads; and

accessing, by each network thread of the plurality of different network threads, a corresponding connection data structure to determine how to process one of the data packets arriving on a connection using any algorithm different from the plurality of algorithms provided by the application used to distribute the data packets for the application to the the plurality of different network threads, wherein each network thread only accesses its corresponding connection data structure.

2. The method of claim 1, wherein each connection data structure represents an array of indexes, each index corresponding to a linked list of portable control blocks (PCBs) storing information about a particular connection.

3. The method of claim 1, wherein each destination port, on which the connections for the application arrive, is associated with an algorithm used to distribute connections among network contexts.

4. The method of claim 3, wherein the algorithm provided by the application represents a hash function computed based on a source address, a source port, and the destination port.

5. The method of claim 1, further comprising queuing the data packets for the application among different network contexts.

6. A method for enabling applications to flexibly distribute connections in a multiprocessing system, the method comprising:

pre-assigning a network connection to a network context to process data packets arriving on the network connection at a source network device;

providing an indication as to whether to perform packet classification based on a destination port or a source port of hte multiprocessing system;

responsive to the packet classification to be performed based on the destination port as indicated in a data packet, updating a destination port data structure with a source address, the source port, the destination port, and the pre-assigned network context; and

responsive to the packet classification to be performed based on the source port as indicated in the data packet, updating a source port data structure with the source address, the source port, the destination port, and the pre-assigned network context.

7. A system for enabling applications to flexibly distribute data packets in a multiprocessing system including a processor and a memory, the system comprising:

a plurality of connection data structures at the multiprocessing system, each connection data structure associated with a network thread executed in the multiprocessing system, the connection data structure storing one or more connections queued to the network thread;

a classification module configured to use a plurality of algorithms provided by an application to distribute different connections to a plurality of different network threads; and

a transport protocol module configured to access each of the plurality of connection data structures corresponding to each network thread of the plurality of different network threads to determine how to process a data packet arriving on a connection using any algorithm different from the plurality of algorithms provided by the application and used by the classification module to distribute the different connections among the plurality of different network threads.

8. The system of claim 7, further comprising:

the application executed at the multiprocessing system, the application providing an indication to migrate an established network connection to a new data structure that queues connections processed by the network thread;

the transport protocol module configured to block processing of first data packets arriving on the established network connection to be migrated until the established network connection is migrated without putting the established network connection in an inconsistent state; and

the classification module configured to migrate the established network connection to the new data structure.

9. The system of claim 8, further comprising maintaining a plurality of timer data structures accessed by the plurality of different network threads and wherein the classification module is further configured to migrate the established network connection to the new network context without halting execution of timer threads.

10. A non-transitory computer readable medium containing executable program instructions executed by a processor, comprising:

program instructions that maintain a plurality of connection data structures, each connection data structure corresponding to a network thread executed in a multiprocessing system;

program instructions that use a plurality of algorithms provided by an application executing on the multiprocessing system to distribute data packets to a plurality of different network threads; and

program instructions that access, by each network thread of the plurality of different network threads, a corresponding connection data structure to determine how to process a data packet arriving on a connection using any algorithm different from the plurality of algorithms provided by the application used to distribute the data packets for the application to the plurality of different network threads, wherein each network thread of the plurality of different network threads only accesses its corresponding connection data structure.

11. The non-transitory computer readable medium of claim 10, further comprising program instructions that queue the data packets for the application among different network contexts.

13. The non-transitory computer readable medium of claim 10, further configured to:

program instructions that receive an indication that an application is to migrate an established network connection to a new connection data structure that queues connections processed by a network thread;

program instructions that halt processing of the data packets arriving on the establishing network connection until the established network connection is migrated without putting the established network connection in an inconsistent state; and

program instructions that migrate the established network connection to the new network thread.

12. A non-transitory computer readable medium containing executable program instructions executed by a processor, comprising:

program instructions that pre-assign a network connection to a connection data structure to process data packets arriving on the network connection at a source network device;

program instructions that provide an indication as to whether packet classification will be performed based on a destination port or a source port;

program instructions that, responsive to the packet classification to be performed based on the destination port as indicated in the data packet, update a destination port data structure with a source address, the source port, the destination port, and the pre-assigned network context; and

program instructions that, responsive to the packet classification to be performed based on the source port as indicated in the data packet, update a source port data structure with the source address, the source port, the destination port, and the pre-assigned network context.

14. A system for enabling applications to flexibly distribute data packets in a multiprocessing system including a processor and a memory, the system comprising:

a network connection configured to be pre-assigned to a network context to process data packets arriving on the network connection at a source network device;

an indication configured to indicate as to whether packet classification will be performed based on a destination port or a source port of the multiprocessing system;

responsive to the packet classification to be performed based on the destination port as indicated in a data packet, a destination port data structure configured to be updated with a source address, the source port, the destination port, and the pre-assigned network context; and

responsive to the packet classification to be performed based on the source port as indicated in the data packet, a source port data structure configured to be updated with the source address, the source port, the destination port, and the pre-assigned network context.