Uses of Class
org.jgroups.protocols.Executing.Owner
-
Packages that use Executing.Owner Package Description 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 Modifier and Type Field Description 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 resultsprotected 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 Modifier and Type Method Description 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)
-