#include <evThreadedController.h>

Inheritance diagram for evThreadedController:

Collaboration diagram for evThreadedController:

Public Member Functions
	vtkTypeMacro (evThreadedController, evMultiProcessController)

void	PrintSelf (ostream &os, vtkIndent indent)

void	Initialize (int argc, char *arcv[])

	vtkGetMacro (LocalProcessId, int)

void	SingleMethodExecute ()

void	MultipleMethodExecute ()

int	Send (vtkDataObject *data, int remoteProcessId, int tag)

int	Send (int *data, int length, int remoteProcessId, int tag)

int	Send (unsigned long *data, int length, int remoteProcessId, int tag)

int	Send (char *data, int length, int remoteProcessId, int tag)

int	Send (double *data, int length, int remoteProcessId, int tag)

int	Send (void **data, int remoteProcessId, int tag)

void	Clear (int remoteProcessId)

int	Receive (vtkDataObject *data, int remoteProcessId, int tag)

int	Receive (int *data, int length, int remoteProcessId, int tag)

int	Receive (unsigned long *data, int length, int remoteProcessId, int tag)

int	Receive (char *data, int length, int remoteProcessId, int tag)

int	Receive (double *data, int length, int remoteProcessId, int tag)

int	Receive (void **data, int remoteProcessId, int tag)

void	Start (int threadIdx)

Public Member Functions inherited from evMultiProcessController
	vtkTypeMacro (evMultiProcessController, vtkObject)

void	PrintSelf (ostream &os, vtkIndent indent)

virtual void	Initialize (int vtkNotUsed(argc), char *arcv[])

virtual void	SetNumberOfProcesses (int num)

	vtkGetMacro (NumberOfProcesses, int)

void	SetSingleMethod (evProcessFunctionType, void *data)

void	SetMultipleMethod (int index, evProcessFunctionType, void *data)

virtual int	GetLocalProcessId ()

	vtkSetMacro (ForceDeepCopy, int)

	vtkGetMacro (ForceDeepCopy, int)

	vtkBooleanMacro (ForceDeepCopy, int)

	vtkSetMacro (Blocking, int)

	vtkGetMacro (Blocking, int)

void	AddRMI (evRMIFunctionType, void *localArg, int tag)

void	RemoveRMI (evRMIFunctionType f, void *arg, int tag)

void	TriggerRMI (int remoteProcessId, void *arg, int argLength, int tag)

void	TriggerRMI (int remoteProcessId, char *arg, int tag)

void	TriggerRMI (int remoteProcessId, int tag)

void	ProcessRMIs ()

	vtkSetMacro (BreakFlag, int)

	vtkGetMacro (BreakFlag, int)

	vtkGetMacro (WriteTime, float)

	vtkGetMacro (ReadTime, float)

	vtkGetMacro (SendWaitTime, float)

	vtkGetMacro (SendTime, float)

	vtkGetMacro (ReceiveWaitTime, float)

	vtkGetMacro (ReceiveTime, float)

Static Public Member Functions
static evThreadedController *	New ()

Static Public Member Functions inherited from evMultiProcessController
static evMultiProcessController *	New ()

static evMultiProcessController *	GetGlobalController ()

Protected Member Functions
	evThreadedController ()

	~evThreadedController ()

	evThreadedController (const evThreadedController &)

void	operator= (const evThreadedController &)

void	CreateProcessControllers ()

evThreadedControllerMessage *	NewMessage (vtkDataObject object, void data, int dataLength)

void	DeleteMessage (evThreadedControllerMessage *message)

void	AddMessage (evThreadedControllerMessage *message)

evThreadedControllerMessage *	FindMessage (int sendId, int tag)

void	ClearMessages (int sendId)

void	RemoveMessage (evThreadedControllerMessage *message)

int	Send (vtkDataObject object, void data, int dataLength, int remoteProcessId, int tag)

int	Receive (vtkDataObject object, void data, int dataLength, int remoteProcessId, int tag)

evMultiProcessController *	GetLocalController ()

Protected Member Functions inherited from evMultiProcessController
	evMultiProcessController ()

	~evMultiProcessController ()

	evMultiProcessController (const evMultiProcessController &)

void	operator= (const evMultiProcessController &)

void	DeleteAndSetMarshalString (char *str, int strLength)

int	WriteObject (vtkDataObject *object)

int	ReadObject (vtkDataObject *object)

int	WriteDataSet (vtkDataSet *object)

int	ReadDataSet (vtkDataSet *object)

int	WriteImageData (vtkImageData *object)

int	ReadImageData (vtkImageData *object)

void	ProcessRMI (int remoteProcessId, void *arg, int argLength, int rmiTag)

virtual void	SetGlobalController (evMultiProcessController *controller)

Protected Attributes
evThreadedController *	Controllers [VTK_MP_CONTROLLER_MAX_PROCESSES]

int	LocalProcessId

int	WaitingForId

vtkMultiThreader *	MultiThreader

int	MultipleMethodFlag

vtkMutexLock *	MessageListLock

vtkMutexLock *	Gate

evThreadedControllerMessage *	MessageListStart

evThreadedControllerMessage *	MessageListEnd

FILE *	LogFile

Protected Attributes inherited from evMultiProcessController
int	MaximumNumberOfProcesses

int	NumberOfProcesses

int	LocalProcessId

evProcessFunctionType	SingleMethod

void *	SingleData

