Managing memory resident queues to control resources of the systems using the queues

• US 7,068,604 B2
• Filed: 08/23/2001
• Issued: 06/27/2006
• Est. Priority Date: 08/23/2001
• Status: Expired due to Fees

• Current Assignee: International Business Machines Corporation
• Original Assignee: International Business Machines Corporation
• Inventors: Dryfoos, Robert O., Wang, Mei-Hui, Chen, Shawfu, Lewis, Peter A., Keenaghan, Jason A., Sutton, Peter G., Feldman, Allan, Hu, David Y., Williams-Obleton, Alice M.
• Primary Examiner(s): TON, DANG T
• Application Number:
  US09/938,031
• Publication Number:
  US 20030041115A1
• Time in Patent Office: 1,769 Days
• Field of Search: 370/428, 370/411, 370/412, 370413-419, 370229-231, 370/389, 370/401, 714/15
• US Class Current: 370/235
• CPC Class Codes: H04L 67/12 specially adapted for proprietary or special-purpose networking environments, e.g. medical networks, sensor networks, networks in vehicles or remote metering networks
• CPC Class Codes: H04L 69/329 in the application layer [OSI layer 7]

Abstract

Memory resident queues are monitored at predefined time intervals. When the monitoring indicates that a particular queue is not being serviced at a desired level, then action is taken to sweep one or more messages from the queue. The sweeping of the messages frees up system resources associated with the messages, thus allowing other tasks to be serviced. If, after the sweeping, it is determined that the queue can handle additional messages, then one or more messages are placed back on the queue.

Claims

1. A method of managing memory resident queues, said method comprising:

determining whether a memory resident queue is being serviced at a desired level;

removing one or more messages from the memory resident queue to storage in response to a determination that the memory resident queue is not being serviced at the desired level; and

returning at least one message of the one or more removed messages to the memory resident queue;

wherein the at least one message comprises a set of one or more messages associated with a selected swept identifier.

2. The method of claim 1, wherein the removing of the one or more messages causes one or more resources associated with the memory resident queue to be freed.

3. The method of claim 1, wherein said returning is performed in response to a determination that the memory resident queue can accept additional messages.

4. The method of claim 1, wherein the desired level takes into consideration a fullness level of the memory resident queue.

16. The method of claim 1, wherein said determining is performed at one or more time intervals.

5. A method of managing memory resident queues, said method comprising:

determining whether a memory resident queue is being serviced at a desired level, wherein the determining comprises;

determining whether a size of at least one component of the memory resident queue satisfies a first criterion; and

determining whether a specified portion of messages of a defined type satisfies a second criterion, wherein the memory resident queue is not being serviced at the desired level when the first and second criterion are satisfied; and

removing one or more messages from the memory resident queue in response to a determination that the memory resident queue is not being serviced at the desired level.

6. The method of claim 5, wherein the at least one component comprises at least one of a head of the memory resident queue and a tail of the memory resident queue.

7. The method of claim 6, wherein the first criterion comprises being greater than a defined limit of the memory resident queue.

8. The method of claim 5, wherein the specified portion of messages of the defined type comprises one half of a number of get messages.

9. The method of claim 8, wherein the second criterion comprises being less than at least one of a size of a head of the memory resident queue and a size of a tail of the memory resident queue.

10. A method of managing memory resident queues, said method comprising:

determining whether a memory resident queue is being serviced at a desired level; and

removing one or more messages from the memory resident queue to storage in response to a determination that the memory resident queue is not being serviced at the desired level, wherein the removing comprises;

allocating storage for the one or more messages to be removed; and

copying the one or more messages from the memory resident queue to the allocated storage.

11. The method of claim 10, further comprising:

identifying the one or more messages being copied with an identifier; and

chaining the identifier to a swept list of the memory resident queue.

12. The method of claim 10, wherein the removing further comprises writing the one or more messages from the allocated storage to at least one storage medium.

13. The method of claim 10, wherein an amount of storage to be allocated is based, at least in part, from where in the memory resident queue the one or more messages are to be removed.

14. The method of claim 13, wherein the one or more messages are to be removed from a tail of the memory resident queue, and wherein the allocating comprises allocating storage for a total number of messages minus a defined number in the tail of the memory resident queue.

15. The method of claim 13, wherein the one or more messages are to be removed from a head of the memory resident queue, and wherein the allocating comprises allocating storage for half a number of get messages being serviced or for a total number of messages minus a defined number in the head of the memory resident queue.

17. A system of managing memory resident queues, said system comprising:

means for determining whether a memory resident queue is being serviced at a desired level;

means for removing one or more messages from the memory resident queue to storage in response to a determination that the memory resident queue is not being serviced at the desired level; and

means for returning at least one message of the one or more removed messages to the memory resident queue;

wherein the at least one message comprises a set of one or more messages associated with a selected swept identifier.

18. The system of claim 17, wherein the removing of the one or more messages causes one or more resources associated with the memory resident queue to be freed.

19. The system of claim 17, wherein the returning is performed in response to a determination that the memory resident queue can accept additional messages.

20. The system of claim 17, wherein the desired level takes into consideration a fullness level of the memory resident queue.

32. The system of claim 17, wherein said means for determining comprises performing the determining at one or more time intervals.

21. A system of managing memory resident queues, said system comprising:

means for determining whether a memory resident queue is being serviced at a desired level, wherein the means for determining comprises;

