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 and 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 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

Modifier and Type	Method and 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)