Polling parameter adjustment

• US 10,250,480 B2
• Filed: 06/07/2018
• Issued: 04/02/2019
• Est. Priority Date: 05/05/2016
• Status: Active Grant

• Current Assignee: International Business Machines Corporation
• Original Assignee: International Business Machines Corporation
• Inventors: Emam, Ossama, Valecha, Vinod A.
• Primary Examiner(s): Ho, Andy
• Application Number:
  US16/002,015
• Publication Number:
  US 20180287923A1
• Time in Patent Office: 299 Days
• Field of Search: 719318
• CPC Class Codes: G06F 9/541 via adapters, e.g. between incompatible applications
• CPC Class Codes: G06F 9/542 Event management; Broadcasting; Multicasting; Notifications
• CPC Class Codes: H04L 43/103 with adaptive polling, i.e. dynamically adapting the polling rate
• CPC Class Codes: H04L 47/58 Changing or combining different scheduling modes, e.g. multimode scheduling
• CPC Class Codes: H04L 67/60 Scheduling or organising the servicing of application requests, e.g. requests for application data transmissions using the analysis and optimisation of the required network resources admission control or resource allocation H04L47/70

Abstract

An approach, executed by a computer, includes receiving at least an initial polling quantity and an initial polling frequency and polling an endpoint application using the initial polling quantity and the initial polling frequency. The approach includes determining a first number of events not consumed in a queue of a listening application and a second number of events generated at the endpoint application and remaining in a queue at the endpoint application and comparing the number of events in each queue. The approach includes adjusting at least one of the initial polling quantity and the initial polling frequency based, at least in part, on the comparison of the first number of events not consumed in the queue of the listening application and the second number of events generated at the endpoint application and remaining in the queue at the endpoint application.

Claims

1. A method for adjusting polling parameters, comprising:

polling, by one or more processors, an endpoint application using an initial polling quantity and an initial polling frequency;

determining, by the one or more processors, a first number of events not consumed in a queue of a listening application and a second number of events in a queue at the endpoint application at an end of a polling cycle; and

comparing, by the one or more processors, the first number of events not consumed in the queue of the listening application and the second number of events in the queue at the endpoint application at the end of the polling cycle.

2. The method of claim 1, further comprising:

adjusting, by the one or more processors, at least one of the initial polling quantity and the initial polling frequency based, at least in part, on the comparison of the first number of events not consumed in the queue of the listening application and the second number of events in the queue at the endpoint application at the end of the polling cycle, wherein adjusting includes one of reducing at least one of the initial polling quantity and the initial polling frequency or increasing at least one of the initial polling quantity and the initial polling frequency.

3. The method of claim 2, wherein adjusting at least one of the initial polling quantity and the initial polling frequency further comprises:

determining, by the one or more processors, when the first number of events not consumed in a queue of the listening application is less than the second number of events in the queue at the endpoint application at the end of the polling cycle; and

responsive to determining that the first number of events not consumed in the queue of the listening application is less than the second number of events in the queue at the endpoint application, increasing, by the one or more processors, at least one of the initial polling frequency and the initial polling quantity, wherein increasing the initial polling quantity is increasing the initial polling quantity by one of a polling quantity increment or by one half of a difference in the number of the first number of events in the queue not consumed in a queue of the listening application and the second number of events in the queue at the endpoint application at the end of the polling cycle.

4. The method of claim 2, wherein adjusting at least one of the initial polling quantity and the initial polling frequency further comprises:

determining, by the one or more processors, whether the first number of events not consumed in the queue of the listening application is greater than the second number of events in the queue at the endpoint application at the end of the polling cycle;

responsive to determining that the first number of events not consumed in the queue of the listening application is greater than the second number of events at the endpoint application at the end of the polling cycle, reducing, by the one or more processors, at least one of the initial polling quantity and the initial polling frequency; and

polling, by the one or more processors, the endpoint application with the one or more adjusted polling parameters.

5. The method of claim 1, further comprising:

initializing, by the one or more processors, a poll group, wherein initializing includes receiving from a user a plurality of initial values for at least a poll group size, a maximum poll interval, and a minimum poll quantity;

executing, by the one or more processors, a first poll cycle in the poll group;

recording, by the one or more processors, poll data for the first poll cycle in the poll group;

executing, by the one or more processors, at least another poll cycle in the poll group;

determining, by the one or more processors, there are no other poll cycles in the poll group;

determining, by the one or more processors, a plurality of statistics for the poll group;

determining, by the one or more processors, one or more adjusted polling parameters based, at least in part, on the plurality of statistics for the poll group; and

determining, by the one or more processors, whether there is another poll group.

6. The method of claim 5, wherein the plurality of statistics include at least an average time taken for the poll cycles in the poll group, an average number of events polled for the poll cycles in the poll group, a cumulative average time taken for the poll group and a cumulative average number of events for the poll group.

7. The method of claim 6, wherein determining, by the one or more processors, the one or more adjusted polling parameters further comprises responsive to determining that the average number of events polled is less than a polling quantity in a last polling cycle in the poll group, reducing the polling quantity to either a maximum of the minimum poll quantity or the cumulative average time taken for the poll group.

8. The method of claim 6, wherein determining, by the one or more processors, the one or more adjusted polling parameters further comprises responsive to determining that the average number of events polled is less than a polling quantity of a last polling cycle in the poll group, setting the poll interval to a minimum of a lesser of a maximum poll interval and the cumulative average time taken for the poll group.

