System for managing data collection processes

• US 7,627,618 B2
• Filed: 02/21/2007
• Issued: 12/01/2009
• Est. Priority Date: 02/21/2007
• Status: Active Grant

• Current Assignee: Uber Technologies, Inc.
• Original Assignee: AT&T Knowledge Ventures, L.P. (AT&T, Inc.)
• Inventors: Honigfort, Ed
• Primary Examiner(s): Lu; Kuen S
• Application Number:
  US11/677,546
• Publication Number:
  US 20080201383A1
• Time in Patent Office: 1,014 Days
• Field of Search: 707/2, 707/104.1
• US Class Current: 1/1
• CPC Class Codes: G06F 16/217 Database tuning G06F16/2282 takes precedence; database performance monitoring G06F11/3409
• CPC Class Codes: G06F 16/2465 Query processing support for facilitating data mining operations in structured databases
• CPC Class Codes: G06F 9/46 Multiprogramming arrangements
• CPC Class Codes: Y10S 707/99955 Archiving or backup

Abstract

A system for managing data collection processes is disclosed. An apparatus that incorporates teachings of the present disclosure can include, a data collection system having a controller element that assigns a priority level for processes, assigns to each of the processes a query interval for requesting use of processing resources, prompts each of the processes according to their respective query interval to request use of at least a portion of available processing resources, releases at least a portion of the available processing resources to a requesting one of the processes when the utilization of available processing resources exceeds a utilization threshold, and modifies the query interval of the processes after occurrence of a triggering event. Additional embodiments are disclosed.

Claims

1. A data collection system, comprising:

a computer-readable storage medium; and

a controller element that;

assigns a priority level to each of a plurality of processes for collecting data in the data collection system;

assigns a query interval for requesting use of available processing resources of the controller element to each of the plurality of processes according to their respective assigned priority level, wherein the assigned query interval comprises a frequency for requesting the available processing resources;

prompts each of the plurality of processes according to their respective query interval to request use of at least a portion of available processing resources of the controller element;

releases at least a portion of the available processing resources of the controller element to a requesting one of the plurality of processes when the utilization of available processing resources exceeds a first utilization threshold; and

modifies the query interval of one or more of the plurality of processes after occurrence of a triggering event;

wherein the controller element determines the modified query interval of a select one of the plurality of processes according to at least one of a sum of a default query interval, an additional delay time assigned to each one of one or more of the plurality of processes assigned a priority level exceeding a priority level assigned to the select one of the plurality of processes, and a system delay time determined from the available amount of processing resources of the controller element.

2. The data collection system of claim 1, wherein the triggering event comprises at least one among an interval of time, a utilization of processing resources of the data collection system exceeding a second utilization threshold, and a quantity of the plurality of processes pending execution exceeding a quantity threshold.

3. The data collection system of claim 1, wherein the controller element repeats the prompting, releasing, and modifying steps.

4. The data collection system of claim 1, wherein the controller element reserves at least a portion of the available processing resources of the controller element for release to one or more of the plurality of processes assigned a priority level exceeding a priority threshold.

5. A computing device, comprising:

a processor; and

a controller element that generates data and prompts a data collection system to transfer data between the data collection system and the computing device, wherein said data collection system;

assigns a priority level to each of a plurality of processes, wherein at least one of the plurality of processes comprises a process associated with transferring data between the computing device and the data collection system;

computes a query interval for each of the plurality of processes according to their respective assigned priority level and available processing resources of the data collection system, wherein the query interval comprises a frequency for requesting the available processing resources;

releases at least a portion of the available processing resources of the data collection system to a requesting one of the plurality of processes according to release criteria; and

re-computes the query interval of one or more of the plurality of processes upon occurrence of one or more triggering events;

wherein the data collection system determines the computed query interval of the select one of the plurality of processes according to at least one of a sum of a default query interval and a system delay time determined from the available amount of processing resources of the data collection system.

6. The computing device of claim 5, wherein the data collection system repeats the release step according to the query interval.

7. The computing device of claim 5, wherein the data collection system determines the computed query interval of a select one of the plurality of processes according to a sum of a default query interval and an additional delay time assigned to each one of the plurality of processes assigned a priority level exceeding a priority level assigned to the select one of the plurality of processes.

8. The computing device of claim 5, wherein the data collection system reserves at least a portion of the available amount of processing resources for release to one or more of the plurality of processes assigned a priority level exceeding a priority threshold.

9. The computing device of claim 5, the data collection system determines the re-computed query interval of a select one of the plurality of processes according to a sum of an additional delay time assigned to each one of one or more of the plurality of processes assigned a priority level exceeding a priority level assigned to the select one of the plurality of processes and a system delay time determined from the available processing resources of the data collection system.

10. The computing device of claim 5, wherein the release criteria comprises having available processing resources sufficient for processing the requesting one of the plurality of processes and one or more of the plurality of processes assigned a priority level exceeding a priority level of the requesting one of the plurality of processes.

11. The computing device of claim 5, wherein the one or more triggering events comprise at least one among an interval of time, a utilization of the processing resources of the data collection system exceeding a utilization threshold, and a quantity of the plurality of processes pending execution exceeding a quantity threshold.

12. A computer-readable storage medium in a data collection system, having computer instructions stored therein, when executed by a machine in the data collection system, performs steps comprising:

assigning a priority level to each of a plurality of processes;

computing a query interval for each of the plurality of processes according to their respective assigned priority level and available processing resources, wherein the query interval comprises a frequency for requesting the available processing resources;

prompting one or more of the plurality of processes according to their respective query interval to request use of at least a portion of the available processing resources;

releasing at least a portion of the available processing resources to a requesting one of the plurality of processes according to release criteria;

re-computing the query interval of one or more processes upon occurrence of one or more triggering events; and

determining the re-computed query interval of a select one of the plurality of processes according to at least one of a sum of an additional delay time assigned to each one of one or more processes assigned a higher priority exceeding a priority level assigned to the select one of the plurality of processes and a system delay time determined from the available processing resources of the data collection system.

13. The storage medium of claim 12, repeating the prompting and releasing steps according to the query interval.

14. The storage medium of claim 12, comprising computer instructions for determining the computed query interval of a select one of the plurality of processes according to a sum of a default query interval, an additional delay time assigned to each of one or more other processes assigned a priority level exceeding a priority level assigned to the select one of the plurality of processes, and a system delay time determined from the available processing resources of the data collection system.

15. The storage medium of claim 12, comprising computer instructions for reserving at least a portion of the available processing resources of the data collection system for release to one or more of the plurality of processes assigned a priority level exceeding a priority threshold.

16. The storage medium of claim 12, wherein the release criteria comprises having available processing resources sufficient for executing the requesting one of the plurality of processes and at least one of the plurality of processes assigned a priority level exceeding the priority level of the requesting one of the plurality of processes.

17. The storage medium of claim 12, comprising computer instructions for determining the available amount of processing resources of the data collection system, wherein the triggering event comprises at least one among an interval of time, a utilization of the processing resources of the data collection system exceeding a utilization threshold, and a quantity of the plurality of processes pending execution exceeding a quantity threshold.