means for determining whether a size of at least one component of the memory resident queue satisfies a first criterion; and

means for determining whether a specified portion of messages of a defined type satisfies a second criterion, wherein the memory resident queue is not being serviced at the desired level when the first and second criterion are satisfied; and

means for removing one or more messages from the memory resident queue in response to a determination tat the memory resident queue is not being serviced at the desired level.

22. The system of claim 21, wherein the at least one component comprises at least one of a head of the memory resident queue and a tail of the memory resident queue.

23. The system of claim 22, wherein the first criterion comprises being greater than a defined limit of the memory resident queue.

24. The system of claim 21, wherein the specified portion of messages of the defined type comprises one half of a number of get messages.

25. The system of claim 24, wherein the second criterion comprises being less than at least one of a size of a head of the memory resident queue and a size of a tail of the memory resident queue.

26. A system of managing memory resident queues, said system comprising:

means for determining whether a memory resident queue is being serviced at a desired level; and

means for removing one or more messages from the memory resident queue to storage in response to a determination that the memory resident queue is not being serviced at the desired level, wherein the means for removing comprises;

means for allocating storage for the one or more messages to be removed; and

means for copying the one or more messages from the memory resident queue to the allocated storage.

27. The system of claim 26, further comprising:

means for identifying the one or more messages being copied with an identifier; and

means for chaining the identifier to a swept list of the memory resident queue.

28. The system of claim 26, wherein the means for removing further comprises means for writing the one or more messages from the allocated storage to at least one storage medium.

29. The system of claim 26, wherein an amount of storage to be allocated is based, at least in part, from where in the memory resident queue the one or more messages are to be removed.

30. The system of claim 29, wherein the one or more messages are to be removed from a tail of the memory resident queue, and wherein the means for allocating comprises means for allocating storage for a total number of messages minus a defined number in the tail of the memory resident queue.

31. The system of claim 29, wherein the one or more messages are to be removed from a head of the memory resident queue, and wherein the means for allocating comprises means for allocating storage for half a number of get messages being serviced or for a total number of messages minus a defined number in the head of the memory resident queue.

33. At least one program storage device readable by a machine, tangibly embodying at least one program of instructions executable by the machine to perform a method of managing memory resident queues, said method comprising:

determining whether a memory resident queue is being serviced at a desired level;

removing one or more messages from the memory resident queue to storage in response to a determination that the memory resident queue is not being serviced at the desired level; and

returning at least one message of the one or more removed messages to the memory resident queue;

wherein the at least one message comprises a set of one or more messages associated with a selected swept identifier.

34. The at least one program storage device of claim 33, wherein the removing of the one or more messages causes one or more resources associated with the memory resident queue to be freed.

35. The at least one program storage device of claim 33 wherein said returning is performed in response to a determination that the memory resident queue can accept additional messages.

36. The at least one program storage device of claim 33, wherein the desired level takes into consideration a fullness level of the memory resident queue.

48. The at least one program storage device of claim 33, wherein said determining is performed at one or more time intervals.

37. At least one program storage device readable by a machine, tangibly embodying at least one program of instructions executable by the machine to perform a method of managing memory resident queues, said method comprising:

determining whether a memory resident queue is being serviced at a desired level, the determining comprising;

determining whether a size of at least one component of the memory resident queue satisfies a first criterion; and

determining whether a specified portion of messages of a defined type satisfies a second criterion, wherein the memory resident queue is not being serviced at the desired level when the first and second criterion are satisfied; and

removing one or more messages from the memory resident queue in response to a determination that the memory resident queue is not being serviced at the desired level.

38. The at least one program storage device of claim 37, wherein the at least one component comprises at least one of a head of the memory resident queue and a tail of the memory resident queue.

39. The at least one program storage device of claim 38, wherein the first criterion comprises being greater than a defined limit of the memory resident queue.

40. The at least one program storage device of claim 37, wherein the specified portion of messages of the defined type comprises one half of a number of get messages.

41. The at least one program storage device of claim 40, wherein the second criterion comprises being less than at least one of a size of a head of the memory resident queue and a size of a tail of the memory resident queue.

42. At least one program storage device readable by a machine, tangibly embodying at least one program of instructions executable by the machine to perform a method of managing memory resident queues, said method comprising:

determining whether a memory resident queue is being serviced at a desired level; and

removing one or more messages from the memory resident queue to storage in response to a determination that the memory resident queue is not being serviced at the desired level, wherein the removing comprises;

allocating storage for the one or more messages to be removed; and

copying the one or more messages from the memory resident queue to the allocated storage.

43. The at least one program storage device of claim 42, wherein said method further comprises:

identifying the one or more messages being copied with an identifier; and

chaining the identifier to a swept list of the memory resident queue.

44. The at least one program storage device of claim 42, wherein the removing further comprises writing the one or more messages from the allocated storage of at least one storage medium.

45. The at least one program storage device of claim 42, wherein an amount of storage to be allocated is based, at least in part, from where in the memory resident queue the one or more messages are to be removed.

46. The at least one program storage device of claim 45, wherein the one or more messages are to be removed from a tail of the memory resident queue, and wherein the allocating comprises allocating storage for a total number of messages minus a defined number in the tail of the memory resident queue.

47. The at least one program storage device of claim 45, wherein the one or more messages are to be removed from a head of the memory resident queue, and wherein the allocating comprises allocating storage for half a number of get messages being serviced or for a total number of messages minus a defined number in the head of the memory resident queue.