Communication method with reduced response time in a distributed data processing system

• US 20060026169A1
• Filed: 05/06/2005
• Published: 02/02/2006
• Est. Priority Date: 11/06/2002
• Status: Abandoned Application

• Current Assignee: Roberto Della Pasqua
• Original Assignee: Roberto Della Pasqua
• Inventors: Pasqua, Roberto Della
• Application Number:
  US11/124,397
• Publication Number:
  US 20060026169A1
• Time in Patent Office: Days
• US Class Current: 1/1
• CPC Class Codes: G06F 2209/5018 Thread allocation
• CPC Class Codes: G06F 9/5044 considering hardware capabilities
• CPC Class Codes: G06F 9/5055 considering software capabilities, i.e. software resources associated or available to the machine
• CPC Class Codes: G06F 9/544 Buffers; Shared memory; Pipes

Abstract

A communication method is proposed in a distributed data processing system including a plurality of client computers and at least one server computer. The method includes the steps under the control of the at least one server computer of: receiving a connection request from a client computer, establishing a connection with the client computer in response to the connection request, classifying the connection according to a typology defined by a persistence thereof, responding to the connection request directly or associating the connection with a reading processing entity having a corresponding latency according to the typology of the connection, periodically activating each reading processing entity according to the corresponding latency, verifying a state of each associated connection by the activated reading processing entity, and responding to each further request received in each connection associated with the activated reading processing entity.

Claims

1. A communication method in a distributed data processing system including a plurality of client computers and at least one server computer, the method including the steps under the control of the at least one server computer of:

receiving a connection request from a client computer,

establishing a connection with the client computer in response to the connection request,

classifying the connection according to a typology defined by a persistence thereof,

responding to the connection request directly or associating the connection with a reading processing entity having a corresponding latency according to the typology of the connection,

periodically activating each reading processing entity according to the corresponding latency,

verifying a state of each associated connection by the activated reading processing entity, and

responding to each further request received in each connection associated with the activated reading processing entity.

2. The method according to claim 1, wherein the step of responding to the connection request directly or associating the connection to the reading processing entity includes:

responding to the connection request directly if the connection involves at least an immediate response, or

associating the connection with the reading processing entity otherwise.

3. The method according to claim 2, wherein the step of responding to the connection request directly is performed if the connection involves a single immediate response.

4. The method according to claim 2, wherein the step of responding to the connection request directly is performed if the connection involves a plurality of immediate responses, the method further including the step of closing the connection when an inactivity time-out is reached.

5. The method according to claim 1, wherein the latency is higher than 0,2 s.

6. The method according to claim 1, wherein the step of associating the connection with the reading processing entity includes selecting one among a plurality of reading processing entities, each one having a corresponding latency, according to logical characteristics of the connection.

7. The method according to claim 6, wherein the step of receiving the connection request includes:

checking a listening communication entity to which the connection requests are sent by each client computer at an operating system level, and

notifying each detected connection request to a sorting processing entity at an application level.

8. The method according to claim 7, wherein the step of establishing the connection includes:

the sorting processing entity notifying each connection request in succession to one of a plurality of analysis processing entities at the application level, and

each analysis processing entity allocating a communication entity in response to the connection request.

9. The method according to claim 8, wherein the step of associating the connection to the reading processing entity includes:

selecting one among a plurality of pools of reading processing entities for corresponding categories of logic characteristics of the connections,

activating a new reading processing entity for the selected pool if all the reading processing entities of the selected pool are associated with a preset maximum number of connections, and

associating the connection to one of the reading processing entities of the selected pool associated with a number of connections lower than the preset maximum number.

10. The method according to claim 9, wherein the step of verifying the state of each associated connection by the activated reading processing entity includes:

checking a state of an input buffer managed at the operating system level for each communication entity associated with the connection,

transferring each block of data present in the input buffer to a corresponding input structure at the application level,

verifying whether the blocks of data in the input structure complete at least one input message, and

notifying the completion of the at least one input message to an execution module.

11. The method according to claim 10, wherein the step of checking the state of the input buffer for each communication entity associated with the connection includes:

receiving a list managed at the operating system level, the list being indicative of the corresponding input buffers comprising at least one block of data.

12. The method according to claim 10, wherein the step of verifying the state of each associated connection by the activated reading processing entity further includes:

closing the connection if a frequency of the received blocks of data exceeds a threshold value.

13. The method according to claim 10, wherein the step of responding to each further request received in each connection associated with the activated reading processing entity includes:

inserting a reference to the at least one input message into a first queue at the operating system level in response to the notification of the completion of the at least one input message,

extracting an indication of one among a plurality of available execution processing entities from a second queue at the operating system level,

assigning the at least one input message to the execution processing entity,

processing the at least one input message by the execution processing entity, and

re-inserting the indication of the execution processing entity into the second queue at the end of the processing of the at least one input message.

14. The method according to claim 13, wherein the step of processing the at least one input message includes:

deriving an output message in response to the at least one input message, and

inserting the output message into an output buffer managed at the operating system level for at least one selected of the connections.

15. The method according to claim 14, wherein the at least one selected connection consists of a plurality of selected connections, the step of inserting the output message into the output buffer for the selected connections including:

causing the operating system to duplicate the output message into the output buffers for the selected connections.

16. In a distributed data processing system including a plurality of client computers and at least one server computer, a computer program product including a computer-usable medium embodying a computer program, the computer program when executed on the at least one server computer causing the at least one server computer to perform a communication method including the steps of:

receiving a connection request from a client computer,

establishing a connection with the client computer in response to the connection request,

classifying the connection according to a typology defined by a persistence thereof,

responding to the connection request directly or associating the connection with a reading processing entity having a corresponding latency according to the typology of the connection,

periodically activating each reading processing entity according to the corresponding latency,

verifying a state of each associated connection by the activated reading processing entity, and

responding to each further request received in each connection associated with the activated reading processing entity.

17. In a distributed data processing system including a plurality of client computers and at least one server computer, a server computer including means for receiving a connection request from a client computer, means for establishing a connection with the client computer in response to the connection request, means for classifying the connection according to a typology defined by a persistence thereof, means for responding to the connection request directly or associating the connection with a reading processing entity having a corresponding latency according to the typology of the connection, means for periodically activating each reading processing entity according to the corresponding latency, the activated reading processing entity verifying a state of each associated connection, and means for responding to each further request received in each connection associated with the activated reading processing entity.