40 #ifndef vtkSocketCommunicator_h
41 #define vtkSocketCommunicator_h
44 #include "vtkParallelCoreModule.h"
48 #ifdef VTK_WORDS_BIGENDIAN
49 #define vtkSwap4 vtkByteSwap::Swap4LE
50 #define vtkSwap4Range vtkByteSwap::Swap4LERange
51 #define vtkSwap8 vtkByteSwap::Swap8LE
52 #define vtkSwap8Range vtkByteSwap::Swap8LERange
54 #define vtkSwap4 vtkByteSwap::Swap4BE
55 #define vtkSwap4Range vtkByteSwap::Swap4BERange
56 #define vtkSwap8 vtkByteSwap::Swap8BE
57 #define vtkSwap8Range vtkByteSwap::Swap8BERange
93 vtkGetMacro(SwapBytesInReceivedData,
int);
132 int destProcessId)
override;
136 int srcProcessId)
override;
144 int operation,
int destProcessId)
override;
146 Operation* operation,
int destProcessId)
override;
148 const void* sendBuffer,
void* recvBuffer,
vtkIdType length,
int type,
int operation)
override;
188 vtkSetMacro(ReportErrors,
int);
189 vtkGetMacro(ReportErrors,
int);
225 vtkGetMacro(IsServer,
int);
266 int SendTagged(
const void*
data,
int wordSize,
int numWords,
int tag,
const char* logName);
271 void*
data,
int wordSize,
int numWords,
int tag,
const char* logName);
280 const char*
name,
const void*
data,
int wordSize,
int numWords,
int tag,
const char* logName);
288 int SelectSocket(
int socket,
unsigned long msec);
301 int TagMessageLength;
304 class vtkMessageBuffer;
305 vtkMessageBuffer* ReceivedMessageBuffer;
Encapsulates a client socket.
A custom operation to use in a reduce command.
Used to send/receive messages in a multiprocess environment.
a simple class to control print indentation
Encapsulate a socket that accepts connections.
Process communication using Sockets.
int ReceiveVoidArray(void *data, vtkIdType length, int type, int remoteHandle, int tag) override
Subclasses have to supply this method to receive various arrays of data.
int ClientSideHandshake()
Performs ClientSide handshake.
int BroadcastVoidArray(void *data, vtkIdType length, int type, int srcProcessId) override
This class foolishly breaks the conventions of the superclass, so the default implementations of thes...
int Handshake()
Performs handshake.
vtkTypeBool PerformHandshake
int GatherVoidArray(const void *sendBuffer, void *recvBuffer, vtkIdType length, int type, int destProcessId) override
virtual int LogToFile(const char *name, int append)
virtual int ConnectTo(const char *hostName, int port)
Open a connection to host.
int ServerSideHandshake()
Performs ServerSide handshake.
virtual ostream * GetLogStream()
void Barrier() override
This class foolishly breaks the conventions of the superclass, so this overload fixes the method.
int GetIsConnected()
Is the communicator connected?.
int SendVoidArray(const void *data, vtkIdType length, int type, int remoteHandle, int tag) override
Performs the actual communication.
void PrintSelf(ostream &os, vtkIndent indent) override
Methods invoked by print to print information about the object including superclasses.
int GatherVVoidArray(const void *sendBuffer, void *recvBuffer, vtkIdType sendLength, vtkIdType *recvLengths, vtkIdType *offsets, int type, int destProcessId) override
int ReceivePartialTagged(void *data, int wordSize, int numWords, int tag, const char *logName)
virtual void CloseConnection()
Close a connection.
void FixByteOrder(void *data, int wordSize, int numWords)
Fix byte order for received data.
int SendTagged(const void *data, int wordSize, int numWords, int tag, const char *logName)
void LogTagged(const char *name, const void *data, int wordSize, int numWords, int tag, const char *logName)
int ReceivedTaggedFromBuffer(void *data, int wordSize, int numWords, int tag, const char *logName)
virtual int WaitForConnection(vtkServerSocket *socket, unsigned long msec=0)
int ReduceVoidArray(const void *sendBuffer, void *recvBuffer, vtkIdType length, int type, Operation *operation, int destProcessId) override
static int GetVersion()
Uniquely identifies the version of this class.
virtual int WaitForConnection(int port)
Wait for connection on a given port.
void SetNumberOfProcesses(int num) override
Set the number of processes you will be using.
int ScatterVVoidArray(const void *sendBuffer, void *recvBuffer, vtkIdType *sendLengths, vtkIdType *offsets, vtkIdType recvLength, int type, int srcProcessId) override
int ScatterVoidArray(const void *sendBuffer, void *recvBuffer, vtkIdType length, int type, int srcProcessId) override
int CheckForErrorInternal(int id)
int ReduceVoidArray(const void *sendBuffer, void *recvBuffer, vtkIdType length, int type, int operation, int destProcessId) override
int AllGatherVoidArray(const void *sendBuffer, void *recvBuffer, vtkIdType length, int type) override
virtual int LogToFile(const char *name)
Log messages to the given file.
~vtkSocketCommunicator() override
bool HasBufferredMessages()
Returns true if there are any messages in the receive buffer.
int AllGatherVVoidArray(const void *sendBuffer, void *recvBuffer, vtkIdType sendLength, vtkIdType *recvLengths, vtkIdType *offsets, int type) override
int ReceiveTagged(void *data, int wordSize, int numWords, int tag, const char *logName)
void SetSocket(vtkClientSocket *)
virtual void SetLogStream(ostream *stream)
Get/Set the output stream to which communications should be logged.
int AllReduceVoidArray(const void *sendBuffer, void *recvBuffer, vtkIdType length, int type, Operation *operation) override
static vtkSocketCommunicator * New()
int SwapBytesInReceivedData
int AllReduceVoidArray(const void *sendBuffer, void *recvBuffer, vtkIdType length, int type, int operation) override
void BufferCurrentMessage()
This flag is cleared before vtkCommand::WrongTagEvent is fired when ever a message with mismatched ta...