28 #ifndef NS3_GRANTED_TIME_WINDOW_MPI_INTERFACE_H 29 #define NS3_GRANTED_TIME_WINDOW_MPI_INTERFACE_H 34 #include "ns3/nstime.h" 35 #include "ns3/buffer.h" 107 virtual void Enable (
int* pargc,
char*** pargv);
108 virtual void Enable (MPI_Comm communicator);
static uint32_t g_sid
System ID (rank) for this task.
static uint32_t g_rxCount
Total packets received.
Simulation virtual time values and global simulation resolution.
MPI_Request * GetRequest()
static uint32_t GetRxCount()
static MPI_Comm g_communicator
MPI communicator being used for ns-3 tasks.
static uint32_t g_txCount
Total packets sent.
virtual MPI_Comm GetCommunicator()
Return the communicator used to run ns-3.
static TypeId GetTypeId(void)
Register this type.
static uint32_t GetTxCount()
virtual void Enable(int *pargc, char ***pargv)
Setup the parallel communication interface.
virtual uint32_t GetSize()
Get the number of ranks used by ns-3.
Pure virtual base class for the interface between ns-3 and the parallel communication layer being use...
static void TestSendComplete()
Check for completed sends.
virtual uint32_t GetSystemId()
Get the id number of this rank.
uint8_t * m_buffer
The buffer.
Interface between ns-3 and MPI.
void SetBuffer(uint8_t *buffer)
MPI_Request m_request
The MPI request handle.
Tracks non-blocking sends.
virtual bool IsEnabled()
Returns enabled state of parallel environment.
static std::list< SentBuffer > g_pendingTx
List of pending non-blocking sends.
Distributed simulator implementation using lookahead.
Every class exported by the ns3 library is enclosed in the ns3 namespace.
static bool g_mpiInitCalled
Has MPI Init been called by this interface.
Declaration of class ns3::ParallelCommunicationInterface.
static bool g_freeCommunicator
Did ns-3 create the communicator? Have to free it.
virtual void Disable()
Clean up the ns-3 parallel communications interface.
virtual void SendPacket(Ptr< Packet > p, const Time &rxTime, uint32_t node, uint32_t dev)
Send a packet to a remote node.
static char ** g_pRxBuffers
Data buffers for non-blocking reads.
static void ReceiveMessages()
Check for received messages complete.
static bool g_enabled
Has this interface been enabled.
const uint32_t MAX_MPI_MSG_SIZE
maximum MPI message size for easy buffer creation
static uint32_t g_size
Size of the MPI COM_WORLD group.
A base class which provides memory management and object aggregation.
static MPI_Request * g_requests
Pending non-blocking receives.
a unique identifier for an interface.
virtual void Destroy()
Deletes storage used by the parallel environment.