org.jgroups.protocols
public class CENTRAL_EXECUTOR extends Executing
Executing.ExecutorHeader, Executing.Owner, Executing.Request, Executing.Type
Modifier and Type | Field and Description |
---|---|
protected java.util.List<Address> |
backups |
protected Address |
coord |
protected boolean |
is_coord |
protected int |
num_backups |
_awaitingConsumer, _awaitingReturn, _consumerLock, _consumersAvailable, _runnableThreads, _running, _runRequests, _tasks, bypass_bundling, counter, local_addr, notifiers, view
Constructor and Description |
---|
CENTRAL_EXECUTOR() |
Modifier and Type | Method and Description |
---|---|
protected void |
copyQueueTo(java.util.List<Address> new_joiners) |
java.lang.String |
getBackups() |
Address |
getCoord() |
java.lang.String |
getCoordinator() |
int |
getNumberOfBackups() |
void |
handleView(View view) |
boolean |
isCoord() |
protected void |
sendNewConsumerRequest(Address sender) |
protected void |
sendNewRunRequest(Address sender) |
protected void |
sendRemoveConsumerRequest(Address sender) |
protected void |
sendRemoveRunRequest(Address sender) |
protected void |
sendToCoordinator(Executing.Type type,
java.lang.Object value) |
void |
setNumberOfBackups(int num_backups) |
protected void |
updateBackups(Executing.Type type,
java.lang.Object obj) |
addExecutorListener, down, getAddress, getBypassBundling, getView, handleConsumerFoundResponse, handleConsumerReadyRequest, handleExceptionResponse, handleInterruptRequest, handleNewConsumer, handleNewRunRequest, handleRemoveConsumer, handleRemoveRunRequest, handleTaskRejectedResponse, handleTaskRequest, handleTaskSubmittedRequest, handleValueResponse, sendRequest, setBypassBundling, up
destroy, downThreadEnabled, dumpStats, enableStats, getConfigurableObjects, getDownProtocol, getId, getLevel, getName, getProperties, getProtocolStack, getSocketFactory, getThreadFactory, getTransport, getUpProtocol, getValue, init, isErgonomics, printStats, providedDownServices, providedUpServices, requiredDownServices, requiredUpServices, resetStats, setDownProtocol, setErgonomics, setId, setLevel, setProperties, setPropertiesInternal, setProperty, setProtocolStack, setSocketFactory, setUpProtocol, setValue, setValues, start, statsEnabled, stop, upThreadEnabled
protected int num_backups
protected Address coord
protected boolean is_coord
protected final java.util.List<Address> backups
public Address getCoord()
public boolean isCoord()
public java.lang.String getCoordinator()
public int getNumberOfBackups()
public void setNumberOfBackups(int num_backups)
public java.lang.String getBackups()
public void handleView(View view)
handleView
in class Executing
protected void updateBackups(Executing.Type type, java.lang.Object obj)
protected void copyQueueTo(java.util.List<Address> new_joiners)
protected void sendToCoordinator(Executing.Type type, java.lang.Object value)
sendToCoordinator
in class Executing
protected void sendNewRunRequest(Address sender)
sendNewRunRequest
in class Executing
protected void sendRemoveRunRequest(Address sender)
sendRemoveRunRequest
in class Executing
protected void sendNewConsumerRequest(Address sender)
sendNewConsumerRequest
in class Executing
protected void sendRemoveConsumerRequest(Address sender)
sendRemoveConsumerRequest
in class Executing
Copyright © 1998-2009 Bela Ban / Red Hat. All Rights Reserved.