Fennel: ExecStreamScheduler Class Reference (original) (raw)

• Main Page

• Namespaces

• Classes

• Files

• Directories

• Related Pages

• Alphabetical List

• Class List

• Class Hierarchy

• Class Members

ExecStreamScheduler defines an abstract base for controlling the scheduling of execution streams. More...

#include <[ExecStreamScheduler.h](ExecStreamScheduler%5F8h-source.html)>

Inheritance diagram for ExecStreamScheduler:

List of all members.

Detailed Description

ExecStreamScheduler defines an abstract base for controlling the scheduling of execution streams.

A scheduler determines which execution streams to run and in what order. For more information, see SchedulerDesign.

Version:

Id

//open/dev/fennel/exec/ExecStreamScheduler.h#17

Definition at line 42 of file ExecStreamScheduler.h.

Constructor & Destructor Documentation

| ExecStreamScheduler::~ExecStreamScheduler | ( | | ) | [virtual] | | ------------------------------------------ | - | | - | ----------- |

Member Function Documentation

Traces the states of the input and output buffers adjacent to a stream.

Parameters:

Definition at line 140 of file ExecStreamScheduler.cpp.

References ExecStreamBufState_names, ExecStreamGraphImpl::getBufAccessorFromEdge(), ExecStreamBufAccessor::getConsumptionAvailable(), ExecStream::getGraph(), ExecStreamGraphImpl::getGraphRep(), ExecStreamBufAccessor::getProductionAvailable(), ExecStreamBufAccessor::getState(), ExecStream::getStreamId(), ExecStreamBufAccessor::hasPendingEOS(), TraceSource::isTracingLevel(), TRACE_FINER, and traceStreamBufferContents().

Referenced by tracePostExecution(), and tracePreExecution().

00144 { 00145 ExecStreamGraphImpl &graphImpl = 00146 dynamic_cast<ExecStreamGraphImpl&>(stream.getGraph()); 00147 ExecStreamGraphImpl::GraphRep const &graphRep = graphImpl.getGraphRep(); 00148 00149 ExecStreamGraphImpl::InEdgeIterPair inEdges = 00150 boost::in_edges(stream.getStreamId(),graphRep); 00151 for (uint i = 0; inEdges.first != inEdges.second; 00152 ++(inEdges.first), ++i) 00153 { 00154 ExecStreamGraphImpl::Edge edge = *(inEdges.first); 00155 ExecStreamBufAccessor &bufAccessor = 00156 graphImpl.getBufAccessorFromEdge(edge); 00157 FENNEL_TRACE( 00158 TRACE_FINER, 00159 "input buffer " << i << ": " 00160 << ExecStreamBufState_names[bufAccessor.getState()] 00161 << (bufAccessor.hasPendingEOS() ? ", EOS pending" : "") 00162 << ", consumption available = " 00163 << bufAccessor.getConsumptionAvailable()); 00164 if (stream.isTracingLevel(inputTupleTraceLevel)) { 00165 traceStreamBufferContents( 00166 stream, bufAccessor, inputTupleTraceLevel); 00167 } 00168 } 00169 00170 ExecStreamGraphImpl::OutEdgeIterPair outEdges = 00171 boost::out_edges(stream.getStreamId(),graphRep); 00172 for (uint i = 0; outEdges.first != outEdges.second; 00173 ++(outEdges.first), ++i) { 00174 ExecStreamGraphImpl::Edge edge = *(outEdges.first); 00175 ExecStreamBufAccessor &bufAccessor = 00176 graphImpl.getBufAccessorFromEdge(edge); 00177 FENNEL_TRACE( 00178 TRACE_FINER, 00179 "output buffer " << i << ": " 00180 << ExecStreamBufState_names[bufAccessor.getState()] 00181 << (bufAccessor.hasPendingEOS() ? ", EOS pending" : "") 00182 << ", consumption available = " 00183 << bufAccessor.getConsumptionAvailable() 00184 << ", production available = " 00185 << bufAccessor.getProductionAvailable()); 00186 if (stream.isTracingLevel(outputTupleTraceLevel)) { 00187 traceStreamBufferContents( 00188 stream, bufAccessor, outputTupleTraceLevel); 00189 } 00190 } 00191 }

| virtual void ExecStreamScheduler::start | ( | | ) | [pure virtual] | | --------------------------------------- | - | | - | ---------------- |

Asynchronously aborts execution of any scheduled streams contained by a particular graph and prevents further scheduling.

Returns immediately, not waiting for abort request to be fully processed.

Parameters:

Implemented in DfsTreeExecStreamScheduler, and ParallelExecStreamScheduler.

| void ExecStreamScheduler::checkAbort | ( | | ) | const [virtual] | | ------------------------------------ | - | | - | ----------------- |

| virtual void ExecStreamScheduler::stop | ( | | ) | [pure virtual] | | -------------------------------------- | - | | - | ---------------- |

Creates a new adapter stream capable of copying the output of a stream with BUFPROV_PRODUCER into the input of a stream with BUFPROV_CONSUMER.

Default implementation is CopyExecStream. Caller is responsible for filling in generic ExecStreamParams after return.

Parameters:

Definition at line 92 of file ExecStreamScheduler.cpp.

References ExecStreamEmbryo::init().

| uint ExecStreamScheduler::getDegreeOfParallelism | ( | | ) | [virtual] | | ------------------------------------------------------------------------------------------------------------- | - | | - | ----------- |

| bool TraceSource::isTracing | ( | | ) | const [inline, inherited] | | --------------------------- | - | | - | --------------------------- |

| TraceTarget& TraceSource::getTraceTarget | ( | | ) | const [inline, inherited] | | ----------------------------------------------------------------- | - | | - | --------------------------- |

| std::string TraceSource::getTraceSourceName | ( | | ) | const [inline, inherited] | | ------------------------------------------- | - | | - | --------------------------- |

Sets the name of this source.

Useful to construct dynamic names for fine-grained filtering.

Definition at line 136 of file TraceSource.h.

00137 { 00138 name = n; 00139 }

| TraceLevel TraceSource::getMinimumTraceLevel | ( | | ) | const [inline, inherited] | | ------------------------------------------------------------------------------------------------------ | - | | - | --------------------------- |

| void TraceSource::disableTracing | ( | | ) | [inherited] | | -------------------------------- | - | | - | ------------- |

Member Data Documentation

The documentation for this class was generated from the following files:

• /home/pub/open/dev/fennel/exec/ExecStreamScheduler.h
• /home/pub/open/dev/fennel/exec/ExecStreamScheduler.cpp

Generated on Mon Jun 22 04:00:30 2009 for Fennel by 1.5.1