LOCAL MESSAGE QUEUE PROCESSING FOR CO-LOCATED WORKERS
First Claim
Patent Images
1. A method to locally process queue requests from co-located workers in a datacenter, the method comprising:
- detecting a producer worker at a first server sending a first message to a datacenter queue at least partially stored at a second server;
storing the first message in a queue cache at the first server, wherein the queue cache includes one of a copy and a partial copy of the datacenter queue;
detecting a consumer worker at the first server sending a message request to the datacenter queue;
providing the stored first message to the consumer worker in response to the message request;
receiving a signal from a command channel associated with the datacenter queue; and
modifying the stored first message in response to receiving the signal.
5 Assignments
0 Petitions
Accused Products
Abstract
Technologies are provided for locally processing queue requests from co-located workers. In some examples, information about the usage of remote datacenter queues by co-located workers may be used to determine one or more matched queues. Messages from local workers to a remote datacenter queue classified as a matched queue may be stored locally. Subsequently, local workers that request messages from matched queues may be provided with the locally-stored messages.
20 Citations
37 Claims
-
1. A method to locally process queue requests from co-located workers in a datacenter, the method comprising:
-
detecting a producer worker at a first server sending a first message to a datacenter queue at least partially stored at a second server; storing the first message in a queue cache at the first server, wherein the queue cache includes one of a copy and a partial copy of the datacenter queue; detecting a consumer worker at the first server sending a message request to the datacenter queue; providing the stored first message to the consumer worker in response to the message request; receiving a signal from a command channel associated with the datacenter queue; and modifying the stored first message in response to receiving the signal. - View Dependent Claims (2, 7, 8, 10, 11, 12)
-
-
3-6. -6. (canceled)
-
9. (canceled)
-
13. A virtual machine manager (VMM) to locally process queue requests from co-located workers in a datacenter, the VMM comprising:
-
a queue usage detector module configured to; detect a producer worker at a first server, wherein the producer worker sends a first message to a datacenter queue at least partially stored at a second server; and detect a consumer worker at the first server, wherein the consumer worker sends a message request to the datacenter queue, and wherein the producer worker and the consumer worker are co-located on a multi-core device at the first server; and a processing module configured to; intercept the first message sent by the producer worker; store the first message at the first server; provide the stored first message to the consumer worker in response to the message request; receive a signal from a command channel associated with the datacenter queue; and modify the stored first message in response to receiving the signal. - View Dependent Claims (17, 18, 20, 23, 24)
-
-
14-16. -16. (canceled)
-
19. (canceled)
-
21. (canceled)
-
22. (canceled)
-
25. A cloud-based datacenter configured to locally process queue requests from co-located workers in the datacenter, the datacenter comprising:
-
a first and a second virtual machine (VM) operable to be executed on one or more physical machines; and a datacenter controller configured to; detect a producer worker that is executed on a first VM and sends a first message to a datacenter queue at least partially stored at a first datacenter location; intercept the first message sent by the producer worker before storing the first message; store the first message in a queue cache at a second datacenter location different from the first; detect a consumer worker that is executed on a second VM and sends a message request to the datacenter queue; provide the stored first message to the consumer worker in response to the message request, wherein the first message is stored and provided from within a server to the producer worker and the consumer worker; receive a signal from a command channel associated with the datacenter queue; and modify the stored first message in response to receiving the signal. - View Dependent Claims (26, 28, 29, 30, 31, 32, 34, 35, 36)
-
-
27. (canceled)
-
33. (canceled)
-
37. (canceled)
Specification