9. A computer program product for adjusting polling parameters, comprising:

one or more computer readable storage media and program instructions stored on the one or more computer readable storage media, the program instructions executable by a processor, the program instructions comprising instructions for;

polling an endpoint application using an initial polling quantity and an initial polling frequency;

determining a first number of events not consumed in a queue of a listening application and a second number of events in a queue at the endpoint application at an end of a polling cycle; and

comparing the first number of events not consumed in the queue of the listening application and the second number of events in the queue at the endpoint application at the end of the polling cycle.

10. The computer program product of claim 9, further comprising:

adjusting at least one of the initial polling quantity and the initial polling frequency based, at least in part, on the comparison of the first number of events not consumed in the queue of the listening application and the second number of events in the queue at the endpoint application at the end of the polling cycle, wherein adjusting includes one of reducing at least one of the initial polling quantity or the initial polling frequency or increasing at least one of the initial polling quantity or the initial polling frequency.

11. The computer program product of claim 10, wherein adjusting at least one of the initial polling quantity and the initial polling frequency further comprises:

determining when the first number of events not consumed in a queue of the listening application is less than the second number of events in the queue at the endpoint application at the end of the polling cycle; and

responsive to determining that the first number of events not consumed in the queue of the listening application is less than the second number of events in the queue at the endpoint application, increasing at least one of the initial polling frequency and the initial polling quantity, wherein increasing the initial polling quantity is increasing the initial polling quantity by one of a polling quantity increment or by one half of a difference in the number of the first number of events in the queue not consumed in the queue of the listening application and the second number of events in the queue at the endpoint application at the end of the polling cycle.

12. The computer program product of claim 10, wherein adjusting at least one of the initial polling quantity and the initial polling frequency further comprises:

determining whether the first number of events not consumed in the queue of the listening application is greater than the second number of events in the queue at the endpoint application at the end of the polling cycle;

responsive to determining that the first number of events not consumed in the queue of the listening application is greater than the second number of events at the endpoint application at the end of the polling cycle, reducing at least one of the initial polling quantity and the initial polling frequency; and

polling the endpoint application with one or more adjusted polling parameters.

13. The computer program product of claim 9, further comprising:

initializing a poll group, wherein initializing includes receiving from a user a plurality of initial values for at least a poll group size, a maximum poll interval, and a minimum poll quantity;

executing a first poll cycle in the poll group;

recording poll data for the first poll cycle in the poll group;

executing at least another poll cycle in the poll group;

determining there are no other poll cycles in the poll group;

determining a plurality of statistics for the poll group;

determining one or more adjusted polling parameters based, at least in part, on the plurality of statistics for the poll group; and

determining whether there is another poll group.

14. The computer program product of claim 13, wherein the plurality of statistics include at least an average time taken for the poll cycles in the poll group, an average number of events polled for the poll cycles in the poll group, a cumulative average time taken for the poll group and a cumulative average number of events for the poll group.

15. The computer program product of claim 13, wherein determining the one or more adjusted polling parameters further comprises responsive to determining that the average number of events polled is less than a polling quantity in a last polling cycle in the poll group, reducing the polling quantity to either a maximum of the minimum poll quantity or the cumulative average time taken for the poll group.

16. The computer program product of claim 13, wherein determining the one or more adjusted polling parameters further comprises responsive to determining that the average number of events polled is less than a polling quantity of a last polling cycle in the poll group, setting the poll interval to a minimum of a lesser of a maximum poll interval and the cumulative average time taken for the poll group.

17. A computer system comprising:

one or more computer processors;

one or more computer readable storage media; and

program instructions stored on the one or more computer readable storage media for execution by at least one of the one or more computer processors, the program instructions comprising instructions to perform a method comprising;

polling an endpoint application using an initial polling quantity and an initial polling frequency;

determining a first number of events not consumed in a queue of a listening application and a second number of events in a queue at the endpoint application at an end of a polling cycle; and

comparing the first number of events not consumed in the queue of the listening application and the second number of events in the queue at the endpoint application at the end of the polling cycle.

18. The computer program product of claim 17, further comprising:

adjusting at least one of the initial polling quantity and the initial polling frequency based, at least in part, on the comparison of the first number of events not consumed in the queue of the listening application and the second number of events in the queue at the endpoint application at the end of the polling cycle, wherein adjusting includes one of reducing at least one of the initial polling quantity or the initial polling frequency or increasing at least one of the initial polling quantity or the initial polling frequency.

19. The computer system of claim 18, wherein adjusting at least one of the initial polling quantity and the initial polling further comprises:

determining whether the first number of events not consumed in the queue of the listening application is greater than the second number of events in the queue at the endpoint application at the end of the polling cycle; and

responsive to determining that the first number of events not consumed in the queue of the listening application is greater than the second number of events at the endpoint application at the end of the polling cycle, reducing at least one of reducing the initial polling quantity and reducing the initial polling frequency.

20. The computer system of claim 17, further comprising:

initializing a poll group, wherein initializing includes receiving from a user a plurality of initial values for at least a poll group size, a maximum poll interval, and a minimum poll quantity;

executing a first poll cycle in the poll group;

recording poll data for the first poll cycle in the poll group;

executing at least another poll cycle in the poll group;

determining there are no other poll cycles in the poll group;

determining a plurality of statistics for the poll group;

determining one or more adjusted polling parameters based, at least in part, on the plurality of statistics for the poll group; and

determining whether there is another poll group.