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. _awaitingReturnThis 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. _consumersAvailableThis is stored on the coordinator side.protected java.util.Map<java.lang.Runnable,Executing.Owner>Executing. _runningThis 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. _runRequestsThis is stored on the coordinator side.Methods in org.jgroups.protocols with parameters of type Executing.Owner Modifier and Type Method Description protected voidExecuting. handleNewConsumer(Executing.Owner sender)protected voidExecuting. handleNewRunRequest(Executing.Owner sender)protected voidExecuting. handleRemoveConsumer(Executing.Owner sender)protected voidExecuting. handleRemoveRunRequest(Executing.Owner sender)protected voidCENTRAL_EXECUTOR. sendNewConsumerRequest(Executing.Owner sender)protected abstract voidExecuting. sendNewConsumerRequest(Executing.Owner source)protected voidCENTRAL_EXECUTOR. sendNewRunRequest(Executing.Owner sender)protected abstract voidExecuting. sendNewRunRequest(Executing.Owner source)protected voidCENTRAL_EXECUTOR. sendRemoveConsumerRequest(Executing.Owner sender)protected abstract voidExecuting. sendRemoveConsumerRequest(Executing.Owner source)protected voidCENTRAL_EXECUTOR. sendRemoveRunRequest(Executing.Owner sender)protected abstract voidExecuting. sendRemoveRunRequest(Executing.Owner source)protected voidCENTRAL_EXECUTOR. updateBackups(Executing.Type type, Executing.Owner obj)
-