VTK
Public Types | Public Member Functions | Static Public Member Functions | Public Attributes | Protected Member Functions
vtkThreadedStreamingPipeline Class Reference

Executive supporting multi-threads. More...

#include <vtkThreadedStreamingPipeline.h>

Inheritance diagram for vtkThreadedStreamingPipeline:
[legend]
Collaboration diagram for vtkThreadedStreamingPipeline:
[legend]

List of all members.

Public Types

typedef vtkCompositeDataPipeline Superclass
enum  { PROCESSING_UNIT_NONE = 0, PROCESSING_UNIT_CPU = 1, PROCESSING_UNIT_GPU = 2 }
- Public Types inherited from vtkCompositeDataPipeline
- Public Types inherited from vtkStreamingDemandDrivenPipeline
- Public Types inherited from vtkDemandDrivenPipeline
- Public Types inherited from vtkExecutive
enum  { RequestUpstream, RequestDownstream }
enum  { BeforeForward, AfterForward }
- Public Types inherited from vtkObject

Public Member Functions

virtual const char * GetClassName ()
virtual int IsA (const char *type)
void PrintSelf (ostream &os, vtkIndent indent)
void Pull ()
void Pull (vtkInformation *info)
void Push ()
void Push (vtkInformation *info)
void ReleaseInputs ()
int ForceUpdateData (int processingUnit, vtkInformation *info)
void UpdateRequestDataTimeFromSource ()
vtkComputingResources * GetResources ()
virtual int ProcessRequest (vtkInformation *request, vtkInformationVector **inInfo, vtkInformationVector *outInfo)
- Public Member Functions inherited from vtkCompositeDataPipeline
vtkDataObject * GetCompositeOutputData (int port)
vtkDataObject * GetCompositeInputData (int port, int index, vtkInformationVector **inInfoVec)
- Public Member Functions inherited from vtkStreamingDemandDrivenPipeline
int PropagateUpdateExtent (int outputPort)
virtual int Update ()
virtual int Update (int port)
virtual int UpdateWholeExtent ()
int SetMaximumNumberOfPieces (int port, int n)
int SetMaximumNumberOfPieces (vtkInformation *, int n)
int GetMaximumNumberOfPieces (int port)
int GetMaximumNumberOfPieces (vtkInformation *)
int SetWholeExtent (vtkInformation *, int extent[6])
void GetWholeExtent (vtkInformation *, int extent[6])
int * GetWholeExtent (vtkInformation *)
int SetUpdateExtentToWholeExtent (int port)
int SetUpdateExtentToWholeExtent (vtkInformation *)
int SetUpdateExtent (int port, int extent[6])
int SetUpdateExtent (vtkInformation *, int extent[6])
void GetUpdateExtent (vtkInformation *, int extent[6])
int * GetUpdateExtent (vtkInformation *)
int SetUpdateExtent (int port, int piece, int numPieces, int ghostLevel)
int SetUpdateExtent (vtkInformation *, int piece, int numPieces, int ghostLevel)
int SetUpdatePiece (vtkInformation *, int piece)
int GetUpdatePiece (vtkInformation *)
int SetUpdateNumberOfPieces (vtkInformation *, int n)
int GetUpdateNumberOfPieces (vtkInformation *)
int SetUpdateGhostLevel (vtkInformation *, int n)
int GetUpdateGhostLevel (vtkInformation *)
int SetUpdateResolution (int port, double r)
int SetUpdateResolution (vtkInformation *, double r)
double GetUpdateResolution (vtkInformation *)
int SetUpdateTimeSteps (int port, double *times, int length)
int SetUpdateTimeSteps (vtkInformation *, double *times, int length)
int SetUpdateTimeStep (int port, double time)
int SetRequestExactExtent (int port, int flag)
int GetRequestExactExtent (int port)
int SetExtentTranslator (int port, vtkExtentTranslator *translator)
int SetExtentTranslator (vtkInformation *, vtkExtentTranslator *translator)
vtkExtentTranslator * GetExtentTranslator (int port)
vtkExtentTranslator * GetExtentTranslator (vtkInformation *info)
int SetWholeBoundingBox (int port, double bb[6])
void GetWholeBoundingBox (int port, double bb[6])
double * GetWholeBoundingBox (int port)
int SetPieceBoundingBox (int port, double bb[6])
void GetPieceBoundingBox (int port, double bb[6])
double * GetPieceBoundingBox (int port)
double ComputePriority ()
virtual double ComputePriority (int port)
- Public Member Functions inherited from vtkDemandDrivenPipeline
virtual int SetReleaseDataFlag (int port, int n)
virtual int GetReleaseDataFlag (int port)
virtual int UpdatePipelineMTime ()
virtual int UpdateDataObject ()
virtual int UpdateInformation ()
virtual int UpdateData (int outputPort)
virtual int ComputePipelineMTime (vtkInformation *request, vtkInformationVector **inInfoVec, vtkInformationVector *outInfoVec, int requestFromOutputPort, unsigned long *mtime)
virtual unsigned long GetPipelineMTime ()
- Public Member Functions inherited from vtkExecutive
vtkAlgorithm * GetAlgorithm ()
int GetNumberOfInputConnections (int port)
virtual vtkInformation * GetOutputInformation (int port)
vtkInformationVector * GetOutputInformation ()
vtkInformation * GetInputInformation (int port, int connection)
vtkInformationVector * GetInputInformation (int port)
vtkInformationVector ** GetInputInformation ()
vtkExecutive * GetInputExecutive (int port, int connection)
virtual vtkAlgorithmOutput * GetProducerPort (vtkDataObject *)
int GetNumberOfInputPorts ()
int GetNumberOfOutputPorts ()
virtual vtkDataObject * GetOutputData (int port)
virtual void SetOutputData (int port, vtkDataObject *, vtkInformation *info)
virtual void SetOutputData (int port, vtkDataObject *)
virtual vtkDataObject * GetInputData (int port, int connection)
virtual vtkDataObject * GetInputData (int port, int connection, vtkInformationVector **inInfoVec)
void SetSharedInputInformation (vtkInformationVector **inInfoVec)
void SetSharedOutputInformation (vtkInformationVector *outInfoVec)
virtual void Register (vtkObjectBase *o)
virtual void UnRegister (vtkObjectBase *o)
virtual int CallAlgorithm (vtkInformation *request, int direction, vtkInformationVector **inInfo, vtkInformationVector *outInfo)
- Public Member Functions inherited from vtkObject
virtual void DebugOn ()
virtual void DebugOff ()
unsigned char GetDebug ()
void SetDebug (unsigned char debugFlag)
virtual void Modified ()
virtual unsigned long GetMTime ()
unsigned long AddObserver (unsigned long event, vtkCommand *, float priority=0.0f)
unsigned long AddObserver (const char *event, vtkCommand *, float priority=0.0f)
vtkCommand * GetCommand (unsigned long tag)
void RemoveObserver (vtkCommand *)
void RemoveObservers (unsigned long event, vtkCommand *)
void RemoveObservers (const char *event, vtkCommand *)
int HasObserver (unsigned long event, vtkCommand *)
int HasObserver (const char *event, vtkCommand *)
void RemoveObserver (unsigned long tag)
void RemoveObservers (unsigned long event)
void RemoveObservers (const char *event)
void RemoveAllObservers ()
int HasObserver (unsigned long event)
int HasObserver (const char *event)
template<class U , class T >
unsigned long AddObserver (unsigned long event, U observer, void(T::*callback)(), float priority=0.0f)
template<class U , class T >
unsigned long AddObserver (unsigned long event, U observer, void(T::*callback)(vtkObject *, unsigned long, void *), float priority=0.0f)
int InvokeEvent (unsigned long event, void *callData)
int InvokeEvent (const char *event, void *callData)
int InvokeEvent (unsigned long event)
int InvokeEvent (const char *event)
- Public Member Functions inherited from vtkObjectBase
const char * GetClassName () const
virtual void Delete ()
virtual void FastDelete ()
void Print (ostream &os)
void SetReferenceCount (int)
void PrintRevisions (ostream &os)
virtual void PrintHeader (ostream &os, vtkIndent indent)
virtual void PrintTrailer (ostream &os, vtkIndent indent)
int GetReferenceCount ()

