Polling parameter adjustment

• US 10,021,011 B2
• Filed: 02/08/2017
• Issued: 07/10/2018
• 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:
  US15/427,497
• Publication Number:
  US 20170324637A1
• Time in Patent Office: 517 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, for adjusting polling parameters. The approach includes one or more processors polling an endpoint application using an initial polling quantity and an 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 in a queue at the endpoint application at an end of a polling cycle. Furthermore, the approach includes adjusting at least one of the initial polling quantity and the initial polling frequency based, at least in part, on a 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.

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 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

adjusting, by one or more processors, at least one of the initial polling quantity and the initial polling frequency based, at least in part, on a 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.

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

determining, by 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; 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, adjusting, by one or more processors, at least one of the initial polling quantity and the initial polling frequency, wherein adjusting includes at least one of reducing the initial polling quantity and reducing the initial polling frequency.

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

determining, by 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, adjusting, by one or more processors, at least one of the initial polling quantity and the initial polling frequency, wherein adjusting includes at least one of increasing the initial polling quantity and increasing the initial polling frequency.

4. The method of claim 1, further comprising polling, by one or more processors, the endpoint application with one or more adjusted polling parameters.

5. The method of claim 1, further comprising:

initializing, by 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 one or more processors, a first poll cycle in the poll group;

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

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

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

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

determining, by 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 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 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 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

adjusting at least one of the initial polling quantity and the initial polling frequency based, at least in part, on a 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.

10. The computer program product of claim 9, 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, adjusting at least one of the initial polling quantity and the initial polling frequency, wherein adjusting includes at least one of reducing the initial polling quantity and reducing the initial polling frequency.

11. The computer program product of claim 9, 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, adjusting at least one of the initial polling quantity and the initial polling frequency, wherein adjusting includes at least one of increasing the initial polling quantity and increasing the initial polling frequency.

12. The computer program product of claim 9, further comprising 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

adjusting at least one of the initial polling quantity and the initial polling frequency based, at least in part, on a 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.

18. The computer system of claim 17, 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, adjusting at least one of the initial polling quantity and the initial polling frequency, wherein adjusting includes at least one of reducing the initial polling quantity and reducing the initial polling frequency.

19. The computer system of claim 17, 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, adjusting at least one of the initial polling quantity and the initial polling frequency, wherein adjusting includes at least one of increasing the initial polling quantity and increasing 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.