On-demand processing pipeline interleaved with temporal processing pipeline

• US 10,437,641 B2
• Filed: 10/27/2017
• Issued: 10/08/2019
• Est. Priority Date: 06/19/2017
• Status: Active Grant

• Current Assignee: Cisco Technology, Inc. (Cisco Systems, Inc.)
• Original Assignee: Cisco Technology, Inc. (Cisco Systems, Inc.)
• Inventors: Narsude, Chetan, Gupta, Gaurav, Suleman, Azeem, Nazar, Shadab, Mamillapalli, Pavan, Iyer, Sundar
• Primary Examiner(s): Khatri, Anil
• Application Number:
  US15/796,263
• Publication Number:
  US 20180365061A1
• Time in Patent Office: 711 Days
• Field of Search: 718 1, 718100-108
• CPC Class Codes: G06F 16/951 Indexing; Web crawling techniques
• CPC Class Codes: G06F 9/4887 involving deadlines, e.g. rate based, periodic
• CPC Class Codes: G06F 9/52 Program synchronisation; Mutual exclusion, e.g. by means of semaphores

Abstract

Aspects of the technology provide systems and methods for interleaving a processing task in a network monitoring appliance. A process of the technology could include steps for identifying operators in the network monitoring appliance, wherein the operators are sequentially arranged to form a processing pipeline, determining an epoch for the processing pipeline, wherein the epoch corresponds with a time duration required for a processing task to traverse the pipeline, and determining a time window in which a supplemental processing task can be interleaved into the processing pipeline, wherein the time window is based on the epoch. Machine-readable media are also provided.

Claims

1. A computer-implemented method for interleaving a processing task in a network monitoring appliance, comprising:

identifying a plurality of operators in the network monitoring appliance, wherein the plurality of operators are sequentially arranged to form a sequentially processing pipeline;

determining an epoch for the processing pipeline,

wherein the epoch corresponds with a time duration required for a processing task to traverse the processing pipeline; and

determining a time window in which a supplemental processing task can be interleaved into the processing pipeline,

wherein the time window is based on the epoch;

interleaving the supplemental processing task into the processing pipeline during the time window.

2. The computer-implemented method of claim 1, further comprising:

selecting an idle operator, from among the plurality of operators in the processing pipeline; and

wherein the interleaving is executed by the idle operator.

3. The computer-implemented method of claim 2, wherein selecting the idle operator is further based on a type of processing associated with the supplemental processing task.

4. The computer-implemented method of claim 1, wherein determining the time window in which the supplemental processing task can be interleaved into the processing pipeline is further based on an estimated time duration to complete the supplemental processing task.

5. The computer-implemented method of claim 1, wherein the plurality of operators are setup as a Directed Acrylic Graph (DAG).

6. The computer-implemented method of claim 1, wherein each of the plurality of operators are configured to perform a different processing task.

7. The computer-implemented method of claim 1, wherein the network monitoring appliance is coupled to a tenant network, and

wherein the processing pipeline is configured to analyze data received from the tenant network to facilitate identification of one or more failure events in the tenant network.

8. A system comprising:

one or more processors;

a network interface coupled to the processors; and

a computer-readable medium coupled to the processors, the computer-readable medium comprising instructions stored therein, which when executed by the processors, cause the processors to perform operations comprising;

identifying a plurality of operators in the network monitoring appliance,

wherein the plurality of operators are sequentially arranged to form a sequentially processing pipeline;

determining an epoch for the processing pipeline, wherein the epoch corresponds with a time duration required for a processing task to traverse the processing pipeline; and

determining a time window in which a supplemental processing task can be interleaved into the processing pipeline,

wherein the time window is based on the epoch;

interleaving the supplemental processing task into the processing pipeline during the time window.

9. The system of claim 8, wherein the processors are further configured to perform operations comprising:

selecting an idle operator, from among the plurality of operators in the processing pipeline, based on the time window; and

wherein the interleaving is executed by the idle operator.

10. The system of claim 9, wherein selecting the idle operator is further based on a type of processing associated with the supplemental processing task.

11. The system of claim 8, wherein determining the time window in which the supplemental processing task can be interleaved into the processing pipeline is further based on an estimated time duration to complete the supplemental processing task.

12. The system of claim 8, wherein the plurality of operators are setup as a Directed Acrylic Graph (DAG).

13. The system of claim 8, wherein each of the plurality of operators are configured to perform a different processing task.

14. The system of claim 8, wherein the network monitoring appliance is coupled to a tenant network, and

wherein the processing pipeline is configured to analyze data received from the tenant network to facilitate identification of one or more failure events in the tenant network.

15. A non-transitory computer-readable storage medium

comprising instructions stored therein, which when executed by one or more

processors, cause the processors to perform operations comprising:

identifying a plurality of operators in the network monitoring appliance,

wherein the plurality of operators are sequentially arranged to form a sequentially processing pipeline;

determining an epoch for the processing pipeline,

wherein the epoch corresponds with a time duration required for a processing task to traverse the processing pipeline; and

determining a time window in which a supplemental processing task can be interleaved into the processing pipeline,

wherein the time window is based on the epoch;

interleaving the supplemental processing task into the processing pipeline during the time window.

16. The non-transitory computer-readable storage medium claim 15, wherein the processors are further configured to perform operations comprising:

selecting an idle operator, from among the plurality of operators in the processing pipeline, based on the time window; and

wherein the interleaving is executed by the idle operator.

17. The non-transitory computer-readable storage medium of claim 16, wherein selecting the idle operator is further based on a type of processing associated with the supplemental processing task.

18. The non-transitory computer-readable storage medium of claim 15, wherein determining the time window in which the supplemental processing task can be interleaved into the processing pipeline is further based on an estimated time duration to complete the supplemental processing task.

19. The non-transitory computer-readable storage medium of claim 15, wherein the plurality of operators are setup as a Directed Acrylic Graph (DAG).

20. The non-transitory computer-readable storage medium of claim 15, wherein each of the plurality of operators are configured to perform a different processing task.