Static Public Member Functions

static
vtkThreadedStreamingPipeline * 
New ()
static int IsTypeOf (const char *type)
static
vtkThreadedStreamingPipeline * 
SafeDownCast (vtkObject *o)
static vtkInformationIntegerKey * AUTO_PROPAGATE ()
static
vtkInformationObjectBaseKey * 
EXTRA_INFORMATION ()
static void SetMultiThreadedEnabled (bool enabled)
static void SetAutoPropagatePush (bool enabled)
static void Pull (vtkExecutiveCollection *execs)
static void Pull (vtkExecutiveCollection *execs, vtkInformation *info)
static void Push (vtkExecutiveCollection *execs)
static void Push (vtkExecutiveCollection *execs, vtkInformation *info)
static void Pull (vtkExecutive *exec)
static void Pull (vtkExecutive *exec, vtkInformation *info)
static void Push (vtkExecutive *exec)
static void Push (vtkExecutive *exec, vtkInformation *info)
- Static Public Member Functions inherited from vtkCompositeDataPipeline
static vtkInformationIntegerKey * REQUIRES_TIME_DOWNSTREAM ()
static
vtkInformationObjectBaseKey * 
COMPOSITE_DATA_META_DATA ()
static
vtkInformationIntegerVectorKey * 
UPDATE_COMPOSITE_INDICES ()
static
vtkInformationIntegerVectorKey * 
COMPOSITE_INDICES ()
static vtkInformationIntegerKey * COMPOSITE_INDEX ()
- Static Public Member Functions inherited from vtkStreamingDemandDrivenPipeline
static vtkInformationRequestKey * REQUEST_UPDATE_EXTENT ()
static vtkInformationRequestKey * REQUEST_UPDATE_EXTENT_INFORMATION ()
static vtkInformationRequestKey * REQUEST_RESOLUTION_PROPAGATE ()
static vtkInformationIntegerKey * CONTINUE_EXECUTING ()
static
vtkInformationObjectBaseKey * 
EXTENT_TRANSLATOR ()
static
vtkInformationIntegerVectorKey * 
COMBINED_UPDATE_EXTENT ()
static vtkInformationIntegerKey * UPDATE_EXTENT_TRANSLATED ()
static
vtkInformationIntegerVectorKey * 
WHOLE_EXTENT ()
static vtkInformationIntegerKey * UNRESTRICTED_UPDATE_EXTENT ()
static vtkInformationIntegerKey * MAXIMUM_NUMBER_OF_PIECES ()
static
vtkInformationDoubleVectorKey * 
WHOLE_BOUNDING_BOX ()
static
vtkInformationDoubleVectorKey * 
PIECE_BOUNDING_BOX ()
static vtkInformationIntegerKey * EXACT_EXTENT ()
static
vtkInformationDoubleVectorKey * 
TIME_STEPS ()
static
vtkInformationDoubleVectorKey * 
TIME_RANGE ()
static
vtkInformationDoubleVectorKey * 
UPDATE_TIME_STEPS ()
static vtkInformationDoubleKey * PRIORITY ()
static vtkInformationDoubleKey * UPDATE_RESOLUTION ()
static vtkInformationIntegerKey * REMOVE_ATTRIBUTE_INFORMATION ()
static vtkInformationIntegerKey * FAST_PATH_FOR_TEMPORAL_DATA ()
static vtkInformationStringKey * FAST_PATH_OBJECT_TYPE ()
static vtkInformationStringKey * FAST_PATH_ID_TYPE ()
static vtkInformationIdTypeKey * FAST_PATH_OBJECT_ID ()
static vtkInformationIntegerKey * UPDATE_EXTENT_INITIALIZED ()
static
vtkInformationIntegerVectorKey * 
UPDATE_EXTENT ()
static vtkInformationIntegerKey * UPDATE_PIECE_NUMBER ()
static vtkInformationIntegerKey * UPDATE_NUMBER_OF_PIECES ()
static vtkInformationIntegerKey * UPDATE_NUMBER_OF_GHOST_LEVELS ()
- Static Public Member Functions inherited from vtkDemandDrivenPipeline
static vtkInformationRequestKey * REQUEST_DATA_OBJECT ()
static vtkInformationRequestKey * REQUEST_INFORMATION ()
static vtkInformationRequestKey * REQUEST_DATA ()
static vtkInformationRequestKey * REQUEST_DATA_NOT_GENERATED ()
static vtkInformationIntegerKey * RELEASE_DATA ()
static vtkInformationIntegerKey * DATA_NOT_GENERATED ()
static vtkDataObject * NewDataObject (const char *type)
static vtkInformationIntegerKey * REQUEST_REGENERATE_INFORMATION ()
- Static Public Member Functions inherited from vtkExecutive
static
vtkInformationExecutivePortKey * 
PRODUCER ()
static
vtkInformationExecutivePortVectorKey * 
CONSUMERS ()
static vtkInformationIntegerKey * FROM_OUTPUT_PORT ()
static vtkInformationIntegerKey * ALGORITHM_BEFORE_FORWARD ()
static vtkInformationIntegerKey * ALGORITHM_AFTER_FORWARD ()
static vtkInformationIntegerKey * ALGORITHM_DIRECTION ()
static vtkInformationIntegerKey * FORWARD_DIRECTION ()
static vtkInformationKeyVectorKey * KEYS_TO_COPY ()
- Static Public Member Functions inherited from vtkObject
static void BreakOnError ()
static void SetGlobalWarningDisplay (int val)
static void GlobalWarningDisplayOn ()
static void GlobalWarningDisplayOff ()
static int GetGlobalWarningDisplay ()

Public Attributes

float LastDataRequestTime
float LastDataRequestTimeFromSource
vtkInformation * ForceDataRequest
vtkComputingResources * Resources
vtkExecutionScheduler * Scheduler

Protected Member Functions

 vtkThreadedStreamingPipeline ()
 ~vtkThreadedStreamingPipeline ()
virtual int ForwardUpstream (vtkInformation *request)
virtual int ForwardUpstream (int i, int j, vtkInformation *request)
- Protected Member Functions inherited from vtkCompositeDataPipeline
 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)
- Protected Member Functions inherited from vtkStreamingDemandDrivenPipeline
 vtkStreamingDemandDrivenPipeline ()
 ~vtkStreamingDemandDrivenPipeline ()
virtual int NeedToExecuteBasedOnFastPathData (vtkInformation *outInfo)
virtual int ExecuteInformation (vtkInformation *request, vtkInformationVector **inInfoVec, vtkInformationVector *outInfoVec)
virtual int VerifyOutputInformation (int outputPort, vtkInformationVector **inInfoVec, vtkInformationVector *outInfoVec)
virtual void ExecuteDataEnd (vtkInformation *request, vtkInformationVector **inInfoVec, vtkInformationVector *outInfoVec)
virtual void ResetUpdateInformation (vtkInformation *request, vtkInformationVector **inInfoVec, vtkInformationVector *outInfoVec)
- Protected Member Functions inherited from vtkDemandDrivenPipeline
 vtkDemandDrivenPipeline ()
 ~vtkDemandDrivenPipeline ()
virtual int CheckDataObject (int port, vtkInformationVector *outInfo)
int InputCountIsValid (vtkInformationVector **)
int InputCountIsValid (int port, vtkInformationVector **)
int InputTypeIsValid (vtkInformationVector **)
int InputTypeIsValid (int port, vtkInformationVector **)
int InputFieldsAreValid (vtkInformationVector **)
int InputFieldsAreValid (int port, vtkInformationVector **)
virtual int InputFieldsAreValid (int port, int index, vtkInformationVector **)
int DataSetAttributeExists (vtkDataSetAttributes *dsa, vtkInformation *field)
int FieldArrayExists (vtkFieldData *data, vtkInformation *field)
int ArrayIsValid (vtkAbstractArray *array, vtkInformation *field)
int InputIsOptional (int port)
int InputIsRepeatable (int port)
- Protected Member Functions inherited from vtkExecutive
 vtkExecutive ()
 ~vtkExecutive ()
int InputPortIndexInRange (int port, const char *action)
int OutputPortIndexInRange (int port, const char *action)
int CheckAlgorithm (const char *method, vtkInformation *request)
virtual int ForwardDownstream (vtkInformation *request)
virtual void ReportReferences (vtkGarbageCollector *)
virtual void SetAlgorithm (vtkAlgorithm *algorithm)
- Protected Member Functions inherited from vtkObject
 vtkObject ()
virtual ~vtkObject ()
virtual void RegisterInternal (vtkObjectBase *, int check)
virtual void UnRegisterInternal (vtkObjectBase *, int check)
void InternalGrabFocus (vtkCommand *mouseEvents, vtkCommand *keypressEvents=NULL)
void InternalReleaseFocus ()
- Protected Member Functions inherited from vtkObjectBase
 vtkObjectBase ()
virtual ~vtkObjectBase ()
virtual void CollectRevisions (ostream &os)
 vtkObjectBase (const vtkObjectBase &)
void operator= (const vtkObjectBase &)

Additional Inherited Members

- Protected Attributes inherited from vtkCompositeDataPipeline
int InLocalLoop
vtkInformation * InformationCache
vtkInformation * GenericRequest
vtkInformation * DataObjectRequest
vtkInformation * InformationRequest
vtkInformation * UpdateExtentRequest
vtkInformation * DataRequest
int SuppressResetPipelineInformation
- Protected Attributes inherited from vtkStreamingDemandDrivenPipeline
int ContinueExecuting
int LastPropogateUpdateExtentShortCircuited
- Protected Attributes inherited from vtkDemandDrivenPipeline
unsigned long PipelineMTime
vtkTimeStamp DataObjectTime
vtkTimeStamp InformationTime
vtkTimeStamp DataTime
vtkInformation * InfoRequest
- Protected Attributes inherited from vtkExecutive
vtkAlgorithm * Algorithm
int InAlgorithm
vtkInformationVector ** SharedInputInformation
vtkInformationVector * SharedOutputInformation
- Protected Attributes inherited from vtkObject
unsigned char Debug
vtkTimeStamp MTime
vtkSubjectHelper * SubjectHelper
- Protected Attributes inherited from vtkObjectBase
int ReferenceCount
vtkWeakPointerBase ** WeakPointers

Detailed Description

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.


Member Typedef Documentation

Reimplemented from vtkCompositeDataPipeline.

Definition at line 59 of file vtkThreadedStreamingPipeline.h.


Member Enumeration Documentation

anonymous enum

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.


Constructor & Destructor Documentation

vtkThreadedStreamingPipeline::vtkThreadedStreamingPipeline ( )
protected
vtkThreadedStreamingPipeline::~vtkThreadedStreamingPipeline ( )
protected

Member Function Documentation

static vtkThreadedStreamingPipeline* vtkThreadedStreamingPipeline::New ( )
static

Create an object with Debug turned off, modified time initialized to zero, and reference counting on.

Reimplemented from vtkCompositeDataPipeline.

virtual const char* vtkThreadedStreamingPipeline::GetClassName ( )
virtual

Reimplemented from vtkCompositeDataPipeline.

static int vtkThreadedStreamingPipeline::IsTypeOf ( const char *  name)
static

Return 1 if this class type is the same type of (or a subclass of) the named class. Returns 0 otherwise. This method works in combination with vtkTypeMacro found in vtkSetGet.h.

Reimplemented from vtkCompositeDataPipeline.

virtual int vtkThreadedStreamingPipeline::IsA ( const char *  name)
virtual

Return 1 if this class is the same type of (or a subclass of) the named class. Returns 0 otherwise. This method works in combination with vtkTypeMacro found in vtkSetGet.h.

