|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
Packages that use Executing.Owner | |
---|---|
org.jgroups.protocols | Provides implementations of transport protocols which are responsible for sending and receiving messages to/from the network. |
Uses of Executing.Owner in org.jgroups.protocols |
---|
Fields in org.jgroups.protocols with type parameters of type Executing.Owner | |
---|---|
protected java.util.Map<Executing.Owner,java.lang.Runnable> |
Executing._awaitingReturn
This is a map on the client side that shows for which owner(consumer, request) the runnable they are currently using. |
protected java.util.Queue<Executing.Owner> |
Executing._consumersAvailable
This is stored on the coordinator side. |
protected java.util.Map<java.lang.Runnable,Executing.Owner> |
Executing._running
This is a map on the server side that shows which owner is currently tied to the runnable so we can return to them the results |
protected java.util.Queue<Executing.Owner> |
Executing._runRequests
This is stored on the coordinator side. |
Methods in org.jgroups.protocols with parameters of type Executing.Owner | |
---|---|
protected void |
Executing.handleNewConsumer(Executing.Owner sender)
|
protected void |
Executing.handleNewRunRequest(Executing.Owner sender)
|
protected void |
Executing.handleRemoveConsumer(Executing.Owner sender)
|
protected void |
Executing.handleRemoveRunRequest(Executing.Owner sender)
|
protected void |
CENTRAL_EXECUTOR.sendNewConsumerRequest(Executing.Owner sender)
|
protected abstract void |
Executing.sendNewConsumerRequest(Executing.Owner source)
|
protected void |
CENTRAL_EXECUTOR.sendNewRunRequest(Executing.Owner sender)
|
protected abstract void |
Executing.sendNewRunRequest(Executing.Owner source)
|
protected void |
CENTRAL_EXECUTOR.sendRemoveConsumerRequest(Executing.Owner sender)
|
protected abstract void |
Executing.sendRemoveConsumerRequest(Executing.Owner source)
|
protected void |
CENTRAL_EXECUTOR.sendRemoveRunRequest(Executing.Owner sender)
|
protected abstract void |
Executing.sendRemoveRunRequest(Executing.Owner source)
|
protected void |
CENTRAL_EXECUTOR.updateBackups(Executing.Type type,
Executing.Owner obj)
|
|
||||||||||
PREV NEXT | FRAMES NO FRAMES |