Polling parameter adjustment

• US 9,632,850 B1
• Filed: 05/05/2016
• Issued: 04/25/2017
• Est. Priority Date: 05/05/2016
• Status: Expired due to Fees

• 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/147,229
• Time in Patent Office: 355 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:

receiving, by one or more processors, at least an initial polling quantity and an initial polling frequency;

polling, by one or more processors, an endpoint application using the initial polling quantity and the 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 generated at the endpoint application and remaining in a queue at the endpoint application;

comparing, by one or more processors, 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 at the 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 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.

2. The method of claim 1, wherein providing, by one or more processors, the one or more adjusted polling parameters 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 generated and remaining 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 generated 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 reducing the initial polling quantity and reducing the initial polling frequency.

3. The method of claim 1, wherein providing, by one or more processors, the one or more adjusted polling parameters 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 generated 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 generated 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 the one or more adjusted polling parameters.

5. The method of claim 1, wherein a checker in a software adapter determines 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.

6. The method of claim 1, wherein a calculator in a software adapter compares 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.

7. The method of claim 1, further comprises:

determining, by one or more processors, a next number of events not consumed in the queue of a listening application and a next number of events generated and remaining in the queue at the endpoint application;

comparing, by one or more processors, the next number of events not consumed in the queue of the listening application and the next number of events generated and remaining in the queue at the endpoint application; and

providing, by one or more processors, one or more second adjusted polling parameters based, at least in part, on the comparison of the next number of events not consumed in the queue of the listening application and the next number of events generated at the endpoint application.

8. The method of claim 7, wherein the second adjusted polling parameter is at least one of a second adjusted polling quantity and a second adjusted polling frequency.

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

10. The method of claim 9, 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.

11. The method of claim 10, 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.

12. The method of claim 10, 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.

13. 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;

receiving at least an initial polling quantity and an initial polling frequency;

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

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;

comparing 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 at the 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 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.

14. The computer program product of claim 13, wherein providing the one or more adjusted polling parameters 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 generated and remaining 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 generated 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 reducing the initial polling quantity and reducing the initial polling frequency.

15. The computer program product of claim 13, wherein providing the one or more adjusted polling parameters further comprises:

determining whether the first number of events not consumed in a queue of the listening application is less than the second number of events generated 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 generated 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.

16. The computer program product of claim 13, further comprises:

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.

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

18. 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;

receiving at least an initial polling quantity and an initial polling frequency;

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

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;

comparing 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 at the end of the polling cycle; and

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.

19. The computer system of claim 18, wherein providing the one or more adjusted polling parameters further comprises:

determining whether the first number of events not consumed in the queue of the listening application is less than the second number of events generated 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 generated 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 18, further comprises:

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.