BEHAVIOR BASED CLIENT SELECTION FOR DISPARATE TREATMENT

• US 20120158886A1
• Filed: 12/15/2010
• Published: 06/21/2012
• Est. Priority Date: 12/15/2010
• Status: Active Grant

• Current Assignee: Kyndryl Incorporated (Kyndryl Holdings, Inc.)
• Original Assignee: International Business Machines Corporation
• Inventors: O'Connell, Brian M., Walker, Keith R.
• Granted Patent: US 8,799,454 B2
• Time in Patent Office: Days
• US Class Current: 709/217
• CPC Class Codes: H04L 41/0803 Configuration setting
• CPC Class Codes: H04L 47/762 triggered by the network
• CPC Class Codes: H04L 67/01 Protocols
• CPC Class Codes: H04L 67/1001 for accessing one among a plurality of replicated servers
• CPC Class Codes: H04L 67/1004 Server selection for load balancing
• 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 67/535 Tracking the activity of the user network monitoring arrangements H04L43/00; recording of computer activity G06F11/34

Abstract

Embodiments for server connection optimization in a persistently connected publish/subscribe environment are provided. A computer assigns an initial activity category for a client. The computer logs, into a log file, one or more select operations of a connection between a client and a first server. The computer calculates a ratio of a number of the select operations to a check time of the first server, wherein the check time is a period of time that has elapsed since a previous review of logged data. The computer sets a second activity category for the client based on a look-up of the ratio in a schedule of ratio ranges in a control file, wherein the second activity category is not the initial activity category. The computer transfers the client from the first server to a second server, in response to setting the second activity category.

Claims

1. A method for server connection optimization in a persistently connected publish/subscribe environment, the method comprising:

a computer assigning an initial activity category for a client;

the computer logging, into a log file, one or more select operations of a connection between the client and a first server;

the computer calculating a ratio of a number of the one or more select operations to a check time of the first server, wherein the check time is a period of time that has elapsed since a previous review of logged data;

the computer setting a second activity category for the client based on a look-up of the ratio in a schedule of ratio ranges in a control file, wherein the second activity category is not the initial activity category; and

the computer transferring the client from the first server to a second server, in response to setting the second activity category.

2. The method of claim 1, wherein the computer logging into the log file the one or more select operations of the connection between the client and the first server is responsive to the server detecting that the client has been connected to the first server for a probation period.

3. The method of claim 1, wherein the first server has a first network address, the second server has a second network address, and the second server and first server are logical partitions on a virtualized server.

4. The method of claim 1, wherein the initial activity category is a high activity category, and wherein the computer setting the second activity category for the client based on the look-up of the ratio in the schedule of ratio ranges in the control file comprises the computer reassigning the client to a low activity category, and wherein the method further comprises:

the computer queuing one or more first client messages during an extended interval;

the computer processing the one or more first client messages responsive to the extended interval expiring;

the computer, responsive to reassigning the client to the low activity category, queuing one or more second client messages during a standard interval, wherein the standard interval is a shorter duration than the extended interval; and

the computer processing the one or more second client messages responsive to the standard interval expiring.

5. The method of claim 4, wherein the computer reassigning the client to the low activity category is responsive to the computer determining that greater than 50% of clients are assigned to the low activity category.

6. The method of claim 1, wherein the initial activity category is a high activity category, wherein the computer setting the second activity category for the client based on the look-up of the ratio in the schedule of ratio ranges in the control file comprises the computer reassigning the client to a low activity category corresponding to a first ratio range of ratios smaller than a second ratio range in the schedule of ratio ranges, and wherein the method further comprises:

the computer, receiving a first message from the client while the client is assigned to the high activity category;

the computer, responsive to receiving the first message, executing an I/O request associated with the first message;

the computer receiving a second message from the client while the client is assigned to the low activity category; and

the computer, responsive to receiving the second message, executing an I/O request associated with the second message.

7. A computer program product comprising one or more computer-readable, tangible storage devices and computer-readable program instructions which are stored on the one or more storage devices and when executed by one or more processors, perform the method of claim 1.

8. A computer system comprising one or more processors, one or more computer-readable memories, one or more computer-readable, tangible storage devices and program instructions which are stored on the one or more storage devices for execution by the one or more processors via the one or more memories and when executed by the one or more processors perform the method of claim 1.

9. A computer program product for server connection optimization in a persistently connected publish/subscribe environment, the computer program product comprising:

