Distributing messages between local queues representative of a common shared queue
First Claim
Patent Images
1. A method of managing common shared queues of a communications environment, said method comprising:
- providing a plurality of shared queues representative of a common shared queue, said plurality of shared queues being coupled to a plurality of processors; and
moving one or more messages from one shared queue of the plurality of shared queues to one or more other shared queues of the plurality of shared queues, in response to a detected condition.
1 Assignment
0 Petitions
Accused Products
Abstract
A common shared queue is provided, which includes a plurality of local queues. Each local queue is resident on a storage medium coupled to a processor. The local queues are monitored, and when it is determined that a particular local queue is being inadequately serviced, then one or more messages are moved from that local queue to one or more other local queues of the common shared queue.
59 Citations
60 Claims
-
1. A method of managing common shared queues of a communications environment, said method comprising:
-
providing a plurality of shared queues representative of a common shared queue, said plurality of shared queues being coupled to a plurality of processors; and
moving one or more messages from one shared queue of the plurality of shared queues to one or more other shared queues of the plurality of shared queues, in response to a detected condition. - View Dependent Claims (2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12, 13)
-
-
14. A method of managing common shared queues of a communications environment, said method comprising:
-
providing a plurality of shared queues representative of a common shared queue, each shared queue of said plurality of shared queues being local to a processor of the communications environment;
monitoring, by at least one processor of the communications environment, queue depth of one or more shared queues of the plurality of shared queues;
determining, via the monitoring, that the queue depth of a shared queue of the one or more shared queues is at a defined level; and
moving one or more messages from the shared queue to one or more other shared queues of the plurality of shared queues, in response to the determining. - View Dependent Claims (15, 16, 17, 18)
-
-
19. A method of providing a common shared queue, said method comprising:
-
providing a plurality of shared queues representative of a common shared queue, said plurality of shared queues being coupled to a plurality of processors; and
accessing, by a distributed application executing across the plurality of processors, the plurality of shared queues to process data used by the distributed application.
-
-
20. A system of managing common shared queues of a communications environment, said system comprising:
-
a plurality of shared queues representative of a common shared queue, said plurality of shared queues being coupled to a plurality of processors; and
means for moving one or more messages from one shared queue of the plurality of shared queues to one or more other shared queues of the plurality of shared queues, in response to a detected condition. - View Dependent Claims (21, 22, 23, 24, 25, 26, 27, 28, 29, 30, 31, 32)
-
-
33. A system of managing common shared queues of a communications environment, said system comprising:
-
a plurality of shared queues representative of a common shared queue, each shared queue of said plurality of shared queues being local to a processor of the communications environment;
means for monitoring, by at least one processor of the communications environment, queue depth of one or more shared queues of the plurality of shared queues;
means for determining that the queue depth of a shared queue of the one or more shared queues is at a defined level; and
means for moving one or more messages from the shared queue to one or more other shared queues of the plurality of shared queues, in response to the determining. - View Dependent Claims (34, 35, 36, 37)
-
-
38. A system of providing a common shared queue, said system comprising:
-
a plurality of shared queues representative of a common shared queue, said plurality of shared queues being coupled to a plurality of processors; and
means for accessing, by a distributed application executing across the plurality of processors, the plurality of shared queues to process data used by the distributed application.
-
-
39. A system of managing common shared queues of a communications environment, said system comprising:
-
a plurality of shared queues representative of a common shared queue, said plurality of shared queues being coupled to a plurality of processors; and
at least one processor adapted to move one or more messages from one shared queue of the plurality of shared queues to one or more other shared queues of the plurality of shared queues, in response to a detected condition.
-
-
40. A system of managing common shared queues of a communications environment, said system comprising:
-
a plurality of shared queues representative of a common shared queue, each shared queue of said plurality of shared queues being local to a processor of the communications environment;
at least one processor of the communications environment adapted to monitor queue depth of one or more shared queues of the plurality of shared queues;
at least one processor adapted to determine that the queue depth of a shared queue of the one or more shared queues is at a defined level; and
at least one processor adapted to move one or more messages from the shared queue to one or more other shared queues of the plurality of shared queues, in response to the determining.
-
-
41. A system of providing a common shared queue, said system comprising:
-
a plurality of shared queues representative of a common shared queue, said plurality of shared queues being coupled to a plurality of processors; and
a distributed application executing across the plurality of processors accessing the plurality of shared queues to process data used by the distributed application.
-
-
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 common shared queues of a communications environment, said method comprising:
-
providing a plurality of shared queues representative of a common shared queue, said plurality of shared queues being coupled to a plurality of processors; and
moving one or more messages from one shared queue of the plurality of shared queues to one or more other shared queues of the plurality of shared queues, in response to a detected condition. - View Dependent Claims (43, 44, 45, 46, 47, 48, 49, 50, 51, 52, 53, 54)
-
-
55. 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 common shared queues of a communications environment, said method comprising:
-
providing a plurality of shared queues representative of a common shared queue, each shared queue of said plurality of shared queues being local to a processor of the communications environment;
monitoring, by at least one processor of the communications environment, queue depth of one or more shared queues of the plurality of shared queues;
determining, via the monitoring, that the queue depth of a shared queue of the one or more shared queues is at a defined level; and
moving one or more messages from the shared queue to one or more other shared queues of the plurality of shared queues, in response to the determining. - View Dependent Claims (56, 57, 58, 59)
-
-
60. 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 providing a common shared queue, said method comprising:
-
providing a plurality of shared queues representative of a common shared queue, said plurality of shared queues being coupled to a plurality of processors; and
accessing, by a distributed application executing across the plurality of processors, the plurality of shared queues to process data used by the distributed application.
-
Specification