A Discrete-Event Network Simulator
API
Loading...
Searching...
No Matches
remote-channel-bundle-manager.cc
Go to the documentation of this file.
1/*
2 * Copyright 2013. Lawrence Livermore National Security, LLC.
3 *
4 * This program is free software; you can redistribute it and/or modify
5 * it under the terms of the GNU General Public License version 2 as
6 * published by the Free Software Foundation;
7 *
8 * This program is distributed in the hope that it will be useful,
9 * but WITHOUT ANY WARRANTY; without even the implied warranty of
10 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
11 * GNU General Public License for more details.
12 *
13 * You should have received a copy of the GNU General Public License
14 * along with this program; if not, write to the Free Software
15 * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
16 *
17 * Author: Steven Smith <smith84@llnl.gov>
18 *
19 */
20
28
31
32#include "ns3/simulator.h"
33
34namespace ns3
35{
36
40
41Ptr<RemoteChannelBundle>
43{
44 ns3::RemoteChannelBundleManager::RemoteChannelMap::iterator kv =
45 g_remoteChannelBundles.find(systemId);
46
47 if (kv == g_remoteChannelBundles.end())
48 {
49 return nullptr;
50 }
51 else
52 {
53 return kv->second;
54 }
55}
56
59{
62
63 Ptr<RemoteChannelBundle> remoteChannelBundle = Create<RemoteChannelBundle>(systemId);
64
65 g_remoteChannelBundles[systemId] = remoteChannelBundle;
66
67 return remoteChannelBundle;
68}
69
70std::size_t
72{
73 return g_remoteChannelBundles.size();
74}
75
76void
78{
80
81 for (RemoteChannelMap::const_iterator iter = g_remoteChannelBundles.begin();
82 iter != g_remoteChannelBundles.end();
83 ++iter)
84 {
85 Ptr<RemoteChannelBundle> bundle = iter->second;
86 bundle->Send(bundle->GetDelay());
87
89 }
90
91 g_initialized = true;
92}
93
94Time
96{
98
100
101 for (RemoteChannelMap::const_iterator kv = g_remoteChannelBundles.begin();
102 kv != g_remoteChannelBundles.end();
103 ++kv)
104 {
105 safeTime = Min(safeTime, kv->second->GetGuaranteeTime());
106 }
107
108 return safeTime;
109}
110
111void
113{
115
117 g_initialized = false;
118}
119
120} // namespace ns3
#define Min(a, b)
static NullMessageSimulatorImpl * GetInstance()
void ScheduleNullMessageEvent(Ptr< RemoteChannelBundle > bundle)
Smart pointer class similar to boost::intrusive_ptr.
Definition: ptr.h:78
static Time GetSafeTime()
Get the safe time across all channels in this bundle.
static Ptr< RemoteChannelBundle > Find(uint32_t systemId)
Get the bundle corresponding to a remote rank.
static void InitializeNullMessageEvents()
Setup initial Null Message events for every RemoteChannelBundle.
static RemoteChannelMap g_remoteChannelBundles
The remote channel bundles.
static Ptr< RemoteChannelBundle > Add(uint32_t systemId)
Add RemoteChannelBundle from this task to MPI task on other side of the link.
std::unordered_map< uint32_t, Ptr< RemoteChannelBundle > > RemoteChannelMap
Container for all remote channel bundles for this task.
static std::size_t Size()
Get the number of ns-3 channels in this bundle.
static void Destroy()
Destroy the singleton.
static bool g_initialized
Protect manager class from being initialized twice or incorrect ordering of method calls.
static Time GetMaximumSimulationTime()
Get the maximum representable simulation time.
Definition: simulator.cc:302
Simulation virtual time values and global simulation resolution.
Definition: nstime.h:105
#define NS_ASSERT(condition)
At runtime, in debugging builds, if this condition is not true, the program prints the source file,...
Definition: assert.h:66
Every class exported by the ns3 library is enclosed in the ns3 namespace.
Declaration of class ns3::NullMessageSimulatorImpl.
Declaration of class ns3::RemoteChannelBundleManager.
Declaration of class ns3::RemoteChannelBundle.