one or more computer-readable, tangible storage devices;

program instructions, stored on at least one of the one or more storage devices, to assign an initial activity category for a client;

program instructions, stored on at least one of the one or more storage devices, to log, into a log file, one or more select operations of a connection between the client and a first server;

program instructions, stored on at least one of the one or more storage devices, to calculate a ratio of a number of the one or more select operations to a check time of the first server, wherein the check time is a period of time that has elapsed since a previous review of logged data;

program instructions, stored on at least one of the one or more storage devices, to set a second activity category for the client based on a look-up of the ratio in a schedule of ratio ranges in a control file, wherein the second activity category is not the initial category; and

program instructions, stored on at least one of the one or more storage devices, to transfer the client from the first server to a second server, in response to setting the second activity category.

10. The computer program product of claim 9, further comprising program instructions, stored at least one of the one or more storage devices, to detect whether the client has been connected to the first server for a probation period;

and wherein the program instructions to log, into the log file, the one or more select operations of the connection between the client and the first server are responsive to the program instructions to detect whether the client has been connected to the first server for the probation period.

11. The computer program product of claim 9, wherein the initial activity category is a high activity category, wherein the program instructions to set the second activity category for the client based on the look-up of the ratio in the schedule of ratio ranges in the control file reassign the client to a low activity category, and wherein the computer program product further comprises:

program instructions, stored on at least one of the one or more storage devices, to queue one or more first client messages during an extended interval;

program instructions, stored on at least one of the one or more storage devices, to process the one or more first client messages responsive to the extended interval expiring;

program instructions, stored on at least one of the one or more storage devices, responsive to reassigning the client to the low activity category, to queue one or more second client messages during a standard interval, wherein the standard interval is a shorter duration than the extended interval; and

program instructions, stored on at least one of the one or more storage devices, to process the one or more second client messages responsive to the standard interval expiring.

12. The computer program product of claim 11, further comprising program instructions, stored on at least one of the one or more storage devices, to determine that greater than 50% of clients are assigned to the low activity category;

and wherein the program instructions to set the second activity category for the client based on the look-up of the ratio in the schedule of ratio ranges in the control file reassign the client to the low activity category are responsive to the program instructions to determine that greater than 50% of clients are assigned to the low activity category.

13. The computer program product of claim 9, wherein the initial activity category is a high activity category, wherein the program instructions to set the second activity category for the client based on the look-up of the ratio in the schedule of ratio ranges in the control file reassign the client to a low activity category corresponding to a first ratio range of ratios smaller than a second ratio range in the schedule of ratio ranges, and wherein the computer program product further comprises:

program instructions, stored on at least one of the one or more storage devices, to receive a first message from the client while the client is assigned to the high activity category;

program instructions, stored on at least one of the one or more storage devices, responsive to receiving the first message, to execute an I/O request associated with the first message;

program instructions, stored on at least one of the one or more storage devices, to receive a second message from the client while the client is assigned to the low activity category; and

program instructions, stored on at least one of the one or more storage devices, responsive to receiving the second message, to execute an I/O request associated with the second message.

14. A data processing system for server connection optimization in a persistently connected publish/subscribe environment, the data processing system comprising:

one or more processors, one or more computer-readable memories and one or more computer-readable, tangible storage devices;

program instructions, stored on at least one of the one or more storage devices for execution by at least one of the one or more processors via at least one of the one or more memories, to assign an initial activity category for a client;

program instructions, stored on at least one of the one or more storage devices for execution by at least one of the one or more processors via at least one of the one or more memories, to log, into a log file, one or more select operations of a connection between the client and a first server;

program instructions, stored on at least one of the one or more storage devices for execution by at least one of the one or more processors via at least one of the one or more memories, to calculate a ratio of a number of the one or more select operations to a check time of the first server, wherein the check time is a period of time that has elapsed since a previous review of logged data;

program instructions, stored on at least one of the one or more storage devices for execution by at least one of the one or more processors via at least one of the one or more memories, to set a second activity category for the client based on a look-up of the ratio in a schedule of ratio ranges in a control file, wherein the second activity category is not the initial category; and

program instructions, stored on at least one of the one or more storage devices for execution by at least one of the one or more processors via at least one of the one or more memories, to transfer the client from the first server to a second server, in response to setting the second activity category.

