Executive supporting multi-threads.
More...
#include <vtkThreadedStreamingPipeline.h>
|
| vtkThreadedStreamingPipeline () |
|
| ~vtkThreadedStreamingPipeline () |
|
virtual int | ForwardUpstream (vtkInformation *request) |
|
virtual int | ForwardUpstream (int i, int j, vtkInformation *request) |
|
| vtkCompositeDataPipeline () |
|
| ~vtkCompositeDataPipeline () |
|
virtual void | CopyDefaultInformation (vtkInformation *request, int direction, vtkInformationVector **inInfoVec, vtkInformationVector *outInfoVec) |
|
virtual void | CopyFromDataToInformation (vtkDataObject *dobj, vtkInformation *inInfo) |
|
virtual void | PushInformation (vtkInformation *) |
|
virtual void | PopInformation (vtkInformation *) |
|
virtual int | ExecuteDataObject (vtkInformation *request, vtkInformationVector **inInfo, vtkInformationVector *outInfo) |
|
virtual int | ExecuteData (vtkInformation *request, vtkInformationVector **inInfoVec, vtkInformationVector *outInfoVec) |
|
virtual void | ExecuteDataStart (vtkInformation *request, vtkInformationVector **inInfoVec, vtkInformationVector *outInfoVec) |
|
virtual int | NeedToExecuteData (int outputPort, vtkInformationVector **inInfoVec, vtkInformationVector *outInfoVec) |
|
virtual int | NeedToExecuteBasedOnTime (vtkInformation *outInfo, vtkDataObject *dataObject) |
|
virtual int | CheckCompositeData (vtkInformation *request, int port, vtkInformationVector **inInfoVec, vtkInformationVector *outInfoVec) |
|
virtual void | ExecuteSimpleAlgorithm (vtkInformation *request, vtkInformationVector **inInfoVec, vtkInformationVector *outInfoVec, int compositePort) |
|
virtual void | ExecuteSimpleAlgorithmTime (vtkInformation *request, vtkInformationVector **inInfoVec, vtkInformationVector *outInfoVec) |
|
vtkDataObject * | ExecuteSimpleAlgorithmForBlock (vtkInformationVector **inInfoVec, vtkInformationVector *outInfoVec, vtkInformation *inInfo, vtkInformation *outInfo, vtkInformation *request, vtkDataObject *dobj) |
|
bool | ShouldIterateOverInput (int &compositePort) |
|
bool | ShouldIterateTemporalData (vtkInformation *request, vtkInformationVector **inInfoVec, vtkInformationVector *outInfoVec) |
|
virtual int | InputTypeIsValid (int port, int index, vtkInformationVector **inInfoVec) |
|
virtual void | ResetPipelineInformation (int port, vtkInformation *) |
|
virtual void | MarkOutputsGenerated (vtkInformation *request, vtkInformationVector **inInfoVec, vtkInformationVector *outInfoVec) |
|
int | NeedToExecuteBasedOnCompositeIndices (vtkInformation *outInfo) |
|
vtkCompositeDataSet * | CreateOutputCompositeDataSet (vtkCompositeDataSet *input, int compositePort) |
|
Executive supporting multi-threads.
vtkThreadeStreamingDemandDrivenPipeline is an executive that supports updating input ports based on the number of threads available.
- See also
- vtkExecutionScheduler
- Examples:
- vtkThreadedStreamingPipeline (Examples)
- Tests:
- vtkThreadedStreamingPipeline (Tests)
Definition at line 55 of file vtkThreadedStreamingPipeline.h.
Definition of different types of processing units an algorithm can be executed
Enumerator |
---|
PROCESSING_UNIT_NONE |
|
PROCESSING_UNIT_CPU |
|
PROCESSING_UNIT_GPU |
|
Definition at line 72 of file vtkThreadedStreamingPipeline.h.
vtkThreadedStreamingPipeline::vtkThreadedStreamingPipeline |
( |
| ) |
|
|
protected |
vtkThreadedStreamingPipeline::~vtkThreadedStreamingPipeline |
( |
| ) |
|
|
protected |
virtual const char* vtkThreadedStreamingPipeline::GetClassName |
( |
| ) |
|
|
virtual |
static int vtkThreadedStreamingPipeline::IsTypeOf |
( |
const char * |
type | ) |
|
|
static |
virtual int vtkThreadedStreamingPipeline::IsA |
( |
const char * |
type | ) |
|
|
virtual |
void vtkThreadedStreamingPipeline::PrintSelf |
( |
ostream & |
os, |
|
|
vtkIndent |
indent |
|
) |
| |
Key to store the priority of a task
Key to store the additional information for an update request
static void vtkThreadedStreamingPipeline::SetMultiThreadedEnabled |
( |
bool |
enabled | ) |
|
|
static |
Enable/Disable Multi-Threaded updating mechanism
static void vtkThreadedStreamingPipeline::SetAutoPropagatePush |
( |
bool |
enabled | ) |
|
|
static |
Enable/Disable automatic propagation of Push events
Trigger the updates on certain execs and asking all of its upstream modules to be updated as well (propagate up)
Trigger the updates on certain execs and asking all of its upstream modules to be updated as well (propagate up)
Trigger the updates on certain execs and asking all of its downstream modules to be updated as well (propagate down)
Trigger the updates on certain execs and asking all of its downstream modules to be updated as well (propagate down)
static void vtkThreadedStreamingPipeline::Pull |
( |
vtkExecutive * |
exec | ) |
|
|
static |
A simplified version of Pull() which only acts upon a single executive
A simplified version of Pull() which only acts upon a single executive
static void vtkThreadedStreamingPipeline::Push |
( |
vtkExecutive * |
exec | ) |
|
|
static |
A simplified version of Push() which only acts upon a single executive
A simplified version of Push() which only acts upon a single executive
void vtkThreadedStreamingPipeline::Pull |
( |
| ) |
|
Triggers upstream modules to update but not including itself
Triggers upstream modules to update but not including itself
void vtkThreadedStreamingPipeline::Push |
( |
| ) |
|
Triggers downstream modules to update but not including itself
Triggers downstream modules to update but not including itself
void vtkThreadedStreamingPipeline::ReleaseInputs |
( |
| ) |
|
Release all the locks for input ports living upstream
Generalized interface for asking the executive to fullfill update requests.
Reimplemented from vtkCompositeDataPipeline.
int vtkThreadedStreamingPipeline::ForceUpdateData |
( |
int |
processingUnit, |
|
|
vtkInformation * |
info |
|
) |
| |
Send a direct REQUEST_DATA (on all ports) to this executive
void vtkThreadedStreamingPipeline::UpdateRequestDataTimeFromSource |
( |
| ) |
|
Update the LastDataRequestTimeFromSource using its upstream time
Return the scheduling for this executive
virtual int vtkThreadedStreamingPipeline::ForwardUpstream |
( |
vtkInformation * |
request | ) |
|
|
protectedvirtual |
virtual int vtkThreadedStreamingPipeline::ForwardUpstream |
( |
int |
i, |
|
|
int |
j, |
|
|
vtkInformation * |
request |
|
) |
| |
|
protectedvirtual |
float vtkThreadedStreamingPipeline::LastDataRequestTime |
float vtkThreadedStreamingPipeline::LastDataRequestTimeFromSource |
The documentation for this class was generated from the following file: