vtkThreadedStreamingPipeline Class Reference

#include <vtkThreadedStreamingPipeline.h>

Inheritance diagram for vtkThreadedStreamingPipeline:

[legend]

Collaboration diagram for vtkThreadedStreamingPipeline:

[legend]

List of all members.

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.


Public Types
typedef vtkCompositeDataPipeline	Superclass

enum	{ PROCESSING_UNIT_NONE = 0, PROCESSING_UNIT_CPU = 1, PROCESSING_UNIT_GPU = 2 }
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)
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)
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)

Member Typedef Documentation

typedef vtkCompositeDataPipeline vtkThreadedStreamingPipeline::Superclass

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]`