15. The data processing system of claim 14, wherein the second activity category is a middle activity category comprising a ratio range having a lower threshold of at least one select operation per 60 seconds and an upper threshold of, at most, ten select operations per 60 seconds.

16. The data processing system of claim 14, further comprising program instructions, stored at least one of the one or more storage devices for execution by at least one of the one or more processors via at least one of the one or more memories, to detect whether the client has been connected to the first server for a probation period;

and wherein the program instructions to log, into the log file, the one or more select operations of the connection between the client and the first server are responsive to the program instructions to detect whether the client has been connected to the first server for the probation period.

17. The data processing system of claim 14, wherein the initial activity category is a high activity category, wherein the program instructions to set the second activity category for the client based on the look-up of the ratio in the schedule of ratio ranges in the control file reassign the client to a low activity category, and wherein the data processing system further comprises:

program instructions, stored on at least one of the one or more storage devices for execution by at least one of the one or more processors via at least one of the one or more memories, to queue one or more first client messages during an extended interval;

program instructions, stored on at least one of the one or more storage devices for execution by at least one of the one or more processors via at least one of the one or more memories, to process the one or more first client messages responsive to the extended interval expiring;

program instructions, stored on at least one of the one or more storage devices for execution by at least one of the one or more processors via at least one of the one or more memories, responsive to reassigning the client to the low activity category, to queue one or more second client messages during a standard interval, wherein the standard interval is a shorter duration than the extended interval; and

program instructions, stored on at least one of the one or more storage devices for execution by at least one of the one or more processors via at least one of the one or more memories, to process the one or more second client messages responsive to the standard interval expiring.

18. The data processing system of claim 17, further comprising program instructions, stored on at least one of the one or more storage devices for execution by at least one of the one or more processors via at least one of the one or more memories, to determine that greater than 50% of clients are assigned to the low activity category;

and wherein the program instructions to set the second activity category for the client based on the look-up of the ratio in the schedule of ratio ranges in the control file reassign the client to the low activity category are responsive to the program instructions to determine that greater than 50% of clients are assigned to the low activity category.

19. The data processing system of claim 14, wherein the initial activity category is a high activity category, wherein the program instructions to set the second activity category for the client based on the look-up of the ratio in the schedule of ratio ranges in the control file reassign the client to a low activity category corresponding to a first ratio range of ratios smaller than a second ratio range in the schedule of ratio ranges, and wherein the data processing system further comprises:

program instructions, stored on at least one of the one or more storage devices for execution by at least one of the one or more processors via at least one of the one or more memories, to receive a first message from the client while the client is assigned to the high activity category;

program instructions, stored on at least one of the one or more storage devices for execution by at least one of the one or more processors via at least one of the one or more memories, responsive to receiving the first message, to execute an I/O request associated with the first message;

program instructions, stored on at least one of the one or more storage devices for execution by at least one of the one or more processors via at least one of the one or more memories, to receive a second message from the client while the client is assigned to the low activity category; and

program instructions, stored on at least one of the one or more storage devices for execution by at least one of the one or more processors via at least one of the one or more memories, responsive to receiving the second message, to execute an I/O request associated with the second message.

20. A method for batching ping replies, the method comprising:

a computer transmitting a scheduled ping to each of a plurality of clients;

the computer queuing a client message with at least one other client message;

the computer processing a plurality of queued client messages to categorize a subset of the plurality of clients as responding clients;

the computer determining that a timeout period is expired; and

the computer, responsive determining that the timeout period is expired, disconnecting at least one client that has not responded to the scheduled ping during the timeout period.

21. The method of claim 20, wherein the computer processing a plurality of queued client messages comprises the computer processing a select operation, and wherein the queued client messages include the client message and the at least one other client message.

22. The method of claim 20, wherein the computer transmitting the scheduled ping to each of the plurality of clients comprises the computer setting an indication in the scheduled ping informing each of the plurality of clients to respond to the scheduled ping using the user datagram protocol.

23. A method for batching ping replies, the method comprising:

a computer transmitting a scheduled ping specifying a return address dedicated to ping replies to each of a plurality of clients;

the computer receiving a plurality of ping responses to the return address;

the computer, responsive to receiving the plurality of ping responses to the return address, updating a data structure of one or more candidate clients for disconnect;

the computer determining that a timeout period is expired; and

the computer, responsive to determining that the timeout period is expired, disconnecting one or more clients present in the data structure of the one or more candidate clients for disconnect.