Modifier and Type | Method and Description |
---|---|
WorkerExecutionContext |
Context.getParentWorkerExecutionContext() |
WorkerExecutionContext |
NativeCallContext.getParentWorkerExecutionContext() |
Constructor and Description |
---|
BLangCallableUnitCallback(Context nativeCallCtx,
WorkerExecutionContext parentCtx,
int[] retRegs,
BType[] retTypes) |
NativeCallContext(WorkerExecutionContext parentCtx,
CallableUnitInfo callableUnitInfo,
WorkerData workerLocal) |
Modifier and Type | Field and Description |
---|---|
WorkerExecutionContext |
CPU.HandleErrorException.ctx |
WorkerExecutionContext |
WorkerExecutionContext.parent |
protected WorkerExecutionContext |
BaseWorkerResponseContext.targetCtx |
Modifier and Type | Method and Description |
---|---|
static WorkerExecutionContext |
BLangScheduler.errorThrown(WorkerExecutionContext ctx,
BMap<String,BValue> error) |
WorkerExecutionContext |
WorkerSignal.getSourceContext() |
WorkerExecutionContext |
InitWorkerResponseContext.joinTargetContextInfo(WorkerExecutionContext targetCtx,
int[] retRegIndexes) |
WorkerExecutionContext |
BaseWorkerResponseContext.joinTargetContextInfo(WorkerExecutionContext targetCtx,
int[] retRegIndexes) |
WorkerExecutionContext |
WorkerResponseContext.joinTargetContextInfo(WorkerExecutionContext targetCtx,
int[] retRegIndexes)
Joins a new target worker execution context to the current response
context.
|
WorkerExecutionContext |
AsyncInvocableWorkerResponseContext.joinTargetContextInfo(WorkerExecutionContext targetCtx,
int[] retRegIndexes) |
protected WorkerExecutionContext |
ForkJoinWorkerResponseContext.onError(WorkerSignal signal) |
protected WorkerExecutionContext |
CallableWorkerResponseContext.onError(WorkerSignal signal) |
protected WorkerExecutionContext |
BaseWorkerResponseContext.onError(WorkerSignal signal) |
protected WorkerExecutionContext |
SyncCallableWorkerResponseContext.onError(WorkerSignal signal) |
protected WorkerExecutionContext |
CallableWorkerResponseContext.onFinalizedError(WorkerExecutionContext targetCtx,
BMap<String,BValue> error) |
WorkerExecutionContext |
CallableWorkerResponseContext.onFulfillment(boolean runInCaller) |
WorkerExecutionContext |
AsyncInvocableWorkerResponseContext.onFulfillment(boolean runInCaller) |
protected WorkerExecutionContext |
ForkJoinWorkerResponseContext.onHalt(WorkerSignal signal) |
protected WorkerExecutionContext |
CallableWorkerResponseContext.onHalt(WorkerSignal signal) |
protected WorkerExecutionContext |
BaseWorkerResponseContext.onHalt(WorkerSignal signal) |
protected WorkerExecutionContext |
SyncCallableWorkerResponseContext.onHalt(WorkerSignal signal) |
protected WorkerExecutionContext |
ForkJoinWorkerResponseContext.onHaltFinalized() |
protected WorkerExecutionContext |
ForkJoinWorkerResponseContext.onReturn(WorkerSignal signal) |
protected WorkerExecutionContext |
CallableWorkerResponseContext.onReturn(WorkerSignal signal) |
protected WorkerExecutionContext |
BaseWorkerResponseContext.onReturn(WorkerSignal signal) |
protected WorkerExecutionContext |
SyncCallableWorkerResponseContext.onReturn(WorkerSignal signal) |
protected WorkerExecutionContext |
ForkJoinWorkerResponseContext.onTimeout(WorkerSignal signal) |
protected WorkerExecutionContext |
BaseWorkerResponseContext.onTimeout(WorkerSignal signal) |
protected WorkerExecutionContext |
CallableWorkerResponseContext.propagateErrorToTarget() |
protected WorkerExecutionContext |
AsyncInvocableWorkerResponseContext.propagateErrorToTarget() |
static WorkerExecutionContext |
BLangScheduler.resume(WorkerExecutionContext ctx) |
static WorkerExecutionContext |
BLangScheduler.resume(WorkerExecutionContext ctx,
boolean runInCaller) |
static WorkerExecutionContext |
BLangScheduler.resume(WorkerExecutionContext ctx,
int targetIp,
boolean runInCaller) |
static WorkerExecutionContext |
BLangScheduler.schedule(WorkerExecutionContext ctx) |
static WorkerExecutionContext |
BLangScheduler.schedule(WorkerExecutionContext ctx,
boolean runInCaller) |
WorkerExecutionContext |
InitWorkerResponseContext.signal(WorkerSignal signal) |
WorkerExecutionContext |
BaseWorkerResponseContext.signal(WorkerSignal signal) |
WorkerExecutionContext |
WorkerResponseContext.signal(WorkerSignal signal)
This is called by the workers to signal the response context of any
signal that needs to be passed into.
|
WorkerExecutionContext |
AsyncInvocableWorkerResponseContext.signal(WorkerSignal signal) |
Modifier and Type | Method and Description |
---|---|
static void |
BLangVMErrors.attachStackFrame(BMap<String,BValue> error,
WorkerExecutionContext context) |
static void |
CPU.copyValues(WorkerExecutionContext ctx,
WorkerData parent,
WorkerData workerSF) |
static BMap<String,BValue> |
BLangVMErrors.createCallCancelledException(WorkerExecutionContext context) |
static BMap<String,BValue> |
BLangVMErrors.createCallFailedException(WorkerExecutionContext context,
Map<String,BMap<String,BValue>> errors) |
static BMap<String,BValue> |
BLangVMErrors.createError(WorkerExecutionContext context,
String message) |
static BMap<String,BValue> |
BLangVMErrors.createNullRefException(WorkerExecutionContext context) |
static BMap<String,BValue> |
BLangVMErrors.createTypeCastError(WorkerExecutionContext context,
String sourceType,
String targetType) |
static BMap<String,BValue> |
BLangVMErrors.createTypeConversionError(WorkerExecutionContext context,
String errorMessage) |
static void |
BLangScheduler.dumpCallStack(WorkerExecutionContext ctx) |
static WorkerExecutionContext |
BLangScheduler.errorThrown(WorkerExecutionContext ctx,
BMap<String,BValue> error) |
static void |
CPU.exec(WorkerExecutionContext ctx) |
static void |
BLangScheduler.executeNow(WorkerExecutionContext ctx)
This method executes a scheduled worker execution context which is in
CREATED state, which means, it is not yet ready for executing.
|
static BRefValueArray |
BLangVMErrors.generateCallStack(WorkerExecutionContext context,
CallableUnitInfo nativeCUI) |
static BMap<String,BValue> |
BLangVMErrors.getStackFrame(WorkerExecutionContext context) |
static void |
CPU.handleError(WorkerExecutionContext ctx) |
WorkerExecutionContext |
InitWorkerResponseContext.joinTargetContextInfo(WorkerExecutionContext targetCtx,
int[] retRegIndexes) |
WorkerExecutionContext |
BaseWorkerResponseContext.joinTargetContextInfo(WorkerExecutionContext targetCtx,
int[] retRegIndexes) |
WorkerExecutionContext |
WorkerResponseContext.joinTargetContextInfo(WorkerExecutionContext targetCtx,
int[] retRegIndexes)
Joins a new target worker execution context to the current response
context.
|
WorkerExecutionContext |
AsyncInvocableWorkerResponseContext.joinTargetContextInfo(WorkerExecutionContext targetCtx,
int[] retRegIndexes) |
boolean |
VarLock.lock(WorkerExecutionContext ctx) |
boolean |
GlobalMemoryBlock.lockBooleanField(WorkerExecutionContext ctx,
int index) |
boolean |
GlobalMemoryArea.lockBooleanField(WorkerExecutionContext ctx,
int pkgIndex,
int varIndex) |
boolean |
GlobalMemoryBlock.lockFloatField(WorkerExecutionContext ctx,
int index) |
boolean |
GlobalMemoryArea.lockFloatField(WorkerExecutionContext ctx,
int pkgIndex,
int varIndex) |
boolean |
GlobalMemoryBlock.lockIntField(WorkerExecutionContext ctx,
int index) |
boolean |
GlobalMemoryArea.lockIntField(WorkerExecutionContext ctx,
int pkgIndex,
int varIndex) |
boolean |
GlobalMemoryBlock.lockRefField(WorkerExecutionContext ctx,
int index) |
boolean |
GlobalMemoryArea.lockRefField(WorkerExecutionContext ctx,
int pkgIndex,
int varIndex) |
boolean |
GlobalMemoryBlock.lockStringField(WorkerExecutionContext ctx,
int index) |
boolean |
GlobalMemoryArea.lockStringField(WorkerExecutionContext ctx,
int pkgIndex,
int varIndex) |
protected void |
BaseWorkerResponseContext.modifyDebugCommands(WorkerExecutionContext parent,
WorkerExecutionContext child) |
protected WorkerExecutionContext |
CallableWorkerResponseContext.onFinalizedError(WorkerExecutionContext targetCtx,
BMap<String,BValue> error) |
static WorkerExecutionContext |
BLangScheduler.resume(WorkerExecutionContext ctx) |
static WorkerExecutionContext |
BLangScheduler.resume(WorkerExecutionContext ctx,
boolean runInCaller) |
static WorkerExecutionContext |
BLangScheduler.resume(WorkerExecutionContext ctx,
int targetIp,
boolean runInCaller) |
static WorkerExecutionContext |
BLangScheduler.schedule(WorkerExecutionContext ctx) |
static WorkerExecutionContext |
BLangScheduler.schedule(WorkerExecutionContext ctx,
boolean runInCaller) |
void |
BLangScheduler.SchedulerStats.stateTransition(WorkerExecutionContext currentCtx,
WorkerState newState) |
static void |
BLangScheduler.stopWorker(WorkerExecutionContext ctx) |
protected void |
CallableWorkerResponseContext.storeError(WorkerExecutionContext sourceCtx,
BMap<String,BValue> error) |
WorkerDataChannel.WorkerResult |
WorkerDataChannel.tryTakeData(WorkerExecutionContext ctx) |
static void |
BLangScheduler.workerDone(WorkerExecutionContext ctx) |
static void |
BLangScheduler.workerExcepted(WorkerExecutionContext ctx) |
static void |
BLangScheduler.workerPaused(WorkerExecutionContext ctx) |
static void |
BLangScheduler.workerReady(WorkerExecutionContext ctx) |
static void |
BLangScheduler.workerRunning(WorkerExecutionContext ctx) |
static void |
BLangScheduler.workerWaitForLock(WorkerExecutionContext ctx) |
static void |
BLangScheduler.workerWaitForResponse(WorkerExecutionContext ctx) |
Modifier and Type | Method and Description |
---|---|
void |
AsyncInvocableWorkerResponseContext.setWorkerExecutionContexts(List<WorkerExecutionContext> workerExecutionContexts) |
Constructor and Description |
---|
ForkJoinWorkerResponseContext(WorkerExecutionContext targetCtx,
int joinTargetIp,
int joinVarReg,
int timeoutTargetIp,
int timeoutVarReg,
int workerCount,
int reqJoinCount,
Set<String> joinWorkerNames,
Map<String,String> channelNames) |
HandleErrorException(WorkerExecutionContext ctx) |
InitWorkerResponseContext(WorkerExecutionContext targetCtx) |
WorkerExecutionContext(WorkerExecutionContext parent,
WorkerResponseContext respCtx,
CallableUnitInfo callableUnitInfo,
WorkerInfo workerInfo,
WorkerData workerLocal,
boolean runInCaller) |
WorkerExecutionContext(WorkerExecutionContext parent,
WorkerResponseContext respCtx,
CallableUnitInfo callableUnitInfo,
WorkerInfo workerInfo,
WorkerData workerLocal,
WorkerData workerResult,
int[] retRegIndexes,
boolean runInCaller) |
WorkerSignal(WorkerExecutionContext sourceContext,
SignalType type,
WorkerData result) |
Modifier and Type | Method and Description |
---|---|
static void |
Executor.submit(Resource resource,
CallableUnitCallback responseCallback,
Map<String,Object> properties,
ObserverContext observerContext,
WorkerExecutionContext context,
BValue... values)
This method will execute Ballerina resource in non-blocking manner.
|
Modifier and Type | Method and Description |
---|---|
static void |
ResourceExecutor.execute(Resource resource,
CallableUnitCallback responseCallback,
Map<String,Object> properties,
ObserverContext observerContext,
WorkerExecutionContext context,
BValue... bValues)
This method will execute the resource, given required details.
|
Modifier and Type | Method and Description |
---|---|
boolean |
LockableStructureType.lockBooleanField(WorkerExecutionContext ctx,
int index) |
boolean |
LockableStructureType.lockFloatField(WorkerExecutionContext ctx,
int index) |
boolean |
LockableStructureType.lockIntField(WorkerExecutionContext ctx,
int index) |
boolean |
LockableStructureType.lockRefField(WorkerExecutionContext ctx,
int index) |
boolean |
LockableStructureType.lockStringField(WorkerExecutionContext ctx,
int index) |
Modifier and Type | Method and Description |
---|---|
WorkerExecutionContext |
VMDebugClientHandler.getWorkerContext(String workerId) |
WorkerExecutionContext |
DebugClientHandler.getWorkerContext(String workerId)
Method to get worker context given the workerId.
|
Modifier and Type | Method and Description |
---|---|
Map<String,WorkerExecutionContext> |
VMDebugClientHandler.getAllWorkerContexts() |
Map<String,WorkerExecutionContext> |
DebugClientHandler.getAllWorkerContexts()
Method to get all worker contexts.
|
Modifier and Type | Method and Description |
---|---|
void |
VMDebugClientHandler.addWorkerContext(WorkerExecutionContext ctx) |
void |
Debugger.addWorkerContext(WorkerExecutionContext ctx)
Add
WorkerExecutionContext to current execution. |
void |
DebugClientHandler.addWorkerContext(WorkerExecutionContext ctx)
Called when adding a context.
|
void |
Debugger.notifyDebugHit(WorkerExecutionContext ctx,
LineNumberInfo currentExecLine,
String workerId)
Send a message to the debug client when a breakpoint is hit.
|
void |
Debugger.pauseWorker(WorkerExecutionContext ctx)
Helper method to stop execution of current worker.
|
Modifier and Type | Method and Description |
---|---|
static WorkerExecutionContext |
BLangVMUtils.handleNativeInvocationError(WorkerExecutionContext parentCtx,
BMap<String,BValue> error) |
static WorkerExecutionContext |
BLangFunctions.invokeCallable(CallableUnitInfo callableUnitInfo,
WorkerExecutionContext parentCtx,
int[] argRegs,
int[] retRegs,
boolean waitForResponse) |
static WorkerExecutionContext |
BLangFunctions.invokeCallable(CallableUnitInfo callableUnitInfo,
WorkerExecutionContext parentCtx,
int[] argRegs,
int[] retRegs,
boolean waitForResponse,
int flags) |
static WorkerExecutionContext |
BLangFunctions.invokeForkJoin(WorkerExecutionContext parentCtx,
ForkjoinInfo forkjoinInfo,
int joinTargetIp,
int joinVarReg,
int timeoutRegIndex,
int timeoutTargetIp,
int timeoutVarReg) |
Modifier and Type | Method and Description |
---|---|
static WorkerData |
BLangVMUtils.createWorkerDataForLocal(WorkerInfo workerInfo,
WorkerExecutionContext parentCtx,
int[] argRegs,
BType[] paramTypes) |
static boolean |
BLangVMUtils.getGlobalTransactionenabled(WorkerExecutionContext ctx) |
static ServiceInfo |
BLangVMUtils.getServiceInfo(WorkerExecutionContext ctx) |
static LocalTransactionInfo |
BLangVMUtils.getTransactionInfo(WorkerExecutionContext ctx) |
static WorkerExecutionContext |
BLangVMUtils.handleNativeInvocationError(WorkerExecutionContext parentCtx,
BMap<String,BValue> error) |
static void |
BLangFunctions.invokeCallable(CallableUnitInfo callableUnitInfo,
WorkerExecutionContext parentCtx) |
static BValue[] |
BLangFunctions.invokeCallable(CallableUnitInfo callableUnitInfo,
WorkerExecutionContext parentCtx,
BValue[] args) |
static WorkerExecutionContext |
BLangFunctions.invokeCallable(CallableUnitInfo callableUnitInfo,
WorkerExecutionContext parentCtx,
int[] argRegs,
int[] retRegs,
boolean waitForResponse) |
static WorkerExecutionContext |
BLangFunctions.invokeCallable(CallableUnitInfo callableUnitInfo,
WorkerExecutionContext parentCtx,
int[] argRegs,
int[] retRegs,
boolean waitForResponse,
int flags) |
static WorkerExecutionContext |
BLangFunctions.invokeForkJoin(WorkerExecutionContext parentCtx,
ForkjoinInfo forkjoinInfo,
int joinTargetIp,
int joinVarReg,
int timeoutRegIndex,
int timeoutTargetIp,
int timeoutVarReg) |
static void |
BLangFunctions.invokePackageInitFunctions(ProgramFile programFile,
WorkerExecutionContext context)
This will order the package imports and inovke each package init function.
|
static void |
BLangFunctions.invokePackageStartFunctions(ProgramFile programFile,
WorkerExecutionContext context)
This will invoke package start functions, this should be invoked after
invoking "invokePackageInitFunctions".
|
static void |
BLangFunctions.invokeServiceCallable(CallableUnitInfo callableUnitInfo,
WorkerExecutionContext parentCtx,
ObserverContext observerContext,
BValue[] args,
CallableUnitCallback responseCallback) |
static int[][] |
BLangVMUtils.populateArgAndReturnData(WorkerExecutionContext ctx,
CallableUnitInfo callableUnitInfo,
BValue[] args) |
static BValue[] |
BLangVMUtils.populateReturnData(WorkerExecutionContext ctx,
CallableUnitInfo callableUnitInfo,
int[] retRegs) |
static void |
BLangVMUtils.removeTransactionInfo(WorkerExecutionContext ctx) |
static void |
BLangVMUtils.setGlobalTransactionEnabledStatus(WorkerExecutionContext ctx,
boolean isGlobalTransactionEnabled) |
static void |
BLangVMUtils.setServiceInfo(WorkerExecutionContext ctx,
ServiceInfo serviceInfo) |
static void |
BLangVMUtils.setTransactionInfo(WorkerExecutionContext ctx,
LocalTransactionInfo localTransactionInfo) |
Modifier and Type | Method and Description |
---|---|
static boolean |
TransactionUtils.isInitiator(WorkerExecutionContext ctx,
String globalTransactionId,
int transactionBlockId) |
boolean |
LocalTransactionInfo.isRetryPossible(WorkerExecutionContext context,
int transactionId) |
static void |
TransactionUtils.notifyTransactionAbort(WorkerExecutionContext ctx,
String globalTransactionId,
int transactionBlockId) |
static BValue[] |
TransactionUtils.notifyTransactionBegin(WorkerExecutionContext ctx,
String globalTransactionId,
String url,
int transactionBlockId,
String protocol) |
static void |
TransactionUtils.notifyTransactionEnd(WorkerExecutionContext ctx,
String globalTransactionId,
int transactionBlockId) |
boolean |
LocalTransactionInfo.onTransactionFailed(WorkerExecutionContext context,
int transactionBlockId) |
Copyright © 2018 WSO2. All rights reserved.