Reimplemented from vtkCompositeDataPipeline.

static vtkThreadedStreamingPipeline* vtkThreadedStreamingPipeline::SafeDownCast ( vtkObject *  o)
static

Reimplemented from vtkCompositeDataPipeline.

void vtkThreadedStreamingPipeline::PrintSelf ( ostream &  os,
vtkIndent  indent 
)
virtual

Methods invoked by print to print information about the object including superclasses. Typically not called by the user (use Print() instead) but used in the hierarchical print process to combine the output of several classes.

Reimplemented from vtkCompositeDataPipeline.

static vtkInformationIntegerKey* vtkThreadedStreamingPipeline::AUTO_PROPAGATE ( )
static

Key to store the priority of a task

static vtkInformationObjectBaseKey* vtkThreadedStreamingPipeline::EXTRA_INFORMATION ( )
static

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

static void vtkThreadedStreamingPipeline::Pull ( vtkExecutiveCollection *  execs)
static

Trigger the updates on certain execs and asking all of its upstream modules to be updated as well (propagate up)

static void vtkThreadedStreamingPipeline::Pull ( vtkExecutiveCollection *  execs,
vtkInformation *  info 
)
static

Trigger the updates on certain execs and asking all of its upstream modules to be updated as well (propagate up)

static void vtkThreadedStreamingPipeline::Push ( vtkExecutiveCollection *  execs)
static

Trigger the updates on certain execs and asking all of its downstream modules to be updated as well (propagate down)

static void vtkThreadedStreamingPipeline::Push ( vtkExecutiveCollection *  execs,
vtkInformation *  info 
)
static

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

static void vtkThreadedStreamingPipeline::Pull ( vtkExecutive *  exec,
vtkInformation *  info 
)
static

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

static void vtkThreadedStreamingPipeline::Push ( vtkExecutive *  exec,
vtkInformation *  info 
)
static

A simplified version of Push() which only acts upon a single executive

void vtkThreadedStreamingPipeline::Pull ( )

Triggers upstream modules to update but not including itself

void vtkThreadedStreamingPipeline::Pull ( vtkInformation *  info)

Triggers upstream modules to update but not including itself

void vtkThreadedStreamingPipeline::Push ( )

Triggers downstream modules to update but not including itself

void vtkThreadedStreamingPipeline::Push ( vtkInformation *  info)

Triggers downstream modules to update but not including itself

void vtkThreadedStreamingPipeline::ReleaseInputs ( )

Release all the locks for input ports living upstream

virtual int vtkThreadedStreamingPipeline::ProcessRequest ( vtkInformation *  request,
vtkInformationVector **  inInfo,
vtkInformationVector *  outInfo 
)
virtual

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

vtkComputingResources* vtkThreadedStreamingPipeline::GetResources ( )

Return the scheduling for this executive

virtual int vtkThreadedStreamingPipeline::ForwardUpstream ( vtkInformation *  request)
protectedvirtual

Reimplemented from vtkCompositeDataPipeline.

virtual int vtkThreadedStreamingPipeline::ForwardUpstream ( int  i,
int  j,
vtkInformation *  request 
)
protectedvirtual

Reimplemented from vtkCompositeDataPipeline.


Member Data Documentation

float vtkThreadedStreamingPipeline::LastDataRequestTime

Definition at line 151 of file vtkThreadedStreamingPipeline.h.

float vtkThreadedStreamingPipeline::LastDataRequestTimeFromSource

Definition at line 152 of file vtkThreadedStreamingPipeline.h.

vtkInformation* vtkThreadedStreamingPipeline::ForceDataRequest

Definition at line 153 of file vtkThreadedStreamingPipeline.h.

vtkComputingResources* vtkThreadedStreamingPipeline::Resources

Definition at line 154 of file vtkThreadedStreamingPipeline.h.

vtkExecutionScheduler* vtkThreadedStreamingPipeline::Scheduler

Definition at line 155 of file vtkThreadedStreamingPipeline.h.


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