abort(ExecStreamGraph &graph) | ParallelExecStreamScheduler | [virtual] |
addGraph(SharedExecStreamGraph pGraph) | ParallelExecStreamScheduler | [virtual] |
addToQueue(ExecStreamId streamId) | ParallelExecStreamScheduler | [private] |
alterNeighborInhibition(ExecStreamId streamId, int delta) | ParallelExecStreamScheduler | [inline, private] |
checkAbort() const | ParallelExecStreamScheduler | [virtual] |
completedQueue | ParallelExecStreamScheduler | [private] |
condition | SynchMonitoredObject | [protected] |
createBufferProvisionAdapter(ExecStreamEmbryo &embryo) | ParallelExecStreamScheduler | [virtual] |
createCopyProvisionAdapter(ExecStreamEmbryo &embryo) | ExecStreamScheduler | [virtual] |
degreeOfParallelism | ParallelExecStreamScheduler | [private] |
disableTracing() | TraceSource | |
ExecStreamScheduler(SharedTraceTarget pTraceTarget, std::string name) | ExecStreamScheduler | [explicit, protected] |
executeManager() | ParallelExecStreamScheduler | [private] |
executeStream(ExecStream &stream, ExecStreamQuantum const &quantum) | ExecStreamScheduler | [inline, protected] |
executeTask(ExecStream &) | ParallelExecStreamScheduler | [private] |
getDegreeOfParallelism() | ParallelExecStreamScheduler | [virtual] |
getMinimumTraceLevel() const | TraceSource | [inline] |
getSharedTraceTarget() const | TraceSource | [inline] |
getTraceSourceName() const | TraceSource | [inline] |
getTraceTarget() const | TraceSource | [inline] |
InhibitedQueue typedef | ParallelExecStreamScheduler | [private] |
inhibitedQueue | ParallelExecStreamScheduler | [private] |
initTraceSource(SharedTraceTarget pTraceTarget, std::string name) | TraceSource | [virtual] |
isInhibited(ExecStreamId streamId) | ParallelExecStreamScheduler | [inline, private] |
isTracing() const | TraceSource | [inline] |
isTracingLevel(TraceLevel level) const | TraceSource | [inline] |
makeRunnable(ExecStream &stream) | ParallelExecStreamScheduler | [virtual] |
ManagerState enum name | ParallelExecStreamScheduler | [private] |
MGR_RUNNING enum value | ParallelExecStreamScheduler | [private] |
MGR_STOPPED enum value | ParallelExecStreamScheduler | [private] |
MGR_STOPPING enum value | ParallelExecStreamScheduler | [private] |
mgrState | ParallelExecStreamScheduler | [private] |
mutex | SynchMonitoredObject | [protected] |
newBufAccessor() | ExecStreamScheduler | [virtual] |
ParallelExecStreamScheduler(SharedTraceTarget pTraceTarget, std::string name, ThreadTracker &threadTracker, uint degreeOfParallelism) | ParallelExecStreamScheduler | [explicit] |
ParallelExecTask class | ParallelExecStreamScheduler | [friend] |
pGraph | ParallelExecStreamScheduler | [private] |
pPendingExcn | ParallelExecStreamScheduler | [private] |
processCompletedTask(ParallelExecResult const &task) | ParallelExecStreamScheduler | [private] |
readStream(ExecStream &stream) | ParallelExecStreamScheduler | [virtual] |
removeGraph(SharedExecStreamGraph pGraph) | ParallelExecStreamScheduler | [virtual] |
retryInhibitedQueue() | ParallelExecStreamScheduler | [private] |
sentinelCondition | ParallelExecStreamScheduler | [private] |
setRunnable(ExecStream &stream, bool) | ParallelExecStreamScheduler | [virtual] |
setTraceSourceName(std::string const &n) | TraceSource | [inline] |
signalSentinel(ExecStreamId sentinelId) | ParallelExecStreamScheduler | [private] |
SS_INHIBITED enum value | ParallelExecStreamScheduler | [private] |
SS_RUNNING enum value | ParallelExecStreamScheduler | [private] |
SS_SLEEPING enum value | ParallelExecStreamScheduler | [private] |
start() | ParallelExecStreamScheduler | [virtual] |
stop() | ParallelExecStreamScheduler | [virtual] |
StreamState enum name | ParallelExecStreamScheduler | [private] |
streamStateMap | ParallelExecStreamScheduler | [private] |
StreamStateMap typedef | ParallelExecStreamScheduler | [private] |
SynchMonitoredObject() | SynchMonitoredObject | [explicit, protected] |
threadPool | ParallelExecStreamScheduler | [private] |
threadTracker | ParallelExecStreamScheduler | [private] |
trace(TraceLevel level, std::string message) const | TraceSource | |
tracePostExecution(ExecStream &stream, ExecStreamResult rc) | ExecStreamScheduler | [protected, virtual] |
tracePreExecution(ExecStream &stream, ExecStreamQuantum const &quantum) | ExecStreamScheduler | [protected, virtual] |
TraceSource() | TraceSource | [explicit, protected] |
TraceSource(SharedTraceTarget pTraceTarget, std::string name) | TraceSource | [explicit, protected] |
traceStreamBufferContents(ExecStream &stream, ExecStreamBufAccessor &bufAccessor, TraceLevel traceLevel) | ExecStreamScheduler | [virtual] |
traceStreamBuffers(ExecStream &stream, TraceLevel inputTupleTraceLevel, TraceLevel outputTupleTraceLevel) | ExecStreamScheduler | [protected, virtual] |
tracingFine | ExecStreamScheduler | [protected] |
transitQueue | ParallelExecStreamScheduler | [private] |
tryExecuteManager() | ParallelExecStreamScheduler | [private] |
tryExecuteTask(ExecStream &) | ParallelExecStreamScheduler | [private] |
~ExecStreamScheduler() | ExecStreamScheduler | [virtual] |
~ParallelExecStreamScheduler() | ParallelExecStreamScheduler | [virtual] |
~TraceSource() | TraceSource | [virtual] |