Method and system for network management with adaptive queue management

• US 20030009553A1
• Filed: 06/29/2001
• Published: 01/09/2003
• Est. Priority Date: 06/29/2001
• Status: Abandoned Application

• Current Assignee: International Business Machines Corporation
• Original Assignee: International Business Machines Corporation
• Inventors: Yarsa, Julianne, Benfield, Jason, Hsu, Oliver Yehung, Ullmann, Lorin Evan
• Application Number:
  US09/895,968
• Publication Number:
  US 20030009553A1
• Time in Patent Office: Days
• US Class Current: 709/224
• CPC Class Codes: H04L 41/0213 Standardised network management protocols, e.g. simple network management protocol [SNMP]
• CPC Class Codes: H04L 41/0233 Object-oriented techniques, for representation of network management data, e.g. common object request broker architecture [CORBA]
• CPC Class Codes: H04L 41/12 Discovery or management of network topologies
• CPC Class Codes: H04L 41/22 comprising specially adapted graphical user interfaces [GUI]
• CPC Class Codes: H04L 41/5003 Managing SLA; Interaction between SLA and QoS
• CPC Class Codes: H04L 41/5058 Service discovery by the service manager

Abstract

A method, system, apparatus, and computer program product is presented for management of a distributed data processing system. A management process discovers endpoints on a network within the distributed data processing system using a network management framework, and a state of the network is determined from a collective state of discovered endpoints. Data generated by the network management framework is queued while waiting to be persisted within a distributed database. An adaptive queue management scheme controls the data flow through a set of queues and adapts its management of those queues in accordance with the collective state of the network. Administrative users of the network management framework may set configuration parameters for the adaptive queue management mechanism.

Claims

1. A method for management of a distributed data processing system, the method comprising:

receiving status information from endpoints within the distributed data processing system;

determining a state of the distributed data processing system, wherein the state of the distributed data processing system depends upon a collective state of endpoints in the distributed data processing system; and

managing a set of one or more queues in accordance with the determined state of the distributed data processing system.

2. The method of claim 1 further comprising:

writing data to a queue, wherein the queue buffers the data prior to persisting the data to a database.

3. The method of claim 1 further comprising:

updating the determined state of the distributed data processing system based upon the received status information; and

modifying a configuration of the one or more queues based on the updated state of the distributed data processing system.

4. The method of claim 1 further comprising:

setting the state of the distributed data processing system based upon a numerical range of a discovery completion percentage for an endpoint discovery process within the distributed data processing system.

5. The method of claim 4 further comprising:

calculating a number of discovered endpoints for the distributed data processing system;

retrieving a maximum number of endpoints in the distributed data processing system; and

computing a discovery completion percentage based upon the number of discovered endpoints for the distributed data processing system and the maximum number of endpoints in the distributed data processing system.

6. The method of claim 1 further comprising:

performing one or more queue operations in accordance with the determined state of the distributed data processing system.

7. The method of claim 6 further comprising:

combining two or more queues.

8. The method of claim 6 further comprising:

splitting a queue.

9. The method of claim 6 further comprising:

flushing a queue.

10. The method of claim 6 further comprising:

adjusting a size of a queue.

11. The method of claim 6 further comprising:

changing a processing priority of a queue.

12. The method of claim 6 further comprising:

implementing one or more queue operations in accordance with one or more configuration parameters, wherein a configuration parameter is selected from the group consisting essentially of;

queue size;

queue type;

queue location;

or queue flush algorithm indication.

14. The apparatus of claim 13 further comprising:

means for writing data to a queue, wherein the queue buffers the data prior to persisting the data to a database.

15. The apparatus of claim 13 further comprising:

means for updating the determined state of the distributed data processing system based upon the received status information; and

means for modifying a configuration of the one or more queues based on the updated state of the distributed data processing system.

16. The apparatus of claim 13 further comprising:

means for setting the state of the distributed data processing system based upon a numerical range of a discovery completion percentage for an endpoint discovery process within the distributed data processing system.

17. The apparatus of claim 16 further comprising:

means for calculating a number of discovered endpoints for the distributed data processing system;

means for retrieving a maximum number of endpoints in the distributed data processing system; and

means for computing a discovery completion percentage based upon the number of discovered endpoints for the distributed data processing system and the maximum number of endpoints in the distributed data processing system.

18. The apparatus of claim 13 further comprising:

means for performing one or more queue operations in accordance with the determined state of the distributed data processing system.

19. The apparatus of claim 18 further comprising:

means for combining two or more queues.

20. The apparatus of claim 18 further comprising:

means for splitting a queue.

21. The apparatus of claim 18 further comprising:

means for flushing a queue.

22. The apparatus of claim 18 further comprising:

means for adjusting a size of a queue.

23. The apparatus of claim 18 further comprising:

means for changing a processing priority of a queue.

24. The apparatus of claim 18 further comprising:

means for implementing one or more queue operations in accordance with one or more configuration parameters, wherein a configuration parameter is selected from the group consisting essentially of;

queue size;

queue type;

queue location;

or queue flush algorithm indication.

26. The computer program product of claim 25 further comprising:

instructions for updating the determined state of the distributed data processing system based upon the received status information; and

instructions for modifying a configuration of the one or more queues based on the updated state of the distributed data processing system.

27. The computer program product of claim 25 further comprising:

instructions for setting the state of the distributed data processing system based upon a numerical range of a discovery completion percentage for an endpoint discovery process within the distributed data processing system.

28. The computer program product of claim 25 further comprising:

instructions for performing one or more queue operations in accordance with the determined state of the distributed data processing system, wherein a queue operation is selected from the group consisting essentially of;

combining two or more queues;

splitting a queue;

flushing a queue;

adjusting a size of a queue;

or changing a processing priority of a queue.

29. The computer program product of claim 25 further comprising:

instructions for implementing one or more queue operations in accordance with one or more configuration parameters, wherein a configuration parameter is selected from the group consisting essentially of;

queue size;

queue type;

queue location;

or queue flush algorithm indication.

13. An apparatus for management of a distributed data processing system, the apparatus comprising:

means for receiving status information from endpoints within the distributed data processing system;

means for determining a state of the distributed data processing system, wherein the state of the distributed data processing system depends upon a collective state of endpoints in the distributed data processing system; and

means for managing a set of one or more queues in accordance with the determined state of the distributed data processing system.

25. A computer program product on a computer readable medium for managing a distributed data processing system, the computer program product comprising:

instructions for receiving status information from endpoints within the distributed data processing system;

instructions for determining a state of the distributed data processing system, wherein the state of the distributed data processing system depends upon a collective state of endpoints in the distributed data processing system; and

instructions for managing a set of one or more queues in accordance with the determined state of the distributed data processing system.