VTK
|
Used to send/receive messages in a multiprocess environment. More...
#include <vtkCommunicator.h>
Classes | |
class | Operation |
Public Types | |
enum | Tags { BROADCAST_TAG = 10, GATHER_TAG = 11, GATHERV_TAG = 12, SCATTER_TAG = 13, SCATTERV_TAG = 14, REDUCE_TAG = 15, BARRIER_TAG = 16 } |
enum | StandardOperations { MAX_OP, MIN_OP, SUM_OP, PRODUCT_OP, LOGICAL_AND_OP, BITWISE_AND_OP, LOGICAL_OR_OP, BITWISE_OR_OP, LOGICAL_XOR_OP, BITWISE_XOR_OP } |
typedef vtkObject | Superclass |
![]() | |
typedef vtkObjectBase | Superclass |
Public Member Functions | |
virtual const char * | GetClassName () |
virtual int | IsA (const char *type) |
void | PrintSelf (ostream &os, vtkIndent indent) |
int | Receive (vtkDataObject *data, int remoteHandle, int tag) |
vtkDataObject * | ReceiveDataObject (int remoteHandle, int tag) |
int | Receive (vtkDataArray *data, int remoteHandle, int tag) |
virtual void | Barrier () |
virtual void | SetNumberOfProcesses (int num) |
virtual int | GetNumberOfProcesses () |
virtual int | GetLocalProcessId () |
int | Send (vtkDataObject *data, int remoteHandle, int tag) |
int | Send (vtkDataArray *data, int remoteHandle, int tag) |
virtual int | SendVoidArray (const void *data, vtkIdType length, int type, int remoteHandle, int tag)=0 |
int | Send (const int *data, vtkIdType length, int remoteHandle, int tag) |
int | Send (const unsigned int *data, vtkIdType length, int remoteHandle, int tag) |
int | Send (const unsigned long *data, vtkIdType length, int remoteHandle, int tag) |
int | Send (const unsigned char *data, vtkIdType length, int remoteHandle, int tag) |
int | Send (const char *data, vtkIdType length, int remoteHandle, int tag) |
int | Send (const float *data, vtkIdType length, int remoteHandle, int tag) |
int | Send (const double *data, vtkIdType length, int remoteHandle, int tag) |
int | Send (const vtkMultiProcessStream &stream, int remoteId, int tag) |
virtual int | ReceiveVoidArray (void *data, vtkIdType maxlength, int type, int remoteHandle, int tag)=0 |
int | Receive (int *data, vtkIdType maxlength, int remoteHandle, int tag) |
int | Receive (unsigned int *data, vtkIdType maxlength, int remoteHandle, int tag) |
int | Receive (unsigned long *data, vtkIdType maxlength, int remoteHandle, int tag) |
int | Receive (unsigned char *data, vtkIdType maxlength, int remoteHandle, int tag) |
int | Receive (char *data, vtkIdType maxlength, int remoteHandle, int tag) |
int | Receive (float *data, vtkIdType maxlength, int remoteHandle, int tag) |
int | Receive (double *data, vtkIdType maxlength, int remoteHandle, int tag) |
int | Receive (vtkMultiProcessStream &stream, int remoteId, int tag) |
virtual vtkIdType | GetCount () |
int | Broadcast (int *data, vtkIdType length, int srcProcessId) |
int | Broadcast (unsigned int *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 (float *data, vtkIdType length, int srcProcessId) |
int | Broadcast (double *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) |
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 float *sendBuffer, float *recvBuffer, vtkIdType length, int destProcessId) |
int | Gather (const double *sendBuffer, double *recvBuffer, vtkIdType length, int destProcessId) |
int | Gather (vtkDataArray *sendBuffer, vtkDataArray *recvBuffer, int destProcessId) |
int | GatherV (const int *sendBuffer, int *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 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 (vtkDataArray *sendBuffer, vtkDataArray *recvBuffer, vtkIdType *recvLengths, vtkIdType *offsets, int destProcessId) |
int | GatherV (vtkDataArray *sendBuffer, vtkDataArray *recvBuffer, int destProcessId) |
int | Scatter (const int *sendBuffer, int *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 float *sendBuffer, float *recvBuffer, vtkIdType length, int srcProcessId) |
int | Scatter (const double *sendBuffer, double *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) |
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 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 | AllGather (const int *sendBuffer, int *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 float *sendBuffer, float *recvBuffer, vtkIdType length) |
int | AllGather (const double *sendBuffer, double *recvBuffer, vtkIdType length) |
int | AllGather (vtkDataArray *sendBuffer, vtkDataArray *recvBuffer) |
int | AllGatherV (const int *sendBuffer, int *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 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 (vtkDataArray *sendBuffer, vtkDataArray *recvBuffer, vtkIdType *recvLengths, vtkIdType *offsets) |
int | AllGatherV (vtkDataArray *sendBuffer, vtkDataArray *recvBuffer) |
int | Reduce (const int *sendBuffer, int *recvBuffer, vtkIdType length, int operation, int destProcessId) |
int | Reduce (const unsigned int *sendBuffer, unsigned int *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 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 (vtkDataArray *sendBuffer, vtkDataArray *recvBuffer, int operation, int destProcessId) |
int | Reduce (const int *sendBuffer, int *recvBuffer, vtkIdType length, Operation *operation, int destProcessId) |
int | Reduce (const unsigned long *sendBuffer, unsigned long *recvBuffer, vtkIdType length, Operation *operation, int destProcessId) |
int | Reduce (const unsigned char *sendBuffer, unsigned char *recvBuffer, vtkIdType length, Operation *operation, int destProcessId) |
int | Reduce (const char *sendBuffer, char *recvBuffer, vtkIdType length, Operation *operation, int destProcessId) |
int | Reduce (const float *sendBuffer, float *recvBuffer, vtkIdType length, Operation *operation, int destProcessId) |
int | Reduce (const double *sendBuffer, double *recvBuffer, vtkIdType length, Operation *operation, int destProcessId) |
int | Reduce (vtkDataArray *sendBuffer, vtkDataArray *recvBuffer, Operation *operation, int destProcessId) |
int | AllReduce (const int *sendBuffer, int *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 float *sendBuffer, float *recvBuffer, vtkIdType length, int operation) |
int | AllReduce (const double *sendBuffer, double *recvBuffer, vtkIdType length, int operation) |
int | AllReduce (vtkDataArray *sendBuffer, vtkDataArray *recvBuffer, int operation) |
int | AllReduce (const int *sendBuffer, int *recvBuffer, vtkIdType length, Operation *operation) |
int | AllReduce (const unsigned long *sendBuffer, unsigned long *recvBuffer, vtkIdType length, Operation *operation) |
int | AllReduce (const unsigned char *sendBuffer, unsigned char *recvBuffer, vtkIdType length, Operation *operation) |
int | AllReduce (const char *sendBuffer, char *recvBuffer, vtkIdType length, Operation *operation) |
int | AllReduce (const float *sendBuffer, float *recvBuffer, vtkIdType length, Operation *operation) |
int | AllReduce (const double *sendBuffer, double *recvBuffer, vtkIdType length, Operation *operation) |
int | AllReduce (vtkDataArray *sendBuffer, vtkDataArray *recvBuffer, Operation *operation) |
virtual int | BroadcastVoidArray (void *data, vtkIdType length, int type, int srcProcessId) |
virtual int | GatherVoidArray (const void *sendBuffer, void *recvBuffer, vtkIdType length, int type, int destProcessId) |
virtual int | GatherVVoidArray (const void *sendBuffer, void *recvBuffer, vtkIdType sendLength, vtkIdType *recvLengths, vtkIdType *offsets, int type, int destProcessId) |
virtual int | ScatterVoidArray (const void *sendBuffer, void *recvBuffer, vtkIdType length, int type, int srcProcessId) |
virtual int | ScatterVVoidArray (const void *sendBuffer, void *recvBuffer, vtkIdType *sendLengths, vtkIdType *offsets, vtkIdType recvLength, int type, int srcProcessId) |
virtual int | AllGatherVoidArray (const void *sendBuffer, void *recvBuffer, vtkIdType length, int type) |
virtual int | AllGatherVVoidArray (const void *sendBuffer, void *recvBuffer, vtkIdType sendLength, vtkIdType *recvLengths, vtkIdType *offsets, int type) |
virtual int | ReduceVoidArray (const void *sendBuffer, void *recvBuffer, vtkIdType length, int type, int operation, int destProcessId) |
virtual int | ReduceVoidArray (const void *sendBuffer, void *recvBuffer, vtkIdType length, int type, Operation *operation, int destProcessId) |
virtual int | AllReduceVoidArray (const void *sendBuffer, void *recvBuffer, vtkIdType length, int type, int operation) |
virtual int | AllReduceVoidArray (const void *sendBuffer, void *recvBuffer, vtkIdType length, int type, Operation *operation) |
virtual int | ComputeGlobalBounds (int processorId, int numProcesses, vtkBoundingBox *bounds, int *rightHasBounds=0, int *leftHasBounds=0, int hasBoundsTag=288402, int localBoundsTag=288403, int globalBoundsTag=288404) |
![]() | |
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) |
![]() | |
const char * | GetClassName () const |
virtual void | Delete () |
virtual void | FastDelete () |
void | Print (ostream &os) |
virtual void | Register (vtkObjectBase *o) |
virtual void | UnRegister (vtkObjectBase *o) |
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 int | IsTypeOf (const char *type) |
static vtkCommunicator * | SafeDownCast (vtkObject *o) |
static void | SetUseCopy (int useCopy) |
static int | GetParentProcessor (int pid) |
static int | GetLeftChildProcessor (int pid) |
static int | MarshalDataObject (vtkDataObject *object, vtkCharArray *buffer) |
static int | UnMarshalDataObject (vtkCharArray *buffer, vtkDataObject *object) |
![]() | |
static vtkObject * | New () |
static void | BreakOnError () |
static void | SetGlobalWarningDisplay (int val) |
static void | GlobalWarningDisplayOn () |
static void | GlobalWarningDisplayOff () |
static int | GetGlobalWarningDisplay () |
Protected Member Functions | |
int | WriteDataArray (vtkDataArray *object) |
int | ReadDataArray (vtkDataArray *object) |
vtkCommunicator () | |
~vtkCommunicator () | |
int | SendElementalDataObject (vtkDataObject *data, int remoteHandle, int tag) |
int | SendMultiBlockDataSet (vtkMultiBlockDataSet *data, int remoteHandle, int tag) |
int | SendTemporalDataSet (vtkTemporalDataSet *data, int remoteHandle, int tag) |
int | ReceiveDataObject (vtkDataObject *data, int remoteHandle, int tag, int type=-1) |
int | ReceiveElementalDataObject (vtkDataObject *data, int remoteHandle, int tag) |
int | ReceiveMultiBlockDataSet (vtkMultiBlockDataSet *data, int remoteHandle, int tag) |
int | ReceiveTemporalDataSet (vtkTemporalDataSet *data, int remoteHandle, int tag) |
![]() | |
vtkObject () | |
virtual | ~vtkObject () |
virtual void | RegisterInternal (vtkObjectBase *, int check) |
virtual void | UnRegisterInternal (vtkObjectBase *, int check) |
void | InternalGrabFocus (vtkCommand *mouseEvents, vtkCommand *keypressEvents=NULL) |
void | InternalReleaseFocus () |
![]() | |
vtkObjectBase () | |
virtual | ~vtkObjectBase () |
virtual void | CollectRevisions (ostream &os) |
virtual void | ReportReferences (vtkGarbageCollector *) |
vtkObjectBase (const vtkObjectBase &) | |
void | operator= (const vtkObjectBase &) |
Protected Attributes | |
int | MaximumNumberOfProcesses |
int | NumberOfProcesses |
int | LocalProcessId |
vtkIdType | Count |
![]() | |
unsigned char | Debug |
vtkTimeStamp | MTime |
vtkSubjectHelper * | SubjectHelper |
![]() | |
int | ReferenceCount |
vtkWeakPointerBase ** | WeakPointers |
Static Protected Attributes | |
static int | UseCopy |
Used to send/receive messages in a multiprocess environment.
This is an abstact class which contains functionality for sending and receiving inter-process messages. It contains methods for marshaling an object into a string (currently used by the MPI communicator but not the shared memory communicator).
Definition at line 49 of file vtkCommunicator.h.
typedef vtkObject vtkCommunicator::Superclass |
Definition at line 54 of file vtkCommunicator.h.
Definition at line 72 of file vtkCommunicator.h.
MAX_OP | |
MIN_OP | |
SUM_OP | |
PRODUCT_OP | |
LOGICAL_AND_OP | |
BITWISE_AND_OP | |
LOGICAL_OR_OP | |
BITWISE_OR_OP | |
LOGICAL_XOR_OP | |
BITWISE_XOR_OP |
Definition at line 83 of file vtkCommunicator.h.
|
protected |
|
protected |
|
virtual |
Reimplemented from vtkObject.
Reimplemented in vtkMPICommunicator, vtkSocketCommunicator, vtkSubCommunicator, and vtkDummyCommunicator.
|
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 vtkObject.
Reimplemented in vtkMPICommunicator, vtkSocketCommunicator, vtkSubCommunicator, and vtkDummyCommunicator.
|
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 vtkObject.
Reimplemented in vtkMPICommunicator, vtkSocketCommunicator, vtkSubCommunicator, and vtkDummyCommunicator.
|
static |
Reimplemented from vtkObject.
Reimplemented in vtkMPICommunicator, vtkSocketCommunicator, vtkSubCommunicator, and vtkDummyCommunicator.
|
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 vtkObject.
Reimplemented in vtkMPICommunicator, vtkSocketCommunicator, vtkSubCommunicator, and vtkDummyCommunicator.
|
virtual |
Set the number of processes you will be using. This defaults to the maximum number available. If you set this to a value higher than the default, you will get an error.
Reimplemented in vtkSocketCommunicator.
|
virtual |
Set the number of processes you will be using. This defaults to the maximum number available. If you set this to a value higher than the default, you will get an error.
|
virtual |
Tells you which process [0, NumProcess) you are in.
int vtkCommunicator::Send | ( | vtkDataObject * | data, |
int | remoteHandle, | ||
int | tag | ||
) |
This method sends a data object to a destination. Tag eliminates ambiguity and is used to match sends to receives.
int vtkCommunicator::Send | ( | vtkDataArray * | data, |
int | remoteHandle, | ||
int | tag | ||
) |
This method sends a data array to a destination. Tag eliminates ambiguity and is used to match sends to receives.
|
pure virtual |
Subclasses have to supply this method to send various arrays of data. The type
arg is one of the VTK type constants recognized by the vtkTemplateMacro (VTK_FLOAT, VTK_INT, etc.). length
is measured in number of values (as opposed to number of bytes).
Implemented in vtkSocketCommunicator, vtkMPICommunicator, vtkSubCommunicator, and vtkDummyCommunicator.
|
inline |
Convenience methods for sending data arrays.
Definition at line 144 of file vtkCommunicator.h.
|
inline |
Convenience methods for sending data arrays.
Definition at line 147 of file vtkCommunicator.h.
|
inline |
Convenience methods for sending data arrays.
Definition at line 150 of file vtkCommunicator.h.
|
inline |
Convenience methods for sending data arrays.
Definition at line 154 of file vtkCommunicator.h.
|
inline |
Convenience methods for sending data arrays.
Definition at line 158 of file vtkCommunicator.h.
|
inline |
Convenience methods for sending data arrays.
Definition at line 161 of file vtkCommunicator.h.
|
inline |
Convenience methods for sending data arrays.
Definition at line 164 of file vtkCommunicator.h.
int vtkCommunicator::Send | ( | const vtkMultiProcessStream & | stream, |
int | remoteId, | ||
int | tag | ||
) |
Convenience methods for sending data arrays.
int vtkCommunicator::Receive | ( | vtkDataObject * | data, |
int | remoteHandle, | ||
int | tag | ||
) |
This method receives a data object from a corresponding send. It blocks until the receive is finished.
vtkDataObject* vtkCommunicator::ReceiveDataObject | ( | int | remoteHandle, |
int | tag | ||
) |
The caller does not have to know the data type before this call is made. It returns the newly created object.
int vtkCommunicator::Receive | ( | vtkDataArray * | data, |
int | remoteHandle, | ||
int | tag | ||
) |
This method receives a data array from a corresponding send. It blocks until the receive is finished.
|
pure virtual |
Subclasses have to supply this method to receive various arrays of data. The type
arg is one of the VTK type constants recognized by the vtkTemplateMacro (VTK_FLOAT, VTK_INT, etc.). maxlength
is measured in number of values (as opposed to number of bytes) and is the maxmum length of the data to receive. If the maxlength is less than the length of the message sent by the sender, an error will be flagged. Once a message is received, use the GetCount() method to determine the actual size of the data received.
Implemented in vtkSocketCommunicator, vtkMPICommunicator, vtkSubCommunicator, and vtkDummyCommunicator.
|
inline |
Convenience methods for receiving data arrays.
Definition at line 205 of file vtkCommunicator.h.
|
inline |
Convenience methods for receiving data arrays.
Definition at line 208 of file vtkCommunicator.h.
|
inline |
Convenience methods for receiving data arrays.
Definition at line 211 of file vtkCommunicator.h.
|
inline |
Convenience methods for receiving data arrays.
Definition at line 215 of file vtkCommunicator.h.
|
inline |
Convenience methods for receiving data arrays.
Definition at line 219 of file vtkCommunicator.h.
|
inline |
Convenience methods for receiving data arrays.
Definition at line 222 of file vtkCommunicator.h.
|
inline |
Convenience methods for receiving data arrays.
Definition at line 225 of file vtkCommunicator.h.
int vtkCommunicator::Receive | ( | vtkMultiProcessStream & | stream, |
int | remoteId, | ||
int | tag | ||
) |
Convenience methods for receiving data arrays.
|
virtual |
Returns the number of words received by the most recent Receive(). Note that this is not the number of bytes received, but the number of items of the data-type received by the most recent Receive() eg. if Receive(int*,..) was used, then this returns the number of ints received; if Receive(double*,..) was used, then this returns the number of doubles received etc. The return value is valid only after a successful Receive().
|
virtual |
Will block the processes until all other processes reach the Barrier function.
Reimplemented in vtkMPICommunicator, and vtkSocketCommunicator.
|
inline |
Broadcast sends the array in the process with id srcProcessId
to all of the other processes. All processes must call these method with the same arguments in order for it to complete.
Definition at line 259 of file vtkCommunicator.h.
|
inline |
Broadcast sends the array in the process with id srcProcessId
to all of the other processes. All processes must call these method with the same arguments in order for it to complete.
Definition at line 262 of file vtkCommunicator.h.
|
inline |
Broadcast sends the array in the process with id srcProcessId
to all of the other processes. All processes must call these method with the same arguments in order for it to complete.
Definition at line 265 of file vtkCommunicator.h.
|
inline |
Broadcast sends the array in the process with id srcProcessId
to all of the other processes. All processes must call these method with the same arguments in order for it to complete.
Definition at line 268 of file vtkCommunicator.h.
|
inline |
Broadcast sends the array in the process with id srcProcessId
to all of the other processes. All processes must call these method with the same arguments in order for it to complete.
Definition at line 271 of file vtkCommunicator.h.
|
inline |
Broadcast sends the array in the process with id srcProcessId
to all of the other processes. All processes must call these method with the same arguments in order for it to complete.
Definition at line 274 of file vtkCommunicator.h.
|
inline |
Broadcast sends the array in the process with id srcProcessId
to all of the other processes. All processes must call these method with the same arguments in order for it to complete.
Definition at line 277 of file vtkCommunicator.h.
int vtkCommunicator::Broadcast | ( | vtkDataObject * | data, |
int | srcProcessId | ||
) |
Broadcast sends the array in the process with id srcProcessId
to all of the other processes. All processes must call these method with the same arguments in order for it to complete.
int vtkCommunicator::Broadcast | ( | vtkDataArray * | data, |
int | srcProcessId | ||
) |
Broadcast sends the array in the process with id srcProcessId
to all of the other processes. All processes must call these method with the same arguments in order for it to complete.
int vtkCommunicator::Broadcast | ( | vtkMultiProcessStream & | stream, |
int | srcProcessId | ||
) |
Broadcast sends the array in the process with id srcProcessId
to all of the other processes. All processes must call these method with the same arguments in order for it to complete.
|
inline |
Gather collects arrays in the process with id destProcessId
. Each process (including the destination) sends the contents of its send buffer to the destination process. The destination process receives the messages and stores them in rank order. The length
argument (which must be the same on all processes) is the length of the sendBuffers. The recvBuffer
(on te destination process) must be of length length*numProcesses. Gather is the inverse operation of Scatter.
Definition at line 301 of file vtkCommunicator.h.
|
inline |
Gather collects arrays in the process with id destProcessId
. Each process (including the destination) sends the contents of its send buffer to the destination process. The destination process receives the messages and stores them in rank order. The length
argument (which must be the same on all processes) is the length of the sendBuffers. The recvBuffer
(on te destination process) must be of length length*numProcesses. Gather is the inverse operation of Scatter.
Definition at line 306 of file vtkCommunicator.h.
|
inline |
Gather collects arrays in the process with id destProcessId
. Each process (including the destination) sends the contents of its send buffer to the destination process. The destination process receives the messages and stores them in rank order. The length
argument (which must be the same on all processes) is the length of the sendBuffers. The recvBuffer
(on te destination process) must be of length length*numProcesses. Gather is the inverse operation of Scatter.
Definition at line 311 of file vtkCommunicator.h.
|
inline |
Gather collects arrays in the process with id destProcessId
. Each process (including the destination) sends the contents of its send buffer to the destination process. The destination process receives the messages and stores them in rank order. The length
argument (which must be the same on all processes) is the length of the sendBuffers. The recvBuffer
(on te destination process) must be of length length*numProcesses. Gather is the inverse operation of Scatter.
Definition at line 316 of file vtkCommunicator.h.
|
inline |
Gather collects arrays in the process with id destProcessId
. Each process (including the destination) sends the contents of its send buffer to the destination process. The destination process receives the messages and stores them in rank order. The length
argument (which must be the same on all processes) is the length of the sendBuffers. The recvBuffer
(on te destination process) must be of length length*numProcesses. Gather is the inverse operation of Scatter.
Definition at line 321 of file vtkCommunicator.h.
|
inline |
Gather collects arrays in the process with id destProcessId
. Each process (including the destination) sends the contents of its send buffer to the destination process. The destination process receives the messages and stores them in rank order. The length
argument (which must be the same on all processes) is the length of the sendBuffers. The recvBuffer
(on te destination process) must be of length length*numProcesses. Gather is the inverse operation of Scatter.
Definition at line 326 of file vtkCommunicator.h.
int vtkCommunicator::Gather | ( | vtkDataArray * | sendBuffer, |
vtkDataArray * | recvBuffer, | ||
int | destProcessId | ||
) |
Gather collects arrays in the process with id destProcessId
. Each process (including the destination) sends the contents of its send buffer to the destination process. The destination process receives the messages and stores them in rank order. The length
argument (which must be the same on all processes) is the length of the sendBuffers. The recvBuffer
(on te destination process) must be of length length*numProcesses. Gather is the inverse operation of Scatter.
|
inline |
GatherV is the vector variant of Gather. It extends the functionality of Gather by allowing a varying count of data from each process. GatherV collects arrays in the process with id destProcessId
. Each process (including the destination) sends the contents of its send buffer to the destination process. The destination process receives the messages and stores them in rank order. The sendLength
argument defines how much the local process sends to destProcessId
and recvLengths
is an array containing the amount destProcessId
receives from each process, in rank order.
Definition at line 353 of file vtkCommunicator.h.
|
inline |
GatherV is the vector variant of Gather. It extends the functionality of Gather by allowing a varying count of data from each process. GatherV collects arrays in the process with id destProcessId
. Each process (including the destination) sends the contents of its send buffer to the destination process. The destination process receives the messages and stores them in rank order. The sendLength
argument defines how much the local process sends to destProcessId
and recvLengths
is an array containing the amount destProcessId
receives from each process, in rank order.
Definition at line 360 of file vtkCommunicator.h.
|
inline |
GatherV is the vector variant of Gather. It extends the functionality of Gather by allowing a varying count of data from each process. GatherV collects arrays in the process with id destProcessId
. Each process (including the destination) sends the contents of its send buffer to the destination process. The destination process receives the messages and stores them in rank order. The sendLength
argument defines how much the local process sends to destProcessId
and recvLengths
is an array containing the amount destProcessId
receives from each process, in rank order.
Definition at line 367 of file vtkCommunicator.h.
|
inline |
GatherV is the vector variant of Gather. It extends the functionality of Gather by allowing a varying count of data from each process. GatherV collects arrays in the process with id destProcessId
. Each process (including the destination) sends the contents of its send buffer to the destination process. The destination process receives the messages and stores them in rank order. The sendLength
argument defines how much the local process sends to destProcessId
and recvLengths
is an array containing the amount destProcessId
receives from each process, in rank order.
Definition at line 374 of file vtkCommunicator.h.
|
inline |
GatherV is the vector variant of Gather. It extends the functionality of Gather by allowing a varying count of data from each process. GatherV collects arrays in the process with id destProcessId
. Each process (including the destination) sends the contents of its send buffer to the destination process. The destination process receives the messages and stores them in rank order. The sendLength
argument defines how much the local process sends to destProcessId
and recvLengths
is an array containing the amount destProcessId
receives from each process, in rank order.
Definition at line 381 of file vtkCommunicator.h.
|
inline |
GatherV is the vector variant of Gather. It extends the functionality of Gather by allowing a varying count of data from each process. GatherV collects arrays in the process with id destProcessId
. Each process (including the destination) sends the contents of its send buffer to the destination process. The destination process receives the messages and stores them in rank order. The sendLength
argument defines how much the local process sends to destProcessId
and recvLengths
is an array containing the amount destProcessId
receives from each process, in rank order.
Definition at line 388 of file vtkCommunicator.h.
int vtkCommunicator::GatherV | ( | vtkDataArray * | sendBuffer, |
vtkDataArray * | recvBuffer, | ||
vtkIdType * | recvLengths, | ||
vtkIdType * | offsets, | ||
int | destProcessId | ||
) |
GatherV is the vector variant of Gather. It extends the functionality of Gather by allowing a varying count of data from each process. GatherV collects arrays in the process with id destProcessId
. Each process (including the destination) sends the contents of its send buffer to the destination process. The destination process receives the messages and stores them in rank order. The sendLength
argument defines how much the local process sends to destProcessId
and recvLengths
is an array containing the amount destProcessId
receives from each process, in rank order.
int vtkCommunicator::GatherV | ( | vtkDataArray * | sendBuffer, |
vtkDataArray * | recvBuffer, | ||
int | destProcessId | ||
) |
GatherV is the vector variant of Gather. It extends the functionality of Gather by allowing a varying count of data from each process. GatherV collects arrays in the process with id destProcessId
. Each process (including the destination) sends the contents of its send buffer to the destination process. The destination process receives the messages and stores them in rank order. The sendLength
argument defines how much the local process sends to destProcessId
and recvLengths
is an array containing the amount destProcessId
receives from each process, in rank order.
|
inline |
Scatter takes an array in the process with id srcProcessId
and distributes it. Each process (including the source) receives a portion of the send buffer. Process 0 receives the first length
values, process 1 receives the second length
values, and so on. Scatter is the inverse operation of Gather.
Definition at line 416 of file vtkCommunicator.h.
|
inline |
Scatter takes an array in the process with id srcProcessId
and distributes it. Each process (including the source) receives a portion of the send buffer. Process 0 receives the first length
values, process 1 receives the second length
values, and so on. Scatter is the inverse operation of Gather.
Definition at line 421 of file vtkCommunicator.h.
|
inline |
Scatter takes an array in the process with id srcProcessId
and distributes it. Each process (including the source) receives a portion of the send buffer. Process 0 receives the first length
values, process 1 receives the second length
values, and so on. Scatter is the inverse operation of Gather.
Definition at line 426 of file vtkCommunicator.h.
|
inline |
Scatter takes an array in the process with id srcProcessId
and distributes it. Each process (including the source) receives a portion of the send buffer. Process 0 receives the first length
values, process 1 receives the second length
values, and so on. Scatter is the inverse operation of Gather.
Definition at line 431 of file vtkCommunicator.h.
|
inline |
Scatter takes an array in the process with id srcProcessId
and distributes it. Each process (including the source) receives a portion of the send buffer. Process 0 receives the first length
values, process 1 receives the second length
values, and so on. Scatter is the inverse operation of Gather.
Definition at line 436 of file vtkCommunicator.h.
|
inline |
Scatter takes an array in the process with id srcProcessId
and distributes it. Each process (including the source) receives a portion of the send buffer. Process 0 receives the first length
values, process 1 receives the second length
values, and so on. Scatter is the inverse operation of Gather.
Definition at line 441 of file vtkCommunicator.h.
int vtkCommunicator::Scatter | ( | vtkDataArray * | sendBuffer, |
vtkDataArray * | recvBuffer, | ||
int | srcProcessId | ||
) |
Scatter takes an array in the process with id srcProcessId
and distributes it. Each process (including the source) receives a portion of the send buffer. Process 0 receives the first length
values, process 1 receives the second length
values, and so on. Scatter is the inverse operation of Gather.
|
inline |
ScatterV is the vector variant of Scatter. It extends the functionality of Scatter by allowing a varying count of data to each process. ScatterV takes an array in the process with id srcProcessId
and distributes it. Each process (including the source) receives a portion of the send buffer defined by the sendLengths
and offsets
arrays.
Definition at line 464 of file vtkCommunicator.h.
|
inline |
ScatterV is the vector variant of Scatter. It extends the functionality of Scatter by allowing a varying count of data to each process. ScatterV takes an array in the process with id srcProcessId
and distributes it. Each process (including the source) receives a portion of the send buffer defined by the sendLengths
and offsets
arrays.
Definition at line 471 of file vtkCommunicator.h.
|
inline |
ScatterV is the vector variant of Scatter. It extends the functionality of Scatter by allowing a varying count of data to each process. ScatterV takes an array in the process with id srcProcessId
and distributes it. Each process (including the source) receives a portion of the send buffer defined by the sendLengths
and offsets
arrays.
Definition at line 478 of file vtkCommunicator.h.
|
inline |
ScatterV is the vector variant of Scatter. It extends the functionality of Scatter by allowing a varying count of data to each process. ScatterV takes an array in the process with id srcProcessId
and distributes it. Each process (including the source) receives a portion of the send buffer defined by the sendLengths
and offsets
arrays.
Definition at line 485 of file vtkCommunicator.h.
|
inline |
ScatterV is the vector variant of Scatter. It extends the functionality of Scatter by allowing a varying count of data to each process. ScatterV takes an array in the process with id srcProcessId
and distributes it. Each process (including the source) receives a portion of the send buffer defined by the sendLengths
and offsets
arrays.
Definition at line 492 of file vtkCommunicator.h.
|
inline |
ScatterV is the vector variant of Scatter. It extends the functionality of Scatter by allowing a varying count of data to each process. ScatterV takes an array in the process with id srcProcessId
and distributes it. Each process (including the source) receives a portion of the send buffer defined by the sendLengths
and offsets
arrays.
Definition at line 499 of file vtkCommunicator.h.
|
inline |
Same as gather except that the result ends up on all processes.
Definition at line 519 of file vtkCommunicator.h.
|
inline |
Same as gather except that the result ends up on all processes.
Definition at line 522 of file vtkCommunicator.h.
|
inline |
Same as gather except that the result ends up on all processes.
Definition at line 527 of file vtkCommunicator.h.
|
inline |
Same as gather except that the result ends up on all processes.
Definition at line 532 of file vtkCommunicator.h.
|
inline |
Same as gather except that the result ends up on all processes.
Definition at line 535 of file vtkCommunicator.h.
|
inline |
Same as gather except that the result ends up on all processes.
Definition at line 538 of file vtkCommunicator.h.
int vtkCommunicator::AllGather | ( | vtkDataArray * | sendBuffer, |
vtkDataArray * | recvBuffer | ||
) |
Same as gather except that the result ends up on all processes.
|
inline |
Same as GatherV except that the result is placed in all processes.
Definition at line 554 of file vtkCommunicator.h.
|
inline |
Same as GatherV except that the result is placed in all processes.
Definition at line 561 of file vtkCommunicator.h.
|
inline |
Same as GatherV except that the result is placed in all processes.
Definition at line 568 of file vtkCommunicator.h.
|
inline |
Same as GatherV except that the result is placed in all processes.
Definition at line 575 of file vtkCommunicator.h.
|
inline |
Same as GatherV except that the result is placed in all processes.
Definition at line 582 of file vtkCommunicator.h.
|
inline |
Same as GatherV except that the result is placed in all processes.
Definition at line 589 of file vtkCommunicator.h.
int vtkCommunicator::AllGatherV | ( | vtkDataArray * | sendBuffer, |
vtkDataArray * | recvBuffer, | ||
vtkIdType * | recvLengths, | ||
vtkIdType * | offsets | ||
) |
Same as GatherV except that the result is placed in all processes.
int vtkCommunicator::AllGatherV | ( | vtkDataArray * | sendBuffer, |
vtkDataArray * | recvBuffer | ||
) |
Same as GatherV except that the result is placed in all processes.
|
inline |
Reduce an array to the given destination process. This version of Reduce takes an identifier defined in the vtkCommunicator::StandardOperations enum to define the operation.
Definition at line 614 of file vtkCommunicator.h.
|
inline |
Reduce an array to the given destination process. This version of Reduce takes an identifier defined in the vtkCommunicator::StandardOperations enum to define the operation.
Definition at line 619 of file vtkCommunicator.h.
|
inline |
Reduce an array to the given destination process. This version of Reduce takes an identifier defined in the vtkCommunicator::StandardOperations enum to define the operation.
Definition at line 624 of file vtkCommunicator.h.
|
inline |
Reduce an array to the given destination process. This version of Reduce takes an identifier defined in the vtkCommunicator::StandardOperations enum to define the operation.
Definition at line 629 of file vtkCommunicator.h.
|
inline |
Reduce an array to the given destination process. This version of Reduce takes an identifier defined in the vtkCommunicator::StandardOperations enum to define the operation.
Definition at line 634 of file vtkCommunicator.h.
|
inline |
Reduce an array to the given destination process. This version of Reduce takes an identifier defined in the vtkCommunicator::StandardOperations enum to define the operation.
Definition at line 639 of file vtkCommunicator.h.
|
inline |
Reduce an array to the given destination process. This version of Reduce takes an identifier defined in the vtkCommunicator::StandardOperations enum to define the operation.
Definition at line 644 of file vtkCommunicator.h.
int vtkCommunicator::Reduce | ( | vtkDataArray * | sendBuffer, |
vtkDataArray * | recvBuffer, | ||
int | operation, | ||
int | destProcessId | ||
) |
Reduce an array to the given destination process. This version of Reduce takes an identifier defined in the vtkCommunicator::StandardOperations enum to define the operation.
|
inline |
Reduce an array to the given destination process. This version of Reduce takes a custom operation as a subclass of vtkCommunicator::Operation.
Definition at line 664 of file vtkCommunicator.h.
|
inline |
Reduce an array to the given destination process. This version of Reduce takes a custom operation as a subclass of vtkCommunicator::Operation.
Definition at line 669 of file vtkCommunicator.h.
|
inline |
Reduce an array to the given destination process. This version of Reduce takes a custom operation as a subclass of vtkCommunicator::Operation.
Definition at line 674 of file vtkCommunicator.h.
|
inline |
Reduce an array to the given destination process. This version of Reduce takes a custom operation as a subclass of vtkCommunicator::Operation.
Definition at line 679 of file vtkCommunicator.h.
|
inline |
Reduce an array to the given destination process. This version of Reduce takes a custom operation as a subclass of vtkCommunicator::Operation.
Definition at line 684 of file vtkCommunicator.h.
|
inline |
Reduce an array to the given destination process. This version of Reduce takes a custom operation as a subclass of vtkCommunicator::Operation.
Definition at line 689 of file vtkCommunicator.h.
int vtkCommunicator::Reduce | ( | vtkDataArray * | sendBuffer, |
vtkDataArray * | recvBuffer, | ||
Operation * | operation, | ||
int | destProcessId | ||
) |
Reduce an array to the given destination process. This version of Reduce takes a custom operation as a subclass of vtkCommunicator::Operation.
|
inline |
Same as Reduce except that the result is placed in all of the processes.
Definition at line 708 of file vtkCommunicator.h.
|
inline |
Same as Reduce except that the result is placed in all of the processes.
Definition at line 713 of file vtkCommunicator.h.
|
inline |
Same as Reduce except that the result is placed in all of the processes.
Definition at line 718 of file vtkCommunicator.h.
|
inline |
Same as Reduce except that the result is placed in all of the processes.
Definition at line 723 of file vtkCommunicator.h.
|
inline |
Same as Reduce except that the result is placed in all of the processes.
Definition at line 728 of file vtkCommunicator.h.
|
inline |
Same as Reduce except that the result is placed in all of the processes.
Definition at line 733 of file vtkCommunicator.h.
int vtkCommunicator::AllReduce | ( | vtkDataArray * | sendBuffer, |
vtkDataArray * | recvBuffer, | ||
int | operation | ||
) |
Same as Reduce except that the result is placed in all of the processes.
|
inline |
Same as Reduce except that the result is placed in all of the processes.
Definition at line 747 of file vtkCommunicator.h.
|
inline |
Same as Reduce except that the result is placed in all of the processes.
Definition at line 752 of file vtkCommunicator.h.
|
inline |
Same as Reduce except that the result is placed in all of the processes.
Definition at line 757 of file vtkCommunicator.h.
|
inline |
Same as Reduce except that the result is placed in all of the processes.
Definition at line 762 of file vtkCommunicator.h.
|
inline |
Same as Reduce except that the result is placed in all of the processes.
Definition at line 767 of file vtkCommunicator.h.
|
inline |
Same as Reduce except that the result is placed in all of the processes.
Definition at line 772 of file vtkCommunicator.h.
int vtkCommunicator::AllReduce | ( | vtkDataArray * | sendBuffer, |
vtkDataArray * | recvBuffer, | ||
Operation * | operation | ||
) |
Same as Reduce except that the result is placed in all of the processes.
|
virtual |
Subclasses should reimplement these if they have a more efficient implementation.
Reimplemented in vtkMPICommunicator, and vtkSocketCommunicator.
|
virtual |
Subclasses should reimplement these if they have a more efficient implementation.
Reimplemented in vtkMPICommunicator, and vtkSocketCommunicator.
|
virtual |
Subclasses should reimplement these if they have a more efficient implementation.
Reimplemented in vtkMPICommunicator, and vtkSocketCommunicator.
|
virtual |
Subclasses should reimplement these if they have a more efficient implementation.
Reimplemented in vtkMPICommunicator, and vtkSocketCommunicator.
|
virtual |
Subclasses should reimplement these if they have a more efficient implementation.
Reimplemented in vtkMPICommunicator, and vtkSocketCommunicator.
|
virtual |
Subclasses should reimplement these if they have a more efficient implementation.
Reimplemented in vtkMPICommunicator, and vtkSocketCommunicator.
|
virtual |
Subclasses should reimplement these if they have a more efficient implementation.
Reimplemented in vtkMPICommunicator, and vtkSocketCommunicator.
|
virtual |
Subclasses should reimplement these if they have a more efficient implementation.
Reimplemented in vtkMPICommunicator, and vtkSocketCommunicator.
|
virtual |
Subclasses should reimplement these if they have a more efficient implementation.
Reimplemented in vtkMPICommunicator, and vtkSocketCommunicator.
|
virtual |
Subclasses should reimplement these if they have a more efficient implementation.
Reimplemented in vtkMPICommunicator, and vtkSocketCommunicator.
|
virtual |
Subclasses should reimplement these if they have a more efficient implementation.
Reimplemented in vtkMPICommunicator, and vtkSocketCommunicator.
|
static |
|
virtual |
Determine the global bounds for a set of processes. BBox is initially set (outside of the call to the local bounds of the process and will be modified to be the global bounds - this default implementation views the processors as a heap tree with the root being processId = 0 If either rightHasBounds or leftHasBounds is not 0 then the corresponding int will be set to 1 if the right/left processor has bounds else it will be set to 0 The last three arguments are the tags to be used when performing the operation
|
static |
Some helper functions when dealing with heap tree - based algorthims
|
static |
Some helper functions when dealing with heap tree - based algorthims
|
static |
Convert a data object into a string that can be transmitted and vice versa. Returns 1 for success and 0 for failure. WARNING: This will only work for types that have a vtkDataWriter class.
|
static |
Convert a data object into a string that can be transmitted and vice versa. Returns 1 for success and 0 for failure. WARNING: This will only work for types that have a vtkDataWriter class.
|
protected |
|
protected |
|
protected |
|
protected |
|
protected |
|
protected |
|
protected |
|
protected |
|
protected |
|
protected |
Definition at line 882 of file vtkCommunicator.h.
|
protected |
Definition at line 883 of file vtkCommunicator.h.
|
protected |
Definition at line 885 of file vtkCommunicator.h.
|
staticprotected |
Definition at line 887 of file vtkCommunicator.h.
|
protected |
Definition at line 889 of file vtkCommunicator.h.