Implementation of the communications layer which uses named pipes. More...
#include <cnamedpipecomm.h>
Public Member Functions | |
cNamedPipeCommunications () | |
virtual | ~cNamedPipeCommunications () |
Redefined methods from cParsimCommunications | |
virtual void | init () |
virtual void | shutdown () |
virtual int | getNumPartitions () const |
virtual int | getProcId () const |
virtual cCommBuffer * | createCommBuffer () |
virtual void | recycleCommBuffer (cCommBuffer *buffer) |
virtual void | send (cCommBuffer *buffer, int tag, int destination) |
virtual bool | receiveBlocking (int filtTag, cCommBuffer *buffer, int &receivedTag, int &sourceProcId) |
virtual bool | receiveNonblocking (int filtTag, cCommBuffer *buffer, int &receivedTag, int &sourceProcId) |
Implementation of the communications layer which uses named pipes.
Pipes are created at initialization time, and are used throughout the whole simulation.
virtual void cNamedPipeCommunications::init | ( | ) | [virtual] |
virtual bool cNamedPipeCommunications::receiveBlocking | ( | int | filtTag, | |
cCommBuffer * | buffer, | |||
int & | receivedTag, | |||
int & | sourceProcId | |||
) | [virtual] |
Receives packed data, and also returns tag and source procId.
Normally returns true; false is returned if blocking was interrupted by the user.
Implements cParsimCommunications.
virtual bool cNamedPipeCommunications::receiveNonblocking | ( | int | filtTag, | |
cCommBuffer * | buffer, | |||
int & | receivedTag, | |||
int & | sourceProcId | |||
) | [virtual] |
Receives packed data, and also returns tag and source procId.
Call is non-blocking -- it returns true if something has been received, false otherwise.
Implements cParsimCommunications.
virtual void cNamedPipeCommunications::shutdown | ( | ) | [virtual] |
Shutdown the communications library.
Closes and removes the named pipes.
Implements cParsimCommunications.