30 #include "ns3/simulator.h" 31 #include "ns3/scheduler.h" 32 #include "ns3/event-impl.h" 33 #include "ns3/channel.h" 34 #include "ns3/node-container.h" 36 #include "ns3/pointer.h" 37 #include "ns3/assert.h" 92 static TypeId tid =
TypeId (
"ns3::DistributedSimulatorImpl")
157 if (!ev->IsCancelled ())
187 for (uint32_t i = 0; i < (*iter)->GetNDevices (); ++i)
191 if (!localNetDevice->IsPointToPoint ())
203 if (
channel->GetDevice (0) == localNetDevice)
205 remoteNode = (
channel->GetDevice (1))->GetNode ();
209 remoteNode = (
channel->GetDevice (0))->GetNode ();
222 channel->GetAttribute (
"Delay", delay);
281 if (lookAhead >
Time (0))
288 NS_LOG_WARN (
"attempted to set lookahead to a negative time: " << lookAhead);
304 scheduler->Insert (next);
360 return TimeStep (
NextTs ());
405 if (
m_pLBTS[i].GetSmallestTime () < smallestTime)
483 ev.
key.
m_ts =
static_cast<uint64_t
> (tAbsolute.GetTimeStep ());
500 ev.key.m_context = context;
501 ev.key.m_uid =
m_uid;
556 if (
id.GetUid () == 2)
574 event.
impl =
id.PeekEventImpl ();
575 event.key.m_ts =
id.GetTs ();
576 event.key.m_context =
id.GetContext ();
577 event.key.m_uid =
id.GetUid ();
579 event.impl->Cancel ();
581 event.impl->Unref ();
591 id.PeekEventImpl ()->Cancel ();
598 if (
id.GetUid () == 2)
600 if (
id.PeekEventImpl () == 0
601 ||
id.PeekEventImpl ()->IsCancelled ())
615 if (
id.PeekEventImpl () == 0
619 ||
id.PeekEventImpl ()->IsCancelled ())
634 return TimeStep (0x7fffffffffffffffLL);
static EventId Schedule(Time const &delay, FUNC f, Ts &&... args)
Schedule an event to expire after delay.
Time m_grantedTime
End of current window.
Simulation virtual time values and global simulation resolution.
~DistributedSimulatorImpl()
Destructor.
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 "...
virtual void SetScheduler(ObjectFactory schedulerFactory)
Set the Scheduler to be used to manage the event list.
uint32_t m_myId
System Id of the rank sending this LBTS.
virtual uint32_t GetContext(void) const
Get the current simulation context.
Ptr< Scheduler > m_events
The event priority queue.
void Unref(void) const
Decrement the reference count.
#define NS_OBJECT_ENSURE_REGISTERED(type)
Register an Object subclass with the TypeId system.
uint32_t m_systemCount
MPI communicator size.
static MPI_Comm GetCommunicator()
Return the communicator used to run ns-3.
int64_t GetInteger(void) const
Get the raw time value, in the current resolution unit.
std::vector< Ptr< Node > >::const_iterator Iterator
Node container iterator.
uint64_t m_ts
Event time stamp.
static uint32_t GetRxCount()
virtual EventId Schedule(Time const &delay, EventImpl *event)
Schedule a future event execution (in the same context).
bool IsLocalFinished(void) const
Check if this rank is finished.
Time Next(void) const
Get the time of the next event, as returned by NextTs().
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...
#define NS_LOG_COMPONENT_DEFINE(name)
Define a Log component with a specific name.
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...
static uint32_t GetTxCount()
void(* Time)(Time oldValue, Time newValue)
TracedValue callback signature for Time.
virtual void DoDispose(void)
Destructor implementation.
Iterator End(void) const
Get an iterator which indicates past-the-last Node in the container.
uint64_t m_eventCount
The event count.
uint32_t m_txCount
Count of transmitted messages.
virtual Time GetDelayLeft(const EventId &id) const
Get the remaining time until this event will execute.
virtual void DoDispose(void)
Destructor implementation.
void Invoke(void)
Called by the simulation engine to notify the event that it is time to execute.
virtual Time GetMaximumSimulationTime(void) const
Get the maximum representable simulation time.
static Time Max()
Maximum representable Time Not to be confused with Max(Time,Time).
static void TestSendComplete()
Check for completed sends.
int64x64_t Min(const int64x64_t &a, const int64x64_t &b)
Minimum.
Declaration of class ns3::MpiInterface.
void ProcessOneEvent(void)
Process the next event.
EventKey key
Key for sorting and ordering Events.
virtual bool IsFinished(void) const
Check if the simulation should finish.
uint32_t m_currentContext
Execution context of the current event.
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.
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...
DistributedSimulatorImpl()
Default constructor.
virtual EventId ScheduleNow(EventImpl *event)
Schedule an event to run at the current virtual time.
virtual uint64_t GetEventCount(void) const
Get the number of events executed.
DestroyEvents m_destroyEvents
The container of events to run at Destroy()
bool m_stop
Flag calling for the end of the simulation.
#define NS_LOG_LOGIC(msg)
Use NS_LOG to output a message of level LOG_LOGIC.
virtual bool IsExpired(const EventId &id) const
Check if an event has already run or been cancelled.
static TypeId GetTypeId(void)
Register this type.
Time m_smallestTime
Earliest next event timestamp.
Distributed simulator implementation using lookahead.
Every class exported by the ns3 library is enclosed in the ns3 namespace.
keep track of a set of node pointers.
virtual uint32_t GetSystemId(void) const
Get the system id of this simulator.
virtual void Destroy()
Execute the events scheduled with ScheduleDestroy().
uint32_t GetSystemId(void) const
static Time m_lookAhead
Current window size.
uint64_t m_currentTs
Timestamp of the current event.
int m_unscheduledEvents
Number of events that have been inserted but not yet scheduled, not counting the "destroy" events; th...
Structure used for all-reduce LBTS computation.
static NodeContainer GetGlobal(void)
Create a NodeContainer that contains a list of all nodes created through NodeContainer::Create() and ...
void CalculateLookAhead(void)
Calculate lookahead constraint based on network latency.
virtual void Remove(const EventId &id)
Remove an event from the event list.
Instantiate subclasses of ns3::Object.
uint32_t m_rxCount
Count of received messages.
static void ReceiveMessages()
Check for received messages complete.
An identifier for simulation events.
static uint32_t GetSystemId()
Get the id number of this rank.
#define NS_LOG_WARN(msg)
Use NS_LOG to output a message of level LOG_WARN.
static void Stop(void)
Tell the Simulator the calling event should be the last one executed.
Time Seconds(double value)
Construct a Time in the indicated unit.
uint32_t m_uid
Next event unique id.
Flag for events not associated with any particular context.
bool m_globalFinished
Are all parallel instances completed.
virtual void BoundLookAhead(const Time lookAhead)
Add additional bound to lookahead constraints.
Declaration of classes ns3::SentBuffer and ns3::GrantedTimeWindowMpiInterface.
virtual void ScheduleWithContext(uint32_t context, Time const &delay, EventImpl *event)
Schedule a future event execution (in a different context).
LbtsMessage * m_pLBTS
Container for Lbts messages, one per rank.
virtual Time Now(void) const
Return the current simulation virtual time.
virtual void Run(void)
Run the simulation.
uint32_t m_currentUid
Unique id of the current event.
virtual void Stop(void)
Tell the Simulator the calling event should be the last one executed.
a unique identifier for an interface.
uint64_t NextTs(void) const
Get the timestep of the next event.
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.
Declaration of classes ns3::LbtsMessage and ns3::DistributedSimulatorImpl.
bool m_isFinished
true when this rank has no more events.
int64_t GetTimeStep(void) const
Get the raw time value, in the current resolution unit.