evProcessFunctionType	MultipleMethod [VTK_MP_CONTROLLER_MAX_PROCESSES]

void *	MultipleData [VTK_MP_CONTROLLER_MAX_PROCESSES]

vtkCollection *	RMIs

char *	MarshalString

int	MarshalStringLength

int	MarshalDataLength

int	BreakFlag

float	ReadTime

float	WriteTime

float	SendWaitTime

float	SendTime

float	ReceiveWaitTime

float	ReceiveTime

int	ForceDeepCopy

int	Blocking

Constructor & Destructor Documentation

evThreadedController::evThreadedController ( )

protected

evThreadedController::~evThreadedController ( )

protected

evThreadedController::evThreadedController ( const evThreadedController & )

inlineprotected

Member Function Documentation

void evThreadedController::AddMessage ( evThreadedControllerMessage * message )

protected

void evThreadedController::Clear ( int remoteProcessId )

virtual

Implements evMultiProcessController.

void evThreadedController::ClearMessages ( int sendId )

protected

void evThreadedController::CreateProcessControllers ( )

protected

void evThreadedController::DeleteMessage ( evThreadedControllerMessage * message )

protected

evThreadedControllerMessage* evThreadedController::FindMessage	(	int	sendId,
		int	tag
	)

protected

evMultiProcessController* evThreadedController::GetLocalController ( )

protectedvirtual

Reimplemented from evMultiProcessController.

void evThreadedController::Initialize	(	int	argc,
		char *	arcv[]
	)

void evThreadedController::MultipleMethodExecute ( )

virtual

Implements evMultiProcessController.

static evThreadedController* evThreadedController::New ( )

static

evThreadedControllerMessage* evThreadedController::NewMessage	(	vtkDataObject *	object,
		void *	data,
		int	dataLength
	)

protected

void evThreadedController::operator= ( const evThreadedController & )

inlineprotected

void evThreadedController::PrintSelf	(	ostream &	os,
		vtkIndent	indent
	)

int evThreadedController::Receive	(	vtkDataObject *	data,
		int	remoteProcessId,
		int	tag
	)

virtual

Reimplemented from evMultiProcessController.

int evThreadedController::Receive	(	int *	data,
		int	length,
		int	remoteProcessId,
		int	tag
	)

virtual

Implements evMultiProcessController.

int evThreadedController::Receive	(	unsigned long *	data,
		int	length,
		int	remoteProcessId,
		int	tag
	)

virtual

Implements evMultiProcessController.

int evThreadedController::Receive	(	char *	data,
		int	length,
		int	remoteProcessId,
		int	tag
	)

virtual

Implements evMultiProcessController.

int evThreadedController::Receive	(	double *	data,
		int	length,
		int	remoteProcessId,
		int	tag
	)

virtual

Implements evMultiProcessController.

int evThreadedController::Receive	(	void **	data,
		int	remoteProcessId,
		int	tag
	)

int evThreadedController::Receive	(	vtkDataObject *	object,
		void *	data,
		int	dataLength,
		int	remoteProcessId,
		int	tag
	)

protected

void evThreadedController::RemoveMessage ( evThreadedControllerMessage * message )

protected

int evThreadedController::Send	(	vtkDataObject *	data,
		int	remoteProcessId,
		int	tag
	)

virtual

Reimplemented from evMultiProcessController.

int evThreadedController::Send	(	int *	data,
		int	length,
		int	remoteProcessId,
		int	tag
	)

virtual

Implements evMultiProcessController.

int evThreadedController::Send	(	unsigned long *	data,
		int	length,
		int	remoteProcessId,
		int	tag
	)

virtual

Implements evMultiProcessController.

int evThreadedController::Send	(	char *	data,
		int	length,
		int	remoteProcessId,
		int	tag
	)

virtual

Implements evMultiProcessController.

int evThreadedController::Send	(	double *	data,
		int	length,
		int	remoteProcessId,
		int	tag
	)

virtual

Implements evMultiProcessController.

int evThreadedController::Send	(	void **	data,
		int	remoteProcessId,
		int	tag
	)

int evThreadedController::Send	(	vtkDataObject *	object,
		void *	data,
		int	dataLength,
		int	remoteProcessId,
		int	tag
	)

protected

void evThreadedController::SingleMethodExecute ( )

virtual

Implements evMultiProcessController.

void evThreadedController::Start ( int threadIdx )

evThreadedController::vtkGetMacro	(	LocalProcessId	,
		int
	)

evThreadedController::vtkTypeMacro	(	evThreadedController	,
		evMultiProcessController
	)

Member Data Documentation

evThreadedController* evThreadedController::Controllers[VTK_MP_CONTROLLER_MAX_PROCESSES]

protected

vtkMutexLock* evThreadedController::Gate

protected

int evThreadedController::LocalProcessId

protected

FILE* evThreadedController::LogFile

protected

evThreadedControllerMessage* evThreadedController::MessageListEnd

protected

vtkMutexLock* evThreadedController::MessageListLock

protected

evThreadedControllerMessage* evThreadedController::MessageListStart

protected

int evThreadedController::MultipleMethodFlag

protected

vtkMultiThreader* evThreadedController::MultiThreader

protected

int evThreadedController::WaitingForId

protected

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

evThreadedController.h

Public Member Functions

Static Public Member Functions

Protected Member Functions

Protected Attributes

Constructor & Destructor Documentation

Member Function Documentation

Member Data Documentation