| Package | Description |
|---|---|
| beehive.workpool |
| Modifier and Type | Field and Description |
|---|---|
java.util.concurrent.ConcurrentHashMap<java.lang.String,LoadInfo> |
LocalWorkpoolImpl.loadInfoTable |
java.util.Vector<LoadInfo> |
ValidateResponse.loadVector |
| Modifier and Type | Method and Description |
|---|---|
LoadInfo |
LocalWorkpoolServer.depositTasks(java.util.Vector<Task> t) |
LoadInfo |
LocalWorkpoolImpl.depositTasks(java.util.Vector<Task> taskList) |
LoadInfo |
LocalWorkpoolServer.getLoadInfo() |
LoadInfo |
LocalWorkpoolImpl.getLoadInfo() |
LoadInfo |
LocalWorkpoolServer.getTerminationStatus(int oldts,
int newts) |
LoadInfo |
LocalWorkpoolImpl.getTerminationStatus(int oldts,
int newts) |
| Modifier and Type | Method and Description |
|---|---|
java.util.Vector<LoadInfo> |
GlobalWorkpoolImpl.buildLoadInfo() |
| Modifier and Type | Method and Description |
|---|---|
void |
ValidationDispatcher.flushBatch(LoadInfo loadInfo) |
void |
GlobalWorkpoolImpl.updateLoadInfo(LoadInfo loadInfo) |
ValidateResponse |
GlobalWorkpoolImpl.validate(long startTS,
RWSetInfo rwSetInfo,
LoadInfo myLoadInfo) |
ValidateResponse |
ValidationService.validate(long startTS,
RWSetInfo rwSet,
LoadInfo myLoad) |
ValidateResponse |
LocalValidator.validate(java.lang.String tid,
long startTS,
RWSetInfo rwSet,
LoadInfo myLoadInfo) |
java.util.Hashtable<java.lang.String,ValidateResponse> |
GlobalWorkpoolImpl.validateBatch(java.util.Queue<ValidationRequest> requestBatch,
LoadInfo myLoad) |
java.util.Hashtable<java.lang.String,ValidateResponse> |
ValidationService.validateBatch(java.util.Queue<ValidationRequest> requestBatch,
LoadInfo myLoad) |
| Modifier and Type | Method and Description |
|---|---|
void |
LocalWorkpoolImpl.updateLoadInfo(java.util.Vector<LoadInfo> loadVector) |