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.
1.6.3