VTK
|
Process communication using Sockets. More...
#include <vtkSocketController.h>
Public Types | |
enum | Consts { ENDIAN_TAG =1010580540, IDTYPESIZE_TAG =1027423549, VERSION_TAG =1044266558, HASH_TAG =0x3f3f3f3f } |
typedef vtkMultiProcessController | Superclass |
![]() | |
enum | Errors { RMI_NO_ERROR, RMI_TAG_ERROR, RMI_ARG_ERROR } |
enum | Consts { ANY_SOURCE = -1, INVALID_SOURCE = -2 } |
enum | Tags { RMI_TAG = 1, RMI_ARG_TAG = 2, BREAK_RMI_TAG = 3, XML_WRITER_DATA_INFO = 4 } |
typedef vtkObject | Superclass |
Public Member Functions | |
virtual vtkTypeBool | IsA (const char *type) |
Return 1 if this class is the same type of (or a subclass of) the named class. More... | |
vtkSocketController * | NewInstance () const |
void | PrintSelf (ostream &os, vtkIndent indent) override |
Methods invoked by print to print information about the object including superclasses. More... | |
void | Initialize (int *argc, char ***argv, int) override |
This method is for initialiazing sockets. More... | |
void | Initialize (int *argc, char ***argv) override |
virtual void | Initialize () |
void | Finalize () override |
Does not apply to sockets. More... | |
void | Finalize (int) override |
This method is for cleaning up. More... | |
void | SingleMethodExecute () override |
Does not apply to sockets. More... | |
void | MultipleMethodExecute () override |
Does not apply to sockets. More... | |
void | CreateOutputWindow () override |
Does not apply to sockets. More... | |
virtual int | WaitForConnection (int port) |
Wait for connection on a given port, forwarded to the communicator. More... | |
virtual void | CloseConnection () |
Close a connection, forwarded to the communicator. More... | |
virtual int | ConnectTo (const char *hostName, int port) |
Open a connection to a give machine, forwarded to the communicator. More... | |
int | GetSwapBytesInReceivedData () |
void | SetCommunicator (vtkSocketCommunicator *comm) |
Set the communicator used in normal and rmi communications. More... | |
vtkMultiProcessController * | CreateCompliantController () |
FOOLISH MORTALS! Thou hast forsaken the sacred laws of ad-hoc polymorphism when thou broke a critical assumption of the superclass (namely, each process has thine own id). More... | |
![]() | |
vtkMultiProcessController * | NewInstance () const |
virtual void | Initialize (int *vtkNotUsed(argc), char ***vtkNotUsed(argv))=0 |
This method is for setting up the processes. More... | |
virtual void | Initialize (int *vtkNotUsed(argc), char ***vtkNotUsed(argv), int initializedExternally)=0 |
This method is for setting up the processes. More... | |
void | SetNumberOfProcesses (int num) |
Set the number of processes you will be using. More... | |
int | GetNumberOfProcesses () |
void | SetSingleMethod (vtkProcessFunctionType, void *data) |
Set the SingleMethod to f() and the UserData of the for the method to be executed by all of the processes when SingleMethodExecute is called. More... | |
void | SetSingleProcessObject (vtkProcess *p) |
Object-oriented flavor of SetSingleMethod(). More... | |
void | SetMultipleMethod (int index, vtkProcessFunctionType, void *data) |
Set the MultipleMethod to f() and the UserData of the for the method to be executed by the process index when MultipleMethodExecute is called. More... | |
int | GetLocalProcessId () |
Tells you which process [0, NumProcess) you are in. More... | |
virtual vtkMultiProcessController * | CreateSubController (vtkProcessGroup *group) |
Creates a new controller with the processes specified by the given group. More... | |
virtual vtkMultiProcessController * | PartitionController (int localColor, int localKey) |
Partitions this controller based on a coloring. More... | |
virtual unsigned long | AddRMI (vtkRMIFunctionType, void *localArg, int tag) |
Register remote method invocation in the receiving process which makes the call. More... | |
virtual int | RemoveFirstRMI (int tag) |
Remove the first RMI matching the tag. More... | |
virtual int | RemoveRMI (unsigned long id) |
Remove the RMI matching the id. More... | |
virtual void | RemoveRMI (vtkRMIFunctionType f, void *arg, int tag) |
Take an RMI away. More... | |
virtual unsigned long | AddRMICallback (vtkRMIFunctionType, void *localArg, int tag) |
These methods are a part of the newer API to add multiple rmi callbacks. More... | |
virtual void | RemoveAllRMICallbacks (int tag) |
These methods are a part of the newer API to add multiple rmi callbacks. More... | |
virtual bool | RemoveRMICallback (unsigned long id) |
Remove a callback. More... | |
void | TriggerRMI (int remoteProcessId, void *arg, int argLength, int tag) |
A method to trigger a method invocation in another process. More... | |
void | TriggerBreakRMIs () |
A convenience method. More... | |
void | TriggerRMI (int remoteProcessId, const char *arg, int tag) |
Convenience method when the arg is a string. More... | |
void | TriggerRMI (int remoteProcessId, int tag) |
Convenience method when there is no argument. More... | |
void | TriggerRMIOnAllChildren (void *arg, int argLength, int tag) |
This is a convenicence method to trigger an RMI call on all the "children" of the current node. More... | |
void | TriggerRMIOnAllChildren (const char *arg, int tag) |
void | TriggerRMIOnAllChildren (int tag) |
void | BroadcastTriggerRMIOnAllChildren (void *arg, int argLength, int tag) |
int | ProcessRMIs (int reportErrors, int dont_loop=0) |
Calling this method gives control to the controller to start processing RMIs. More... | |
int | ProcessRMIs () |
int | BroadcastProcessRMIs (int reportErrors, int dont_loop=0) |
virtual void | SetBreakFlag (int) |
Setting this flag to 1 will cause the ProcessRMIs loop to return. More... | |
virtual int | GetBreakFlag () |
virtual void | SetBroadcastTriggerRMI (bool) |
Setting this flag to 1 will cause the TriggerRMIOnAllChildren to use a collective broadcast operation to communicate the RMI tag to the satellites. More... | |
virtual bool | GetBroadcastTriggerRMI () |
virtual void | BroadcastTriggerRMIOn () |
virtual void | BroadcastTriggerRMIOff () |
virtual vtkCommunicator * | GetCommunicator () |
Returns the communicator associated with this controller. More... | |
void | Barrier () |
This method can be used to synchronize processes. More... | |
int | Send (const int *data, vtkIdType length, int remoteProcessId, int tag) |
This method sends data to another process. More... | |
int | Send (const short *data, vtkIdType length, int remoteProcessId, int tag) |
int | Send (const unsigned short *data, vtkIdType length, int remoteProcessId, int tag) |
int | Send (const unsigned int *data, vtkIdType length, int remoteProcessId, int tag) |
int | Send (const unsigned long *data, vtkIdType length, int remoteProcessId, int tag) |
int | Send (const long *data, vtkIdType length, int remoteProcessId, int tag) |
int | Send (const signed char *data, vtkIdType length, int remoteProcessId, int tag) |
int | Send (const char *data, vtkIdType length, int remoteProcessId, int tag) |
int | Send (const unsigned char *data, vtkIdType length, int remoteProcessId, int tag) |
int | Send (const float *data, vtkIdType length, int remoteProcessId, int tag) |
int | Send (const double *data, vtkIdType length, int remoteProcessId, int tag) |
int | Send (const long long *data, vtkIdType length, int remoteProcessId, int tag) |
int | Send (const unsigned long long *data, vtkIdType length, int remoteProcessId, int tag) |
int | Send (vtkDataObject *data, int remoteId, int tag) |
int | Send (vtkDataArray *data, int remoteId, int tag) |
int | Send (const vtkMultiProcessStream &stream, int remoteId, int tag) |
Send a stream to another process. More... | |
int | Receive (int *data, vtkIdType maxlength, int remoteProcessId, int tag) |
This method receives data from a corresponding send. More... | |
int | Receive (unsigned int *data, vtkIdType maxlength, int remoteProcessId, int tag) |
int | Receive (short *data, vtkIdType maxlength, int remoteProcessId, int tag) |
int | Receive (unsigned short *data, vtkIdType maxlength, int remoteProcessId, int tag) |
int | Receive (long *data, vtkIdType maxlength, int remoteProcessId, int tag) |
int | Receive (unsigned long *data, vtkIdType maxlength, int remoteProcessId, int tag) |
int | Receive (char *data, vtkIdType maxlength, int remoteProcessId, int tag) |
int | Receive (unsigned char *data, vtkIdType maxlength, int remoteProcessId, int tag) |
int | Receive (signed char *data, vtkIdType maxlength, int remoteProcessId, int tag) |
int | Receive (float *data, vtkIdType maxlength, int remoteProcessId, int tag) |
int | Receive (double *data, vtkIdType maxlength, int remoteProcessId, int tag) |
int | Receive (long long *data, vtkIdType maxLength, int remoteProcessId, int tag) |
int | Receive (unsigned long long *data, vtkIdType maxLength, int remoteProcessId, int tag) |
int | Receive (vtkDataObject *data, int remoteId, int tag) |
int | Receive (vtkDataArray *data, int remoteId, int tag) |
int | Receive (vtkMultiProcessStream &stream, int remoteId, int tag) |
Receive a stream from the other processes. More... | |
vtkDataObject * | ReceiveDataObject (int remoteId, int tag) |
vtkIdType | GetCount () |
Returns the number of words received by the most recent Receive(). More... | |
int | Broadcast (int *data, vtkIdType length, int srcProcessId) |
Broadcast sends the array in the process with id srcProcessId to all of the other processes. More... | |
int | Broadcast (unsigned int *data, vtkIdType length, int srcProcessId) |
int | Broadcast (short *data, vtkIdType length, int srcProcessId) |
int | Broadcast (unsigned short *data, vtkIdType length, int srcProcessId) |
int | Broadcast (long *data, vtkIdType length, int srcProcessId) |
int | Broadcast (unsigned long *data, vtkIdType length, int srcProcessId) |
int | Broadcast (unsigned char *data, vtkIdType length, int srcProcessId) |
int | Broadcast (char *data, vtkIdType length, int srcProcessId) |
int | Broadcast (signed char *data, vtkIdType length, int srcProcessId) |
int | Broadcast (float *data, vtkIdType length, int srcProcessId) |
int | Broadcast (double *data, vtkIdType length, int srcProcessId) |
int | Broadcast (long long *data, vtkIdType length, int srcProcessId) |
int | Broadcast (unsigned long long *data, vtkIdType length, int srcProcessId) |
int | Broadcast (vtkDataObject *data, int srcProcessId) |
int | Broadcast (vtkDataArray *data, int srcProcessId) |
int | Broadcast (vtkMultiProcessStream &stream, int srcProcessId) |
int | Gather (const int *sendBuffer, int *recvBuffer, vtkIdType length, int destProcessId) |
Gather collects arrays in the process with id destProcessId . More... | |
int | Gather (const unsigned int *sendBuffer, unsigned int *recvBuffer, vtkIdType length, int destProcessId) |
int | Gather (const short *sendBuffer, short *recvBuffer, vtkIdType length, int destProcessId) |
int | Gather (const unsigned short *sendBuffer, unsigned short *recvBuffer, vtkIdType length, int destProcessId) |
int | Gather (const long *sendBuffer, long *recvBuffer, vtkIdType length, int destProcessId) |
int | Gather (const unsigned long *sendBuffer, unsigned long *recvBuffer, vtkIdType length, int destProcessId) |
int | Gather (const unsigned char *sendBuffer, unsigned char *recvBuffer, vtkIdType length, int destProcessId) |
int | Gather (const char *sendBuffer, char *recvBuffer, vtkIdType length, int destProcessId) |
int | Gather (const signed char *sendBuffer, signed char *recvBuffer, vtkIdType length, int destProcessId) |
int | Gather (const float *sendBuffer, float *recvBuffer, vtkIdType length, int destProcessId) |
int | Gather (const double *sendBuffer, double *recvBuffer, vtkIdType length, int destProcessId) |
int | Gather (const long long *sendBuffer, long long *recvBuffer, vtkIdType length, int destProcessId) |
int | Gather (const unsigned long long *sendBuffer, unsigned long long *recvBuffer, vtkIdType length, int destProcessId) |
int | Gather (vtkDataArray *sendBuffer, vtkDataArray *recvBuffer, int destProcessId) |
int | Gather (vtkDataObject *sendBuffer, std::vector< vtkSmartPointer< vtkDataObject > > &recvBuffer, int destProcessId) |
Gathers vtkDataObject (sendBuffer ) from all ranks to the destProcessId . More... | |
int | GatherV (const int *sendBuffer, int *recvBuffer, vtkIdType sendLength, vtkIdType *recvLengths, vtkIdType *offsets, int destProcessId) |
GatherV is the vector variant of Gather. More... | |
int | GatherV (const unsigned int *sendBuffer, unsigned int *recvBuffer, vtkIdType sendLength, vtkIdType *recvLengths, vtkIdType *offsets, int destProcessId) |
int | GatherV (const short *sendBuffer, short *recvBuffer, vtkIdType sendLength, vtkIdType *recvLengths, vtkIdType *offsets, int destProcessId) |
int | GatherV (const unsigned short *sendBuffer, unsigned short *recvBuffer, vtkIdType sendLength, vtkIdType *recvLengths, vtkIdType *offsets, int destProcessId) |
int | GatherV (const long *sendBuffer, long *recvBuffer, vtkIdType sendLength, vtkIdType *recvLengths, vtkIdType *offsets, int destProcessId) |
int | GatherV (const unsigned long *sendBuffer, unsigned long *recvBuffer, vtkIdType sendLength, vtkIdType *recvLengths, vtkIdType *offsets, int destProcessId) |
int | GatherV (const unsigned char *sendBuffer, unsigned char *recvBuffer, vtkIdType sendLength, vtkIdType *recvLengths, vtkIdType *offsets, int destProcessId) |
int | GatherV (const char *sendBuffer, char *recvBuffer, vtkIdType sendLength, vtkIdType *recvLengths, vtkIdType *offsets, int destProcessId) |
int | GatherV (const signed char *sendBuffer, signed char *recvBuffer, vtkIdType sendLength, vtkIdType *recvLengths, vtkIdType *offsets, int destProcessId) |
int | GatherV (const float *sendBuffer, float *recvBuffer, vtkIdType sendLength, vtkIdType *recvLengths, vtkIdType *offsets, int destProcessId) |
int | GatherV (const double *sendBuffer, double *recvBuffer, vtkIdType sendLength, vtkIdType *recvLengths, vtkIdType *offsets, int destProcessId) |
int | GatherV (const long long *sendBuffer, long long *recvBuffer, vtkIdType sendLength, vtkIdType *recvLengths, vtkIdType *offsets, int destProcessId) |
int | GatherV (const unsigned long long *sendBuffer, unsigned long long *recvBuffer, vtkIdType sendLength, vtkIdType *recvLengths, vtkIdType *offsets, int destProcessId) |
int | GatherV (vtkDataArray *sendBuffer, vtkDataArray *recvBuffer, vtkIdType *recvLengths, vtkIdType *offsets, int destProcessId) |
int | GatherV (vtkDataArray *sendBuffer, vtkDataArray *recvBuffer, vtkIdTypeArray *recvLengths, vtkIdTypeArray *offsets, int destProcessId) |
int | GatherV (vtkDataArray *sendBuffer, vtkDataArray *recvBuffer, int destProcessId) |
This special form of GatherV will automatically determine recvLengths and offsets to tightly pack the data in the recvBuffer in process order. More... | |
int | GatherV (vtkDataObject *sendData, vtkSmartPointer< vtkDataObject > *recvData, int destProcessId) |
int | Scatter (const int *sendBuffer, int *recvBuffer, vtkIdType length, int srcProcessId) |
Scatter takes an array in the process with id srcProcessId and distributes it. More... | |
int | Scatter (const unsigned int *sendBuffer, unsigned int *recvBuffer, vtkIdType length, int srcProcessId) |
int | Scatter (const short *sendBuffer, short *recvBuffer, vtkIdType length, int srcProcessId) |
int | Scatter (const unsigned short *sendBuffer, unsigned short *recvBuffer, vtkIdType length, int srcProcessId) |
int | Scatter (const long *sendBuffer, long *recvBuffer, vtkIdType length, int srcProcessId) |
int | Scatter (const unsigned long *sendBuffer, unsigned long *recvBuffer, vtkIdType length, int srcProcessId) |
int | Scatter (const unsigned char *sendBuffer, unsigned char *recvBuffer, vtkIdType length, int srcProcessId) |
int | Scatter (const char *sendBuffer, char *recvBuffer, vtkIdType length, int srcProcessId) |
int | Scatter (const signed char *sendBuffer, signed char *recvBuffer, vtkIdType length, int srcProcessId) |
int | Scatter (const float *sendBuffer, float *recvBuffer, vtkIdType length, int srcProcessId) |
int | Scatter (const double *sendBuffer, double *recvBuffer, vtkIdType length, int srcProcessId) |
int | Scatter (const long long *sendBuffer, long long *recvBuffer, vtkIdType length, int srcProcessId) |
int | Scatter (const unsigned long long *sendBuffer, unsigned long long *recvBuffer, vtkIdType length, int srcProcessId) |
int | Scatter (vtkDataArray *sendBuffer, vtkDataArray *recvBuffer, int srcProcessId) |
int | ScatterV (const int *sendBuffer, int *recvBuffer, vtkIdType *sendLengths, vtkIdType *offsets, vtkIdType recvLength, int srcProcessId) |
ScatterV is the vector variant of Scatter. More... | |
int | ScatterV (const unsigned int *sendBuffer, unsigned int *recvBuffer, vtkIdType *sendLengths, vtkIdType *offsets, vtkIdType recvLength, int srcProcessId) |
int | ScatterV (const short *sendBuffer, short *recvBuffer, vtkIdType *sendLengths, vtkIdType *offsets, vtkIdType recvLength, int srcProcessId) |
int | ScatterV (const unsigned short *sendBuffer, unsigned short *recvBuffer, vtkIdType *sendLengths, vtkIdType *offsets, vtkIdType recvLength, int srcProcessId) |
int | ScatterV (const long *sendBuffer, long *recvBuffer, vtkIdType *sendLengths, vtkIdType *offsets, vtkIdType recvLength, int srcProcessId) |
int | ScatterV (const unsigned long *sendBuffer, unsigned long *recvBuffer, vtkIdType *sendLengths, vtkIdType *offsets, vtkIdType recvLength, int srcProcessId) |
int | ScatterV (const unsigned char *sendBuffer, unsigned char *recvBuffer, vtkIdType *sendLengths, vtkIdType *offsets, vtkIdType recvLength, int srcProcessId) |
int | ScatterV (const char *sendBuffer, char *recvBuffer, vtkIdType *sendLengths, vtkIdType *offsets, vtkIdType recvLength, int srcProcessId) |
int | ScatterV (const signed char *sendBuffer, signed char *recvBuffer, vtkIdType *sendLengths, vtkIdType *offsets, vtkIdType recvLength, int srcProcessId) |
int | ScatterV (const float *sendBuffer, float *recvBuffer, vtkIdType *sendLengths, vtkIdType *offsets, vtkIdType recvLength, int srcProcessId) |
int | ScatterV (const double *sendBuffer, double *recvBuffer, vtkIdType *sendLengths, vtkIdType *offsets, vtkIdType recvLength, int srcProcessId) |
int | ScatterV (const long long *sendBuffer, long long *recvBuffer, vtkIdType *sendLengths, vtkIdType *offsets, vtkIdType recvLength, int srcProcessId) |
int | ScatterV (const unsigned long long *sendBuffer, unsigned long long *recvBuffer, vtkIdType *sendLengths, vtkIdType *offsets, vtkIdType recvLength, int srcProcessId) |
int | AllGather (const int *sendBuffer, int *recvBuffer, vtkIdType length) |
Same as gather except that the result ends up on all processes. More... | |
int | AllGather (const unsigned int *sendBuffer, unsigned int *recvBuffer, vtkIdType length) |
int | AllGather (const short *sendBuffer, short *recvBuffer, vtkIdType length) |
int | AllGather (const unsigned short *sendBuffer, unsigned short *recvBuffer, vtkIdType length) |
int | AllGather (const long *sendBuffer, long *recvBuffer, vtkIdType length) |
int | AllGather (const unsigned long *sendBuffer, unsigned long *recvBuffer, vtkIdType length) |
int | AllGather (const unsigned char *sendBuffer, unsigned char *recvBuffer, vtkIdType length) |
int | AllGather (const char *sendBuffer, char *recvBuffer, vtkIdType length) |
int | AllGather (const signed char *sendBuffer, signed char *recvBuffer, vtkIdType length) |
int | AllGather (const float *sendBuffer, float *recvBuffer, vtkIdType length) |
int | AllGather (const double *sendBuffer, double *recvBuffer, vtkIdType length) |
int | AllGather (const long long *sendBuffer, long long *recvBuffer, vtkIdType length) |
int | AllGather (const unsigned long long *sendBuffer, unsigned long long *recvBuffer, vtkIdType length) |
int | AllGather (vtkDataArray *sendBuffer, vtkDataArray *recvBuffer) |
int | AllGatherV (const int *sendBuffer, int *recvBuffer, vtkIdType sendLength, vtkIdType *recvLengths, vtkIdType *offsets) |
Same as GatherV except that the result is placed in all processes. More... | |
int | AllGatherV (const unsigned int *sendBuffer, unsigned int *recvBuffer, vtkIdType sendLength, vtkIdType *recvLengths, vtkIdType *offsets) |
int | AllGatherV (const short *sendBuffer, short *recvBuffer, vtkIdType sendLength, vtkIdType *recvLengths, vtkIdType *offsets) |
int | AllGatherV (const unsigned short *sendBuffer, unsigned short *recvBuffer, vtkIdType sendLength, vtkIdType *recvLengths, vtkIdType *offsets) |
int | AllGatherV (const long *sendBuffer, long *recvBuffer, vtkIdType sendLength, vtkIdType *recvLengths, vtkIdType *offsets) |
int | AllGatherV (const unsigned long *sendBuffer, unsigned long *recvBuffer, vtkIdType sendLength, vtkIdType *recvLengths, vtkIdType *offsets) |
int | AllGatherV (const unsigned char *sendBuffer, unsigned char *recvBuffer, vtkIdType sendLength, vtkIdType *recvLengths, vtkIdType *offsets) |
int | AllGatherV (const char *sendBuffer, char *recvBuffer, vtkIdType sendLength, vtkIdType *recvLengths, vtkIdType *offsets) |
int | AllGatherV (const signed char *sendBuffer, signed char *recvBuffer, vtkIdType sendLength, vtkIdType *recvLengths, vtkIdType *offsets) |
int | AllGatherV (const float *sendBuffer, float *recvBuffer, vtkIdType sendLength, vtkIdType *recvLengths, vtkIdType *offsets) |
int | AllGatherV (const double *sendBuffer, double *recvBuffer, vtkIdType sendLength, vtkIdType *recvLengths, vtkIdType *offsets) |
int | AllGatherV (const long long *sendBuffer, long long *recvBuffer, vtkIdType sendLength, vtkIdType *recvLengths, vtkIdType *offsets) |
int | AllGatherV (const unsigned long long *sendBuffer, unsigned long long *recvBuffer, vtkIdType sendLength, vtkIdType *recvLengths, vtkIdType *offsets) |
int | AllGatherV (vtkDataArray *sendBuffer, vtkDataArray *recvBuffer, vtkIdType *recvLengths, vtkIdType *offsets) |
int | AllGatherV (vtkDataArray *sendBuffer, vtkDataArray *recvBuffer) |
This special form of AllGatherV will automatically determine recvLengths and offsets to tightly pack the data in the recvBuffer in process order. More... | |
int | Reduce (const int *sendBuffer, int *recvBuffer, vtkIdType length, int operation, int destProcessId) |
Reduce an array to the given destination process. More... | |
int | Reduce (const unsigned int *sendBuffer, unsigned int *recvBuffer, vtkIdType length, int operation, int destProcessId) |
int | Reduce (const short *sendBuffer, short *recvBuffer, vtkIdType length, int operation, int destProcessId) |
int | Reduce (const unsigned short *sendBuffer, unsigned short *recvBuffer, vtkIdType length, int operation, int destProcessId) |
int | Reduce (const long *sendBuffer, long *recvBuffer, vtkIdType length, int operation, int destProcessId) |
int | Reduce (const unsigned long *sendBuffer, unsigned long *recvBuffer, vtkIdType length, int operation, int destProcessId) |
int | Reduce (const unsigned char *sendBuffer, unsigned char *recvBuffer, vtkIdType length, int operation, int destProcessId) |
int | Reduce (const char *sendBuffer, char *recvBuffer, vtkIdType length, int operation, int destProcessId) |
int | Reduce (const signed char *sendBuffer, signed char *recvBuffer, vtkIdType length, int operation, int destProcessId) |
int | Reduce (const float *sendBuffer, float *recvBuffer, vtkIdType length, int operation, int destProcessId) |
int | Reduce (const double *sendBuffer, double *recvBuffer, vtkIdType length, int operation, int destProcessId) |
int | Reduce (const long long *sendBuffer, long long *recvBuffer, vtkIdType length, int operation, int destProcessId) |
int | Reduce (const unsigned long long *sendBuffer, unsigned long long *recvBuffer, vtkIdType length, int operation, int destProcessId) |
int | Reduce (vtkDataArray *sendBuffer, vtkDataArray *recvBuffer, int operation, int destProcessId) |
int | Reduce (const int *sendBuffer, int *recvBuffer, vtkIdType length, vtkCommunicator::Operation *operation, int destProcessId) |
Reduce an array to the given destination process. More... | |
int | Reduce (const unsigned int *sendBuffer, unsigned int *recvBuffer, vtkIdType length, vtkCommunicator::Operation *operation, int destProcessId) |
int | Reduce (const short *sendBuffer, short *recvBuffer, vtkIdType length, vtkCommunicator::Operation *operation, int destProcessId) |
int | Reduce (const unsigned short *sendBuffer, unsigned short *recvBuffer, vtkIdType length, vtkCommunicator::Operation *operation, int destProcessId) |
int | Reduce (const long *sendBuffer, long *recvBuffer, vtkIdType length, vtkCommunicator::Operation *operation, int destProcessId) |
int | Reduce (const unsigned long *sendBuffer, unsigned long *recvBuffer, vtkIdType length, vtkCommunicator::Operation *operation, int destProcessId) |
int | Reduce (const unsigned char *sendBuffer, unsigned char *recvBuffer, vtkIdType length, vtkCommunicator::Operation *operation, int destProcessId) |
int | Reduce (const char *sendBuffer, char *recvBuffer, vtkIdType length, vtkCommunicator::Operation *operation, int destProcessId) |
int | Reduce (const signed char *sendBuffer, signed char *recvBuffer, vtkIdType length, vtkCommunicator::Operation *operation, int destProcessId) |
int | Reduce (const float *sendBuffer, float *recvBuffer, vtkIdType length, vtkCommunicator::Operation *operation, int destProcessId) |
int | Reduce (const double *sendBuffer, double *recvBuffer, vtkIdType length, vtkCommunicator::Operation *operation, int destProcessId) |
int | Reduce (const long long *sendBuffer, long long *recvBuffer, vtkIdType length, vtkCommunicator::Operation *operation, int destProcessId) |
int | Reduce (const unsigned long long *sendBuffer, unsigned long long *recvBuffer, vtkIdType length, vtkCommunicator::Operation *operation, int destProcessId) |
int | Reduce (vtkDataArray *sendBuffer, vtkDataArray *recvBuffer, vtkCommunicator::Operation *operation, int destProcessId) |
int | AllReduce (const int *sendBuffer, int *recvBuffer, vtkIdType length, int operation) |
Same as Reduce except that the result is placed in all of the processes. More... | |
int | AllReduce (const unsigned int *sendBuffer, unsigned int *recvBuffer, vtkIdType length, int operation) |
int | AllReduce (const short *sendBuffer, short *recvBuffer, vtkIdType length, int operation) |
int | AllReduce (const unsigned short *sendBuffer, unsigned short *recvBuffer, vtkIdType length, int operation) |
int | AllReduce (const long *sendBuffer, long *recvBuffer, vtkIdType length, int operation) |
int | AllReduce (const unsigned long *sendBuffer, unsigned long *recvBuffer, vtkIdType length, int operation) |
int | AllReduce (const unsigned char *sendBuffer, unsigned char *recvBuffer, vtkIdType length, int operation) |
int | AllReduce (const char *sendBuffer, char *recvBuffer, vtkIdType length, int operation) |
int | AllReduce (const signed char *sendBuffer, signed char *recvBuffer, vtkIdType length, int operation) |
int | AllReduce (const float *sendBuffer, float *recvBuffer, vtkIdType length, int operation) |
int | AllReduce (const double *sendBuffer, double *recvBuffer, vtkIdType length, int operation) |
int | AllReduce (const long long *sendBuffer, long long *recvBuffer, vtkIdType length, int operation) |
int | AllReduce (const unsigned long long *sendBuffer, unsigned long long *recvBuffer, vtkIdType length, int operation) |
int | AllReduce (vtkDataArray *sendBuffer, vtkDataArray *recvBuffer, int operation) |
int | AllReduce (const int *sendBuffer, int *recvBuffer, vtkIdType length, vtkCommunicator::Operation *operation) |
int | AllReduce (const unsigned int *sendBuffer, unsigned int *recvBuffer, vtkIdType length, vtkCommunicator::Operation *operation) |
int | AllReduce (const short *sendBuffer, short *recvBuffer, vtkIdType length, vtkCommunicator::Operation *operation) |
int | AllReduce (const unsigned short *sendBuffer, unsigned short *recvBuffer, vtkIdType length, vtkCommunicator::Operation *operation) |
int | AllReduce (const long *sendBuffer, long *recvBuffer, vtkIdType length, vtkCommunicator::Operation *operation) |
int | AllReduce (const unsigned long *sendBuffer, unsigned long *recvBuffer, vtkIdType length, vtkCommunicator::Operation *operation) |
int | AllReduce (const unsigned char *sendBuffer, unsigned char *recvBuffer, vtkIdType length, vtkCommunicator::Operation *operation) |
int | AllReduce (const char *sendBuffer, char *recvBuffer, vtkIdType length, vtkCommunicator::Operation *operation) |
int | AllReduce (const signed char *sendBuffer, signed char *recvBuffer, vtkIdType length, vtkCommunicator::Operation *operation) |
int | AllReduce (const float *sendBuffer, float *recvBuffer, vtkIdType length, vtkCommunicator::Operation *operation) |
int | AllReduce (const double *sendBuffer, double *recvBuffer, vtkIdType length, vtkCommunicator::Operation *operation) |
int | AllReduce (const long long *sendBuffer, long long *recvBuffer, vtkIdType length, vtkCommunicator::Operation *operation) |
int | AllReduce (const unsigned long long *sendBuffer, unsigned long long *recvBuffer, vtkIdType length, vtkCommunicator::Operation *operation) |
int | AllReduce (vtkDataArray *sendBuffer, vtkDataArray *recvBuffer, vtkCommunicator::Operation *operation) |
![]() | |
vtkBaseTypeMacro (vtkObject, vtkObjectBase) | |
virtual void | DebugOn () |
Turn debugging output on. More... | |
virtual void | DebugOff () |
Turn debugging output off. More... | |
bool | GetDebug () |
Get the value of the debug flag. More... | |
void | SetDebug (bool debugFlag) |
Set the value of the debug flag. More... | |
virtual void | Modified () |
Update the modification time for this object. More... | |
virtual vtkMTimeType | GetMTime () |
Return this object's modified time. More... | |
unsigned long | AddObserver (unsigned long event, vtkCommand *, float priority=0.0f) |
Allow people to add/remove/invoke observers (callbacks) to any VTK object. More... | |
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 *) |
vtkTypeBool | HasObserver (unsigned long event, vtkCommand *) |
vtkTypeBool | HasObserver (const char *event, vtkCommand *) |
void | RemoveObserver (unsigned long tag) |
void | RemoveObservers (unsigned long event) |
void | RemoveObservers (const char *event) |
void | RemoveAllObservers () |
vtkTypeBool | HasObserver (unsigned long event) |
vtkTypeBool | HasObserver (const char *event) |
template<class U , class T > | |
unsigned long | AddObserver (unsigned long event, U observer, void(T::*callback)(), float priority=0.0f) |
Overloads to AddObserver that allow developers to add class member functions as callbacks for events. More... | |
template<class U , class T > | |
unsigned long | AddObserver (unsigned long event, U observer, void(T::*callback)(vtkObject *, unsigned long, void *), float priority=0.0f) |
template<class U , class T > | |
unsigned long | AddObserver (unsigned long event, U observer, bool(T::*callback)(vtkObject *, unsigned long, void *), float priority=0.0f) |
Allow user to set the AbortFlagOn() with the return value of the callback method. More... | |
int | InvokeEvent (unsigned long event, void *callData) |
This method invokes an event and return whether the event was aborted or not. More... | |
int | InvokeEvent (const char *event, void *callData) |
int | InvokeEvent (unsigned long event) |
int | InvokeEvent (const char *event) |
![]() | |
const char * | GetClassName () const |
Return the class name as a string. More... | |
virtual void | Delete () |
Delete a VTK object. More... | |
virtual void | FastDelete () |
Delete a reference to this object. More... | |
void | InitializeObjectBase () |
void | Print (ostream &os) |
Print an object to an ostream. More... | |
virtual void | PrintHeader (ostream &os, vtkIndent indent) |
virtual void | PrintTrailer (ostream &os, vtkIndent indent) |
virtual void | Register (vtkObjectBase *o) |
Increase the reference count (mark as used by another object). More... | |
virtual void | UnRegister (vtkObjectBase *o) |
Decrease the reference count (release by another object). More... | |
int | GetReferenceCount () |
Return the current reference count of this object. More... | |
void | SetReferenceCount (int) |
Sets the reference count. More... | |
void | PrintRevisions (ostream &) |
Legacy. More... | |
Static Public Member Functions | |
static vtkSocketController * | New () |
static vtkTypeBool | IsTypeOf (const char *type) |
static vtkSocketController * | SafeDownCast (vtkObjectBase *o) |
![]() | |
static vtkTypeBool | IsTypeOf (const char *type) |
static vtkMultiProcessController * | SafeDownCast (vtkObjectBase *o) |
static vtkMultiProcessController * | GetGlobalController () |
This convenience method returns the controller associated with the local process. More... | |
static int | GetBreakRMITag () |
Accessor to some default tags. More... | |
static int | GetRMITag () |
static int | GetRMIArgTag () |
static void | SetGlobalController (vtkMultiProcessController *controller) |
![]() | |
static vtkObject * | New () |
Create an object with Debug turned off, modified time initialized to zero, and reference counting on. More... | |
static void | BreakOnError () |
This method is called when vtkErrorMacro executes. More... | |
static void | SetGlobalWarningDisplay (int val) |
This is a global flag that controls whether any debug, warning or error messages are displayed. More... | |
static void | GlobalWarningDisplayOn () |
static void | GlobalWarningDisplayOff () |
static int | GetGlobalWarningDisplay () |
![]() | |
static vtkTypeBool | IsTypeOf (const char *name) |
Return 1 if this class type is the same type of (or a subclass of) the named class. More... | |
static vtkObjectBase * | New () |
Create an object with Debug turned off, modified time initialized to zero, and reference counting on. More... | |
Protected Member Functions | |
virtual vtkObjectBase * | NewInstanceInternal () const |
vtkSocketController () | |
~vtkSocketController () override | |
![]() | |
vtkMultiProcessController () | |
~vtkMultiProcessController () override | |
virtual void | TriggerRMIInternal (int remoteProcessId, void *arg, int argLength, int rmiTag, bool propagate) |
Implementation for TriggerRMI() provides subclasses an opportunity to modify the behaviour eg. More... | |
void | GetMultipleMethod (int index, vtkProcessFunctionType &func, void *&data) |
void | ProcessRMI (int remoteProcessId, void *arg, int argLength, int rmiTag) |
virtual vtkMultiProcessController * | GetLocalController () |
![]() | |
vtkObject () | |
~vtkObject () override | |
void | RegisterInternal (vtkObjectBase *, vtkTypeBool check) override |
void | UnRegisterInternal (vtkObjectBase *, vtkTypeBool check) override |
void | InternalGrabFocus (vtkCommand *mouseEvents, vtkCommand *keypressEvents=nullptr) |
These methods allow a command to exclusively grab all events. More... | |
void | InternalReleaseFocus () |
![]() | |
vtkObjectBase () | |
virtual | ~vtkObjectBase () |
virtual void | CollectRevisions (ostream &) |
virtual void | ReportReferences (vtkGarbageCollector *) |
vtkObjectBase (const vtkObjectBase &) | |
void | operator= (const vtkObjectBase &) |
Static Protected Attributes | |
static int | Initialized |
Additional Inherited Members | |
![]() | |
vtkProcessFunctionType | SingleMethod |
void * | SingleData |
int | BreakFlag |
int | ForceDeepCopy |
bool | BroadcastTriggerRMI |
vtkOutputWindow * | OutputWindow |
vtkCommunicator * | Communicator |
vtkCommunicator * | RMICommunicator |
![]() | |
bool | Debug |
vtkTimeStamp | MTime |
vtkSubjectHelper * | SubjectHelper |
![]() | |
vtkAtomicInt32 | ReferenceCount |
vtkWeakPointerBase ** | WeakPointers |
Process communication using Sockets.
This is a concrete implementation of vtkMultiProcessController. It supports one-to-one communication using sockets. Note that process 0 will always correspond to self and process 1 to the remote process. This class is best used with ports.
Definition at line 52 of file vtkSocketController.h.
Definition at line 56 of file vtkSocketController.h.
Enumerator | |
---|---|
ENDIAN_TAG | |
IDTYPESIZE_TAG | |
VERSION_TAG | |
HASH_TAG |
Definition at line 126 of file vtkSocketController.h.
|
protected |
|
overrideprotected |
|
static |
|
static |
|
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 vtkMultiProcessController.
|
static |
|
protectedvirtual |
Reimplemented from vtkMultiProcessController.
vtkSocketController* vtkSocketController::NewInstance | ( | ) | const |
|
overridevirtual |
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 vtkMultiProcessController.
This method is for initialiazing sockets.
One of these is REQUIRED for Windows.
Definition at line 63 of file vtkSocketController.h.
|
override |
|
inlinevirtual |
Definition at line 66 of file vtkSocketController.h.
|
inlineoverridevirtual |
Does not apply to sockets.
Does nothing.
Implements vtkMultiProcessController.
Definition at line 72 of file vtkSocketController.h.
|
inlineoverridevirtual |
This method is for cleaning up.
If a subclass needs to clean up process communication (i.e. MPI) it would over ride this method. Provided for finalization outside vtk.
Implements vtkMultiProcessController.
Definition at line 73 of file vtkSocketController.h.
|
inlineoverridevirtual |
Does not apply to sockets.
Does nothing.
Implements vtkMultiProcessController.
Definition at line 78 of file vtkSocketController.h.
|
inlineoverridevirtual |
Does not apply to sockets.
Does nothing.
Implements vtkMultiProcessController.
Definition at line 83 of file vtkSocketController.h.
|
inlineoverridevirtual |
Does not apply to sockets.
Does nothing.
Implements vtkMultiProcessController.
Definition at line 88 of file vtkSocketController.h.
Wait for connection on a given port, forwarded to the communicator.
|
virtual |
Close a connection, forwarded to the communicator.
Open a connection to a give machine, forwarded to the communicator.
int vtkSocketController::GetSwapBytesInReceivedData | ( | ) |
void vtkSocketController::SetCommunicator | ( | vtkSocketCommunicator * | comm | ) |
Set the communicator used in normal and rmi communications.
vtkMultiProcessController* vtkSocketController::CreateCompliantController | ( | ) |
FOOLISH MORTALS! Thou hast forsaken the sacred laws of ad-hoc polymorphism when thou broke a critical assumption of the superclass (namely, each process has thine own id).
The time frame to fix thy error has passed. Too much code has come to rely on this abhorrent behavior. Instead, we offer this gift: a method for creating an equivalent communicator with correct process id semantics. The calling code is responsible for deleting this controller.
|
staticprotected |
Definition at line 139 of file vtkSocketController.h.