35 #include <ns3/simulator.h> 36 #include <ns3/scheduler.h> 37 #include <ns3/event-impl.h> 38 #include <ns3/channel.h> 39 #include <ns3/node-container.h> 40 #include <ns3/double.h> 42 #include <ns3/pointer.h> 43 #include <ns3/assert.h> 62 static TypeId tid =
TypeId (
"ns3::NullMessageSimulatorImpl")
66 .AddAttribute (
"SchedulerTune",
"Null Message scheduler tuning parameter",
69 MakeDoubleChecker<double> (0.01,1.0))
130 if (!ev->IsCancelled ())
145 int num_local_nodes = 0;
159 for (uint32_t i = 0; i < (*iter)->GetNDevices (); ++i)
163 if (!localNetDevice->IsPointToPoint ())
175 if (
channel->GetDevice (0) == localNetDevice)
177 remoteNode = (
channel->GetDevice (1))->GetNode ();
181 remoteNode = (
channel->GetDevice (0))->GetNode ();
194 if (!remoteChannelBundle)
200 channel->GetAttribute (
"Delay", delay);
201 remoteChannelBundle->AddChannel (
channel, delay.
Get () );
225 scheduler->Insert (next);
264 return TimeStep (ev.key.m_ts);
408 ev.
key.
m_ts =
static_cast<uint64_t
> (tAbsolute.GetTimeStep ());
429 ev.
key.
m_ts = tAbsolute.GetTimeStep ();
486 if (
id.GetUid () == 2)
504 event.
impl =
id.PeekEventImpl ();
505 event.key.m_ts =
id.GetTs ();
506 event.key.m_context =
id.GetContext ();
507 event.key.m_uid =
id.GetUid ();
509 event.impl->Cancel ();
511 event.impl->Unref ();
521 id.PeekEventImpl ()->Cancel ();
528 if (
id.GetUid () == 2)
530 if (
id.PeekEventImpl () == 0
531 ||
id.PeekEventImpl ()->IsCancelled ())
545 if (
id.PeekEventImpl () == 0
549 ||
id.PeekEventImpl ()->IsCancelled ())
564 return TimeStep (0x7fffffffffffffffLL);
Time CalculateGuaranteeTime(uint32_t systemId)
static EventId Schedule(Time const &delay, FUNC f, Ts &&... args)
Schedule an event to expire after delay.
virtual void Remove(const EventId &id)
Remove an event from the event list.
Simulation virtual time values and global simulation resolution.
Smart pointer class similar to boost::intrusive_ptr.
#define NS_LOG_FUNCTION(parameters)
If log level LOG_FUNCTION is enabled, this macro will output all input parameters separated by "...
void Unref(void) const
Decrement the reference count.
#define NS_OBJECT_ENSURE_REGISTERED(type)
Register an Object subclass with the TypeId system.
std::vector< Ptr< Node > >::const_iterator Iterator
Node container iterator.
virtual void Destroy()
Execute the events scheduled with ScheduleDestroy().
uint64_t m_ts
Event time stamp.
uint64_t m_currentTs
Timestamp of the current event.
void HandleArrivingMessagesNonBlocking(void)
Non blocking receive of pending messages.
Declaration of class ns3::NullMessageSimulatorImpl.
virtual EventId ScheduleNow(EventImpl *event)
Schedule an event to run at the current virtual time.
Ptr< Scheduler > m_events
The event priority queue.
EventImpl * impl
Pointer to the event implementation.
#define NS_ASSERT(condition)
At runtime, in debugging builds, if this condition is not true, the program prints the source file...
U * PeekPointer(const Ptr< U > &p)
~NullMessageSimulatorImpl()
Destructor.
#define NS_LOG_COMPONENT_DEFINE(name)
Define a Log component with a specific name.
virtual bool IsFinished(void) const
Check if the simulation should finish.
static void ReceiveMessagesNonBlocking()
Non-blocking check for received messages complete.
static void Cancel(const EventId &id)
Set the cancel bit on this event: the event's associated function will not be invoked when it expires...
void ProcessOneEvent(void)
Process the next event on the queue.
void(* Time)(Time oldValue, Time newValue)
TracedValue callback signature for Time.
void RescheduleNullMessageEvent(Ptr< RemoteChannelBundle > bundle)
virtual void DoDispose(void)
Destructor implementation.
uint32_t m_currentUid
Unique id of the current event.
Collection of ns-3 channels between local and remote nodes.
Iterator End(void) const
Get an iterator which indicates past-the-last Node in the container.
virtual EventId ScheduleDestroy(EventImpl *event)
Schedule an event to run at the end of the simulation, after the Stop() time or condition has been re...
virtual uint32_t GetContext(void) const
Get the current simulation context.
void CalculateSafeTime(void)
Calculate the SafeTime.
void Invoke(void)
Called by the simulation engine to notify the event that it is time to execute.
static NullMessageSimulatorImpl * GetInstance(void)
uint32_t m_uid
Next event unique id.
static void TestSendComplete()
Check for completed sends.
int64x64_t Min(const int64x64_t &a, const int64x64_t &b)
Minimum.
Declaration of class ns3::MpiInterface.
static Time GetSafeTime(void)
Get the safe time across all channels in this bundle.
EventKey key
Key for sorting and ordering Events.
static void Destroy()
Deletes storage used by the parallel environment.
AttributeValue implementation for Time.
Ptr< Object > Create(void) const
Create an Object instance of the configured TypeId.
uint32_t m_uid
Event unique id.
static void SendNullMessage(const Time &guaranteeUpdate, Ptr< RemoteChannelBundle > bundle)
Send a Null Message to across the specified bundle.
static void InitializeNullMessageEvents(void)
Setup initial Null Message events for every RemoteChannelBundle.
DestroyEvents m_destroyEvents
The container of events to run at Destroy()
Time GetSafeTime(void)
Get the current SafeTime; the maximum time that events can be processed based on information received...
#define NS_LOG_LOGIC(msg)
Use NS_LOG to output a message of level LOG_LOGIC.
virtual uint64_t GetEventCount(void) const
Get the number of events executed.
static void Destroy(void)
Destroy the singleton.
virtual void Run(void)
Run the simulation.
static NullMessageSimulatorImpl * g_instance
Singleton instance.
uint64_t m_eventCount
The event count.
virtual bool IsExpired(const EventId &id) const
Check if an event has already run or been cancelled.
Every class exported by the ns3 library is enclosed in the ns3 namespace.
void CalculateLookAhead(void)
Calculate the lookahead allowable for this MPI task.
keep track of a set of node pointers.
static void ReceiveMessagesBlocking()
Blocking message receive.
virtual void ScheduleWithContext(uint32_t context, Time const &delay, EventImpl *event)
Schedule a future event execution (in a different context).
uint32_t GetSystemId(void) const
static Ptr< RemoteChannelBundle > Find(uint32_t systemId)
Get the bundle corresponding to a remote rank.
void HandleArrivingMessagesBlocking(void)
Blocking receive of arriving messages.
virtual Time Now(void) const
Return the current simulation virtual time.
bool m_stop
Flag calling for the end of the simulation.
Time m_safeTime
The time for which it is safe for this task to execute events without danger of out-of-order events...
Declaration of class ns3::RemoteChannelBundleManager.
NullMessageSimulatorImpl()
Default constructor.
int m_unscheduledEvents
Number of events that have been inserted but not yet scheduled, not counting the "destroy" events; th...
static Ptr< RemoteChannelBundle > Add(uint32_t systemId)
Add RemoteChannelBundle from this task to MPI task on other side of the link.
Simulator implementation using MPI and a Null Message algorithm.
Ptr< const AttributeAccessor > MakeDoubleAccessor(T1 a1)
Create an AttributeAccessor for a class data member, or a lone class get functor or set method...
static NodeContainer GetGlobal(void)
Create a NodeContainer that contains a list of all nodes created through NodeContainer::Create() and ...
Instantiate subclasses of ns3::Object.
Declaration of class ns3::RemoteChannelBundle.
Declaration of classes ns3::NullMessageSentBuffer and ns3::NullMessageMpiInterface.
virtual uint32_t GetSystemId(void) const
Get the system id of this simulator.
An identifier for simulation events.
static uint32_t GetSystemId()
Get the id number of this rank.
virtual Time GetMaximumSimulationTime(void) const
Get the maximum representable simulation time.
static void Stop(void)
Tell the Simulator the calling event should be the last one executed.
virtual void Stop(void)
Tell the Simulator the calling event should be the last one executed.
uint32_t m_currentContext
Execution context of the current event.
Time Seconds(double value)
Construct a Time in the indicated unit.
virtual void Cancel(const EventId &id)
Set the cancel bit on this event: the event's associated function will not be invoked when it expires...
void ScheduleNullMessageEvent(Ptr< RemoteChannelBundle > bundle)
Flag for events not associated with any particular context.
void NullMessageEventHandler(RemoteChannelBundle *bundle)
virtual EventId Schedule(Time const &delay, EventImpl *event)
Schedule a future event execution (in the same context).
virtual void DoDispose(void)
Destructor implementation.
static void InitializeSendReceiveBuffers(void)
Initialize send and receive buffers.
Time GetDelay(void) const
Get the minimum delay along any channel in this bundle.
This class can be used to hold variables of floating point type such as 'double' or 'float'...
double m_schedulerTune
Null Message performance tuning parameter.
a unique identifier for an interface.
virtual void SetScheduler(ObjectFactory schedulerFactory)
Set the Scheduler to be used to manage the event list.
virtual Time GetDelayLeft(const EventId &id) const
Get the remaining time until this event will execute.
static TypeId GetTypeId(void)
Register this type.
TypeId SetParent(TypeId tid)
Set the parent TypeId.
static uint32_t GetSize()
Get the number of ranks used by ns-3.
uint32_t m_context
Event context.
Iterator Begin(void) const
Get an iterator which refers to the first Node in the container.
The SimulatorImpl base class.
uint32_t m_systemCount
MPI communicator size.
int64_t GetTimeStep(void) const
Get the raw time value, in the current resolution unit.