Resource scheduler within a network device

• US 7,930,408 B1
• Filed: 06/02/2009
• Issued: 04/19/2011
• Est. Priority Date: 12/29/2006
• Status: Expired due to Fees

• Current Assignee: Juniper Networks Incorporated
• Original Assignee: Juniper Networks Incorporated
• Inventors: Sun, Yi, Cheng, Yonghui
• Primary Examiner(s): Maung; Zarni
• Application Number:
  US12/476,315
• Time in Patent Office: 686 Days
• Field of Search: 709227-229, 709/203, 709/250, 713/188, 713/200, 713/201
• US Class Current: 709/227
• CPC Class Codes: H04L 47/193 at the transport layer, e.g. TCP related
• CPC Class Codes: H04L 47/2416 Real-time traffic
• CPC Class Codes: H04L 47/50 Queue scheduling
• CPC Class Codes: H04L 47/52 by attributing bandwidth to queues
• CPC Class Codes: H04L 49/9047 including multiple buffers, e.g. buffer pools
• CPC Class Codes: H04L 63/145 the attack involving the propagation of malware through the network, e.g. viruses, trojans or worms
• CPC Class Codes: H04L 67/62 Establishing a time schedule for servicing the requests

Abstract

A network device is described in which a dedicated resource scheduler monitors memory consumption to provide for improved processing of communication sessions. The scheduler maintains a dependency list of communication sessions, and reserves memory for communication sessions as requests for memory are received. The amount of memory reserved is determined based on the amount of memory currently reserved for the communication sessions in the dependency list. The network device may control ongoing communication sessions by way of window manipulation. Communication sessions are processed in a first mode when available memory has not reached a predetermined amount, while communication sessions are processed in a second mode when available memory reaches a predetermined amount.

Claims

1. An anti-virus device for processing communication sessions comprising:

an internal memory;

an anti-virus engine that performs file-based anti-virus scanning on network traffic received via communication sessions using the internal memory; and

a resource scheduler module that prevents the communication sessions from timing out by allocating memory from the internal memory so that at least one of the communication sessions is guaranteed to be processed to completion.

2. The device of claim 1, wherein the resource scheduler module is configured such that:

when available memory has not reached a predetermined amount remaining, the resource scheduler module operates in a first mode to cause the anti-virus engine to process the communication sessions in parallel; and

when available memory reaches a predetermined amount remaining, the resource scheduler module operates in a second mode to cause the anti-virus engine to process the communication sessions sequentially in accordance with a dependency list of communication sessions maintained by the resource scheduler module, wherein the dependency list specifies an order in which to process the communications sessions and specifies an amount of memory currently reserved for each of the communication sessions.

3. The device of claim 2, further comprising:

an anti-virus engine that processes the communication sessions in accordance with the dependency list; and

a proxy module that receives a request to reserve memory for processing a new communication session;

wherein the resource scheduler module determines whether an amount of memory required to process the new communication session is greater than a total amount of memory reserved for the communication sessions already listed within the dependency list, and

wherein when the amount of memory required to process the new communication session is greater than the total amount of memory reserved for the communication sessions already listed within the dependency list, the resource scheduler module reserves memory for the new communication session in an amount equal to a difference between the amount of memory required to process the new communication session and the total amount of memory currently reserved for the communication sessions already listed to guarantee that processing of the new communication session can be completed upon processing the communication sessions already listed within the dependency list.

4. The device of claim 3, wherein the proxy module is a Transmission Control Protocol (TCP) proxy module, and wherein the communication sessions are TCP sessions.

5. The device of claim 2, further comprising a connection management module that dynamically initiates closing of communication windows for the communication sessions other than the first communication session on the dependency list when the scheduler operates in the second mode.

6. The device of claim 1, wherein the internal memory comprises:

a heap of available memory;

a public buffer pool; and

a reserved buffer pool, wherein the public buffer pool and the reserved buffer pool are maintained as logical data structures on top of the heap and used for allocating packet buffers to store packets received via the communication sessions,

wherein the resource scheduler module operates in a first mode when neither the available memory within the heap nor available memory within the public buffer pool has reached a respective predetermined amount, and

wherein the resource scheduler module operates in a second mode when either the available memory within the heap or the available memory within the public buffer pool has reached a respective predetermined amount.

7. A method comprising:

with an anti-virus device, performing file-based anti-virus scanning on network traffic received via communication sessions using an internal memory of the anti-virus device; and

preventing the communication sessions from timing out by allocating memory with a resource scheduler module of the anti-virus device from the internal memory so that at least one of the communication sessions is guaranteed to be processed to completion.

8. The method of claim 7, further comprising:

when available memory has not reached a predetermined amount remaining, processing the communication sessions in a first mode comprising processing the communication sessions in parallel; and

when available memory reaches a predetermined amount remaining, processing the communication sessions in a second mode comprising processing the communication sessions sequentially in accordance with a dependency list of communication sessions maintained by the resource scheduler module, wherein the dependency list specifies an order in which to process the communications sessions and specifies an amount of memory currently reserved for each of the communication sessions.

9. The method of claim 8, wherein processing the communication sessions in the second mode comprises dynamically initiating closing of communication windows for the communication sessions other than a first communication session on the dependency list.

10. The method of claim 8, further comprising:

when an amount of memory required to process a new communication session is less than or equal to the total amount of memory reserved for communication sessions already listed within the dependency list, reserving no additional memory for the new communication session.

11. The method of claim 10, wherein the amount of memory required to process the new communication session is determined based on protocol information associated with the new communication session.

12. A non-transitory computer-readable storage medium comprising instructions for causing a programmable processor to:

perform file-based anti-virus scanning on network traffic received via communication sessions using an internal memory of the anti-virus device; and

prevent the communication sessions from timing out by allocating memory from the internal memory so that at least one of the communication sessions is guaranteed to be processed to completion.