48#include "ns3/core-module.h"
49#include "ns3/internet-stack-helper.h"
50#include "ns3/ipv4-address-helper.h"
51#include "ns3/ipv4-global-routing-helper.h"
52#include "ns3/ipv4-list-routing-helper.h"
53#include "ns3/ipv4-static-routing-helper.h"
54#include "ns3/mpi-interface.h"
55#include "ns3/network-module.h"
56#include "ns3/nix-vector-helper.h"
57#include "ns3/on-off-helper.h"
58#include "ns3/packet-sink-helper.h"
59#include "ns3/packet-sink.h"
60#include "ns3/point-to-point-helper.h"
90 MPI_Comm_rank(splitComm, &otherId);
91 MPI_Comm_size(splitComm, &otherSize);
104 << otherId <<
":" << otherSize << std::endl);
109main(
int argc,
char* argv[])
112 bool nullmsg =
false;
116 bool testing =
false;
120 cmd.AddValue(
"nix",
"Enable the use of nix-vector or global routing", nix);
121 cmd.AddValue(
"nullmsg",
122 "Enable the use of null-message synchronization (instead of granted time window)",
124 cmd.AddValue(
"tracing",
"Enable pcap tracing",
tracing);
125 cmd.AddValue(
"init",
"ns-3 should initialize MPI by calling MPI_Init", init);
126 cmd.AddValue(
"verbose",
"verbose output",
verbose);
127 cmd.AddValue(
"test",
"Enable regression test output", testing);
128 cmd.Parse(argc, argv);
149 MPI_Init(&argc, &argv);
162 if ((!init) && (worldSize != 2))
164 RANK0COUT(
"This simulation requires exactly 2 logical processors if --init is not set."
171 RANK0COUT(
"This simulation requires 2 or more logical processors." << std::endl);
181 bool freeComm =
false;
183 MPI_Comm splitComm = MPI_COMM_WORLD;
185 std::string ns3Ranks;
187 int color = MPI_UNDEFINED;
191 std::stringstream ss;
193 ss <<
"MPI_COMM_WORLD (" << worldSize <<
" ranks)";
195 splitComm = MPI_COMM_WORLD;
203 if (worldRank == 1 || worldRank == 2)
211 std::stringstream ss;
212 ss <<
"Split [1-2] (out of " << worldSize <<
" ranks) from MPI_COMM_WORLD";
216 MPI_Comm_split(MPI_COMM_WORLD, color, worldRank, &splitComm);
229 RANK0COUT(
"Routing: " << (nix ?
"nix-vector" :
"global") <<
"\n");
230 RANK0COUT(
"Synchronization: " << (nullmsg ?
"null-message" :
"granted time window (YAWNS)")
233 << (init ?
"explicitly by this program" :
"implicitly by ns3::MpiInterface::Enable()")
235 RANK0COUT(
"ns-3 Communicator: " << ns3Ranks <<
"\n");
238 RANK0COUT(
"Rank assignments:" << std::endl);
256 MPI_Recv(&token, 1, MPI_INT, worldRank - 1, 0, MPI_COMM_WORLD, MPI_STATUS_IGNORE);
260 MPI_Send(&token, 1, MPI_INT, (worldRank + 1) % worldSize, 0, MPI_COMM_WORLD);
264 MPI_Recv(&token, 1, MPI_INT, worldSize - 1, 0, MPI_COMM_WORLD, MPI_STATUS_IGNORE);
308 RANK0COUT(
"This simulation requires at least 2 logical processors." << std::endl);
319 leftLeafNodes.
Create(4, 0);
327 routerNodes.
Add(routerNode1);
328 routerNodes.
Add(routerNode2);
332 rightLeafNodes.
Create(4, 1);
344 routerDevices = routerLink.
Install(routerNodes);
352 leftLeafDevices.
Add(temp.
Get(0));
353 leftRouterDevices.
Add(temp.
Get(1));
362 rightLeafDevices.
Add(temp.
Get(0));
363 rightRouterDevices.
Add(temp.
Get(1));
371 list.
Add(staticRouting, 0);
372 list.Add(nixRouting, 10);
376 stack.SetRoutingHelper(list);
388 leftAddress.
SetBase(
"10.1.1.0",
"255.255.255.0");
391 routerAddress.
SetBase(
"10.2.1.0",
"255.255.255.0");
394 rightAddress.
SetBase(
"10.3.1.0",
"255.255.255.0");
397 routerInterfaces = routerAddress.
Assign(routerDevices);
403 ndc.
Add(leftLeafDevices.
Get(i));
404 ndc.
Add(leftRouterDevices.
Get(i));
406 leftLeafInterfaces.
Add(ifc.
Get(0));
407 leftRouterInterfaces.
Add(ifc.
Get(1));
415 ndc.
Add(rightLeafDevices.
Get(i));
416 ndc.
Add(rightRouterDevices.
Get(i));
418 rightLeafInterfaces.
Add(ifc.
Get(0));
419 rightRouterInterfaces.
Add(ifc.
Get(1));
432 routerLink.
EnablePcap(
"router-left", routerDevices,
true);
433 leafLink.
EnablePcap(
"leaf-left", leftLeafDevices,
true);
438 routerLink.
EnablePcap(
"router-right", routerDevices,
true);
439 leafLink.
EnablePcap(
"leaf-right", rightLeafDevices,
true);
444 uint16_t
port = 50000;
452 auto apps = sinkHelper.Install(rightLeafNodes.
Get(i));
457 sink->TraceConnectWithoutContext(
"RxWithAddresses",
470 clientHelper.SetAttribute(
"OnTime",
StringValue(
"ns3::ConstantRandomVariable[Constant=1]"));
471 clientHelper.SetAttribute(
"OffTime",
472 StringValue(
"ns3::ConstantRandomVariable[Constant=0]"));
478 clientHelper.SetAttribute(
"Remote", remoteAddress);
497 MPI_Comm_free(&splitComm);
a polymophic address class
holds a vector of ns3::Application pointers.
void Start(Time start) const
Start all of the Applications in this container at the start time given as a parameter.
void Stop(Time stop) const
Arrange for all of the Applications in this container to Stop() at the Time given as a parameter.
void Add(ApplicationContainer other)
Append the contents of another ApplicationContainer to the end of this container.
Parse command-line arguments.
static void Bind(std::string name, const AttributeValue &value)
Iterate over the set of GlobalValues until a matching name is found and then set its value with Globa...
aggregate IP/TCP/UDP functionality to existing Nodes.
A helper class to make life easier while doing simple IPv4 address assignment in scripts.
void SetBase(Ipv4Address network, Ipv4Mask mask, Ipv4Address base="0.0.0.1")
Set the base network number, network mask and base address.
Ipv4Address NewNetwork()
Increment the network number and reset the IP address counter to the base value provided in the SetBa...
Ipv4InterfaceContainer Assign(const NetDeviceContainer &c)
Assign IP addresses to the net devices specified in the container based on the current network prefix...
static Ipv4Address GetAny()
static void PopulateRoutingTables()
Build a routing database and initialize the routing tables of the nodes in the simulation.
holds a vector of std::pair of Ptr<Ipv4> and interface index.
std::pair< Ptr< Ipv4 >, uint32_t > Get(uint32_t i) const
Get the std::pair of an Ptr<Ipv4> and interface stored at the location specified by the index.
void Add(const Ipv4InterfaceContainer &other)
Concatenate the entries in the other container with ours.
Ipv4Address GetAddress(uint32_t i, uint32_t j=0) const
Helper class that adds ns3::Ipv4ListRouting objects.
void Add(const Ipv4RoutingHelper &routing, int16_t priority)
Helper class that adds ns3::Ipv4StaticRouting objects.
static uint32_t GetSystemId()
Get the id number of this rank.
static uint32_t GetSize()
Get the number of ranks used by ns-3.
static void Disable()
Clean up the ns-3 parallel communications interface.
static void Enable(int *pargc, char ***pargv)
Setup the parallel communication interface.
holds a vector of ns3::NetDevice pointers
void Add(NetDeviceContainer other)
Append the contents of another NetDeviceContainer to the end of this container.
Ptr< NetDevice > Get(uint32_t i) const
Get the Ptr<NetDevice> stored in this container at a given index.
Helper class that adds Nix-vector routing to nodes.
keep track of a set of node pointers.
void Create(uint32_t n)
Create n nodes and append pointers to them to the end of this NodeContainer.
void Add(const NodeContainer &nc)
Append the contents of another NodeContainer to the end of this container.
Ptr< Node > Get(uint32_t i) const
Get the Ptr<Node> stored in this container at a given index.
A helper to make it easier to instantiate an ns3::OnOffApplication on a set of nodes.
A helper to make it easier to instantiate an ns3::PacketSinkApplication on a set of nodes.
void EnablePcap(std::string prefix, Ptr< NetDevice > nd, bool promiscuous=false, bool explicitFilename=false)
Enable pcap output the indicated net device.
Build a set of PointToPointNetDevice objects.
void SetDeviceAttribute(std::string name, const AttributeValue &value)
Set an attribute value to be propagated to each NetDevice created by the helper.
void SetChannelAttribute(std::string name, const AttributeValue &value)
Set an attribute value to be propagated to each Channel created by the helper.
NetDeviceContainer Install(NodeContainer c)
Smart pointer class similar to boost::intrusive_ptr.
static void Destroy()
Execute the events scheduled with ScheduleDestroy().
static void Run()
Run the simulation.
static void Stop()
Tell the Simulator the calling event should be the last one executed.
static void SinkTrace(const ns3::Ptr< const ns3::Packet > packet, const ns3::Address &srcAddress, const ns3::Address &destAddress)
PacketSink receive trace callback.
static void Verify(unsigned long expectedCount)
Verify the sink trace count observed matches the expected count.
static void Init()
PacketSink Init.
static int GetWorldSize()
Get the MPI size of the world communicator.
static int GetWorldRank()
Get the MPI rank in the world communicator.
Hold variables of type string.
Hold an unsigned integer type.
#define NS_ASSERT_MSG(condition, message)
At runtime, in debugging builds, if this condition is not true, the program prints the message to out...
void SetDefault(std::string name, const AttributeValue &value)
#define NS_LOG_COMPONENT_DEFINE(name)
Define a Log component with a specific name.
#define RANK0COUT(x)
Write to std::cout only from rank 0.
#define RANK0COUTAPPEND(x)
Append to std::cout only from rank 0.
Ptr< T > CreateObject(Args &&... args)
Create an object by type, with varying number of constructor parameters.
Time Seconds(double value)
Construct a Time in the indicated unit.
Common methods for MPI examples.
Every class exported by the ns3 library is enclosed in the ns3 namespace.
void LogComponentEnable(const std::string &name, LogLevel level)
Enable the logging output associated with that log component.
Callback< R, Args... > MakeCallback(R(T::*memPtr)(Args...), OBJ objPtr)
Build Callbacks for class method members which take varying numbers of arguments and potentially retu...
Ptr< T1 > DynamicCast(const Ptr< T2 > &p)
Cast a Ptr.
@ LOG_LEVEL_INFO
LOG_INFO and above.
void ReportRank(int color, MPI_Comm splitComm)
Report my rank, in both MPI_COMM_WORLD and the split communicator.
const int NS_COLOR
Tag for whether this rank should go into a new communicator ns-3 ranks will have color == 1.
const int NOT_NS_COLOR
Tag for whether this rank should go into a new communicator ns-3 ranks will have color == 1.
bool tracing
Flag to enable/disable generation of tracing files.
Ptr< PacketSink > sink
Pointer to the packet sink application.