Method for continuous I/O request processing in an asynchronous environment

• US 7,272,834 B2
• Filed: 01/04/2002
• Issued: 09/18/2007
• Est. Priority Date: 11/21/2001
• Status: Expired due to Fees

• Current Assignee: International Business Machines Corporation
• Original Assignee: International Business Machines Corporation
• Inventors: Cernohous, Bob Richard, Simonson, Steven John, Bauman, Mark Linus, Hofer, Kent L., Kasperski, John Charles, Christenson, David Alan, Brooks, John Lee, Goodrich, Clark Anthony
• Primary Examiner(s): Thomson; William
• Assistant Examiner(s): Truong; LeChi
• Application Number:
  US10/037,553
• Publication Number:
  US 20030097455A1
• Time in Patent Office: 2,083 Days
• Field of Search: 719/310, 719/328, 719/314
• US Class Current: 719/314
• 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/162 involving adaptations of sockets based mechanisms secure socket layer H04L63/168

Abstract

Method, apparatus and article of manufacture for continuous modes for both asynchronous accepts and asynchronous receives. A single asynchronous accept is performed on a listening socket and a single asynchronous receive is performed on each connected socket. The continuous mode inputs result in queuing data structures on a pending queue. The contents of the pending data structures on the pending queue are copied to completion queues, while the pending data structures remain on the pending queue.

Claims

1. A computer-implemented method for providing asynchronous network communications between a client and a server, comprising:

configuring a socket for an application on the server;

in response to a request from the client, issuing a single, continuous mode operation to the socket, wherein the single, continuous mode operation including;

a single asynchronous accept operation, configuring a listening socket to process a plurality of incoming client connections, wherein issuing the single asynchronous accept operation comprises;

placing a single pending accept data structure on a pending queue, and

for each of the plurality of incoming client connections, copying contents of the single pending accept data structure to a completed accept data structure queued on a accept completion queue, wherein the single pending accept data structure remains on the pending queue after the contents are copied; and

a single asynchronous receive operation, configuring a client socket to process a plurality of client requests, wherein issuing the single asynchronous receive operation comprises;

placing a single pending receive data structure on a pending queue, and

for each completed client request, copying contents of the pending receive data structure to a completed receive data structure queued on a receive completion queue.

2. The computer-implemented method of claim 1, further comprising, configuring the client socket, with the single asynchronous receive operation, to recognize a format of each of the plurality of client requests, whereby the client socket is configured to receive the client requests without invoking the application until the request is completely received.

3. The computer-implemented method of claim 1, wherein the single, continuous mode operations are issued from a main thread of the application.

4. The computer-implemented method of claim 1, wherein issuing the single asynchronous receive operation comprises:

placing a single pending receive data structure on a pending queue;

for each completed client request, copying contents of the pending receive data structure to a completed receive data structure queued on a receive completion queue.

5. The computer-implemented method of claim 1, further comprising, for each completed client request, acquiring a buffer from system supply memory to contain the completed client request.

6. The computer-implemented method of claim 5, wherein allocating the buffer comprises sizing the buffer according to a size of the completed client request.

7. A computer readable storage medium containing a sockets-based program comprising at least one of a continuous mode accept application programming interface and a continuous mode receive application programming interface, wherein the sockets-based program, when executed, performs operations for processing messages, the operation comprising:

configuring a listening socket to handle a plurality of incoming client connections, as a result of issuing a single asynchronous accept operation from an application, wherein issuing the single asynchronous accept operation comprises;

placing a single pending receive data structure on a pending queue; and

for each completed client request, copying contents of the pending receive data structure to a completed receive data structure queued on a receive completion queue, wherein the single pending accept data structure remains on the pending queue after the contents are copied; and

configuring a client socket to handle a plurality of client requests, as a result of issuing a single, asynchronous receive operation issued by the application, wherein issuing the single asynchronous receive operation comprises;

placing a single pending receive data structure on a pending queue; and

for each completed client request, copying contents of the pending receive data structure to a completed receive data structure queued on a receive completion queue.

8. The computer readable medium of claim 7, further comprising, configuring the client socket, with the single asynchronous receive operation, to recognize a format of each of the plurality of client requests, whereby the client socket is configured to handle receiving the client requests without invoking the application until the message is completely received.

9. The computer readable medium of claim 7, wherein the single asynchronous accept operation and the single asynchronous receive operation are issued from a main thread of the application.

10. The computer readable medium of claim 7, further comprising, when the single asynchronous receive operation is issued:

placing a single pending receive data structure on a pending queue;

for each completed client request, copying contents of the pending receive data structure to a completed receive data structure queued on a receive completion queue.

11. The computer readable medium of claim 7, further comprising, for each completed client request, acquiring a buffer from system owned memory space to contain the completed client request.

12. The computer readable medium of claim 11, wherein allocating the buffer comprises sizing the buffer according to a size of the completed client request.

13. A system in a distributed computer environment, comprising:

a network facility configured to support a continuous mode network connection between a remote computer and a server computer;

a memory, on the server computer, containing content comprising an application and a plurality of sockets application programming interfaces (APIs), wherein the sockets APIs comprise at least one of an asynchronous accept operation and an asynchronous receive operation;

a processor which, when executing the contents, is configured to perform operation comprising

in response to a connection request, performing the single asynchronous accept operation to configure a listening socket to receive a plurality of incoming client connections, and wherein the content of the memory further comprises a pending queue on which a single pending accept data structure is queued as a result of the single asynchronous accept operation; and

in response to the asynchronous receive request, performing a single asynchronous receive operation to configure a client socket to receive a plurality of client requests, and wherein the content of the memory further comprises a pending queue on which a single pending receive data structure is queued as a result of the single asynchronous receive operation.

14. The system of claim 13, wherein the content of the memory further comprises a system owned memory space and wherein the operations further comprise:

for each completed client request, acquiring a buffer from the system owned memory space to contain the completed client request.

15. The system of claim 13, wherein the content of the memory further comprises a system owned memory space and wherein the operations further comprise:

for each completed client request, acquiring a buffer from the system owned memory space to contain the completed client request, wherein the buffer is sized according to a size of the completed client request.

16. The system of claim 13, wherein the content of the memory further comprises an accept completion queue to which contents of the pending accept data structure are copied upon receiving a client connection on the listening socket and wherein the pending accept data structure remains on the pending queue.

17. The system of claim 13, wherein the content of the memory further comprises a receive completion queue to which contents of the pending receive data structure are copied upon receiving a completed client request on the client socket and wherein the pending receive data structure remains on the pending queue.