A Discrete-Event Network Simulator
Home
Tutorials ▼
English
Docs ▼
Wiki
Manual
Models
Develop ▼
API
Bugs
API
null-message-mpi-interface.h
Go to the documentation of this file.
1
/* -*- Mode:C++; c-file-style:"gnu"; indent-tabs-mode:nil; -*- */
2
/*
3
* Copyright 2013. Lawrence Livermore National Security, LLC.
4
*
5
* This program is free software; you can redistribute it and/or modify
6
* it under the terms of the GNU General Public License version 2 as
7
* published by the Free Software Foundation;
8
*
9
* This program is distributed in the hope that it will be useful,
10
* but WITHOUT ANY WARRANTY; without even the implied warranty of
11
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
12
* GNU General Public License for more details.
13
*
14
* You should have received a copy of the GNU General Public License
15
* along with this program; if not, write to the Free Software
16
* Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
17
*
18
* Author: Steven Smith <smith84@llnl.gov>
19
*
20
*/
21
22
#ifndef NS3_NULLMESSAGE_MPI_INTERFACE_H
23
#define NS3_NULLMESSAGE_MPI_INTERFACE_H
24
25
#include "
parallel-communication-interface.h
"
26
27
#include <ns3/nstime.h>
28
#include <ns3/buffer.h>
29
30
#include "mpi.h"
31
#include <list>
32
33
namespace
ns3
{
34
35
class
RemoteChannelBundle;
36
class
Packet;
37
45
class
NullMessageSentBuffer
46
{
47
public
:
48
NullMessageSentBuffer
();
49
~NullMessageSentBuffer
();
50
54
uint8_t*
GetBuffer
();
58
void
SetBuffer
(uint8_t* buffer);
62
MPI_Request*
GetRequest
();
63
64
private
:
65
69
uint8_t*
m_buffer
;
70
74
MPI_Request
m_request
;
75
};
76
83
class
NullMessageMpiInterface
:
public
ParallelCommunicationInterface
84
{
85
public
:
86
87
NullMessageMpiInterface
();
88
~NullMessageMpiInterface
();
89
93
virtual
void
Destroy
();
97
virtual
uint32_t
GetSystemId
();
101
virtual
uint32_t
GetSize
();
105
virtual
bool
IsEnabled
();
113
virtual
void
Enable
(
int
* pargc,
char
*** pargv);
119
virtual
void
Disable
();
137
virtual
void
SendPacket
(
Ptr<Packet>
p,
const
Time
&rxTime, uint32_t node, uint32_t dev);
162
static
void
SendNullMessage
(
const
Time
& guaranteeUpdate,
Ptr<RemoteChannelBundle>
bundle);
167
static
void
ReceiveMessagesNonBlocking
();
172
static
void
ReceiveMessagesBlocking
();
176
static
void
TestSendComplete
();
177
184
static
void
InitializeSendReceiveBuffers
(
void
);
185
186
private
:
187
195
static
void
ReceiveMessages
(
bool
blocking =
false
);
196
197
// System ID (rank) for this task
198
static
uint32_t
g_sid
;
199
200
// Size of the MPI COM_WORLD group.
201
static
uint32_t
g_size
;
202
203
// Number of neighbor tasks, tasks that this task shares a link with.
204
static
uint32_t
g_numNeighbors
;
205
206
static
bool
g_initialized
;
207
static
bool
g_enabled
;
208
209
// Pending non-blocking receives
210
static
MPI_Request*
g_requests
;
211
212
// Data buffers for non-blocking receives
213
static
char
**
g_pRxBuffers
;
214
215
// List of pending non-blocking sends
216
static
std::list<NullMessageSentBuffer>
g_pendingTx
;
217
};
218
219
}
// namespace ns3
220
221
#endif
/* NS3_NULL_MESSAGE_MPI_INTERFACE_H */
ns3::NullMessageMpiInterface::Destroy
virtual void Destroy()
Delete all buffers.
Definition:
null-message-mpi-interface.cc:102
ns3::NullMessageMpiInterface::g_requests
static MPI_Request * g_requests
Definition:
null-message-mpi-interface.h:210
ns3::Time
Simulation virtual time values and global simulation resolution.
Definition:
nstime.h:102
ns3::Ptr< Packet >
ns3::NullMessageSentBuffer::GetRequest
MPI_Request * GetRequest()
Definition:
null-message-mpi-interface.cc:76
ns3::NullMessageMpiInterface::~NullMessageMpiInterface
~NullMessageMpiInterface()
Definition:
null-message-mpi-interface.cc:96
ns3::NullMessageMpiInterface::GetSystemId
virtual uint32_t GetSystemId()
Definition:
null-message-mpi-interface.cc:108
ns3::NullMessageMpiInterface::ReceiveMessagesNonBlocking
static void ReceiveMessagesNonBlocking()
Non-blocking check for received messages complete.
Definition:
null-message-mpi-interface.cc:257
ns3::NullMessageSentBuffer::GetBuffer
uint8_t * GetBuffer()
Definition:
null-message-mpi-interface.cc:64
ns3::ParallelCommunicationInterface
Pure virtual base class for the interface between ns-3 and the parallel communication layer being use...
Definition:
parallel-communication-interface.h:47
ns3::NullMessageSentBuffer::SetBuffer
void SetBuffer(uint8_t *buffer)
Definition:
null-message-mpi-interface.cc:70
ns3::NullMessageMpiInterface::SendPacket
virtual void SendPacket(Ptr< Packet > p, const Time &rxTime, uint32_t node, uint32_t dev)
Definition:
null-message-mpi-interface.cc:180
ns3::NullMessageMpiInterface::TestSendComplete
static void TestSendComplete()
Check for completed sends.
Definition:
null-message-mpi-interface.cc:364
ns3::NullMessageMpiInterface::GetSize
virtual uint32_t GetSize()
Definition:
null-message-mpi-interface.cc:115
ns3::NullMessageMpiInterface::Enable
virtual void Enable(int *pargc, char ***pargv)
Definition:
null-message-mpi-interface.cc:133
ns3::NullMessageMpiInterface::SendNullMessage
static void SendNullMessage(const Time &guaranteeUpdate, Ptr< RemoteChannelBundle > bundle)
Send a Null Message to across the specified bundle.
Definition:
null-message-mpi-interface.cc:219
ns3::NullMessageMpiInterface::ReceiveMessages
static void ReceiveMessages(bool blocking=false)
Check for received messages complete.
Definition:
null-message-mpi-interface.cc:266
ns3::NullMessageMpiInterface::Disable
virtual void Disable()
Terminates the MPI environment by calling MPI_Finalize This function must be called after Destroy ()...
Definition:
null-message-mpi-interface.cc:386
ns3
Every class exported by the ns3 library is enclosed in the ns3 namespace.
ns3::NullMessageMpiInterface::ReceiveMessagesBlocking
static void ReceiveMessagesBlocking()
Blocking message receive.
Definition:
null-message-mpi-interface.cc:248
ns3::NullMessageMpiInterface::IsEnabled
virtual bool IsEnabled()
Definition:
null-message-mpi-interface.cc:122
parallel-communication-interface.h
ns3::NullMessageSentBuffer::NullMessageSentBuffer
NullMessageSentBuffer()
Definition:
null-message-mpi-interface.cc:52
ns3::NullMessageMpiInterface::g_enabled
static bool g_enabled
Definition:
null-message-mpi-interface.h:207
ns3::NullMessageSentBuffer::m_buffer
uint8_t * m_buffer
Buffer for send.
Definition:
null-message-mpi-interface.h:69
ns3::NullMessageMpiInterface::g_initialized
static bool g_initialized
Definition:
null-message-mpi-interface.h:206
ns3::NullMessageSentBuffer::~NullMessageSentBuffer
~NullMessageSentBuffer()
Definition:
null-message-mpi-interface.cc:58
ns3::NullMessageMpiInterface::g_size
static uint32_t g_size
Definition:
null-message-mpi-interface.h:201
ns3::NullMessageSentBuffer
Non-blocking send buffers for Null Message implementation.
Definition:
null-message-mpi-interface.h:45
ns3::NullMessageMpiInterface::g_pRxBuffers
static char ** g_pRxBuffers
Definition:
null-message-mpi-interface.h:213
ns3::NullMessageMpiInterface::InitializeSendReceiveBuffers
static void InitializeSendReceiveBuffers(void)
Initialize send and receive buffers.
Definition:
null-message-mpi-interface.cc:155
ns3::NullMessageMpiInterface::g_sid
static uint32_t g_sid
Definition:
null-message-mpi-interface.h:198
ns3::NullMessageMpiInterface::g_numNeighbors
static uint32_t g_numNeighbors
Definition:
null-message-mpi-interface.h:204
ns3::NullMessageMpiInterface::g_pendingTx
static std::list< NullMessageSentBuffer > g_pendingTx
Definition:
null-message-mpi-interface.h:216
ns3::NullMessageMpiInterface::NullMessageMpiInterface
NullMessageMpiInterface()
Definition:
null-message-mpi-interface.cc:91
ns3::NullMessageSentBuffer::m_request
MPI_Request m_request
MPI request posted for the send.
Definition:
null-message-mpi-interface.h:74
ns3::NullMessageMpiInterface
Interface between ns-3 and MPI for the Null Message distributed simulation implementation.
Definition:
null-message-mpi-interface.h:83
src
mpi
model
null-message-mpi-interface.h
Generated on Sun Jun 28 2020 12:05:29 for ns-3 by
1.8.14