A Discrete-Event Network Simulator
API
Loading...
Searching...
No Matches
onoff-application.cc
Go to the documentation of this file.
1//
2// Copyright (c) 2006 Georgia Tech Research Corporation
3//
4// SPDX-License-Identifier: GPL-2.0-only
5//
6// Author: George F. Riley<riley@ece.gatech.edu>
7//
8
9// ns3 - On/Off Data Source Application class
10// George F. Riley, Georgia Tech, Spring 2007
11// Adapted from ApplicationOnOff in GTNetS.
12
13#include "onoff-application.h"
14
15#include "ns3/address.h"
16#include "ns3/boolean.h"
17#include "ns3/data-rate.h"
18#include "ns3/inet-socket-address.h"
19#include "ns3/inet6-socket-address.h"
20#include "ns3/log.h"
21#include "ns3/node.h"
22#include "ns3/nstime.h"
23#include "ns3/packet-socket-address.h"
24#include "ns3/packet.h"
25#include "ns3/pointer.h"
26#include "ns3/random-variable-stream.h"
27#include "ns3/simulator.h"
28#include "ns3/socket-factory.h"
29#include "ns3/socket.h"
30#include "ns3/string.h"
31#include "ns3/trace-source-accessor.h"
32#include "ns3/udp-socket-factory.h"
33#include "ns3/uinteger.h"
34
35namespace ns3
36{
37
38NS_LOG_COMPONENT_DEFINE("OnOffApplication");
39
40NS_OBJECT_ENSURE_REGISTERED(OnOffApplication);
41
42TypeId
44{
45 static TypeId tid =
46 TypeId("ns3::OnOffApplication")
48 .SetGroupName("Applications")
49 .AddConstructor<OnOffApplication>()
50 .AddAttribute("DataRate",
51 "The data rate in on state.",
52 DataRateValue(DataRate("500kb/s")),
55 .AddAttribute("PacketSize",
56 "The size of packets sent in on state",
57 UintegerValue(512),
60 .AddAttribute("Remote",
61 "The address of the destination",
65 .AddAttribute("Local",
66 "The Address on which to bind the socket. If not set, it is generated "
67 "automatically.",
71 .AddAttribute("Tos",
72 "The Type of Service used to send IPv4 packets. "
73 "All 8 bits of the TOS byte are set (including ECN bits).",
77 .AddAttribute("OnTime",
78 "A RandomVariableStream used to pick the duration of the 'On' state.",
79 StringValue("ns3::ConstantRandomVariable[Constant=1.0]"),
82 .AddAttribute("OffTime",
83 "A RandomVariableStream used to pick the duration of the 'Off' state.",
84 StringValue("ns3::ConstantRandomVariable[Constant=1.0]"),
87 .AddAttribute("MaxBytes",
88 "The total number of bytes to send. Once these bytes are sent, "
89 "no packet is sent again, even in on state. The value zero means "
90 "that there is no limit.",
94 .AddAttribute("Protocol",
95 "The type of protocol to use. This should be "
96 "a subclass of ns3::SocketFactory",
99 // This should check for SocketFactory as a parent
101 .AddAttribute("EnableSeqTsSizeHeader",
102 "Enable use of SeqTsSizeHeader for sequence number and timestamp",
103 BooleanValue(false),
106 .AddTraceSource("Tx",
107 "A new packet is created and is sent",
109 "ns3::Packet::TracedCallback")
110 .AddTraceSource("TxWithAddresses",
111 "A new packet is created and is sent",
113 "ns3::Packet::TwoAddressTracedCallback")
114 .AddTraceSource("TxWithSeqTsSize",
115 "A new packet is created with SeqTsSizeHeader",
117 "ns3::PacketSink::SeqTsSizeCallback");
118 return tid;
119}
120
122 : m_socket(nullptr),
123 m_connected(false),
124 m_residualBits(0),
125 m_lastStartTime(Seconds(0)),
126 m_totBytes(0),
127 m_unsentPacket(nullptr)
128{
129 NS_LOG_FUNCTION(this);
130}
131
136
137void
139{
140 NS_LOG_FUNCTION(this << maxBytes);
141 m_maxBytes = maxBytes;
142}
143
146{
147 NS_LOG_FUNCTION(this);
148 return m_socket;
149}
150
151int64_t
153{
154 NS_LOG_FUNCTION(this << stream);
155 m_onTime->SetStream(stream);
156 m_offTime->SetStream(stream + 1);
157 return 2;
158}
159
160void
162{
163 NS_LOG_FUNCTION(this);
164
165 CancelEvents();
166 m_socket = nullptr;
167 m_unsentPacket = nullptr;
168 // chain up
170}
171
172// Application Methods
173void
174OnOffApplication::StartApplication() // Called at time specified by Start
175{
176 NS_LOG_FUNCTION(this);
177
178 // Create the socket if not already
179 if (!m_socket)
180 {
182 int ret = -1;
183
184 NS_ABORT_MSG_IF(m_peer.IsInvalid(), "'Remote' attribute not properly set");
185
186 if (!m_local.IsInvalid())
187 {
192 "Incompatible peer and local address IP version");
193 ret = m_socket->Bind(m_local);
194 }
195 else
196 {
198 {
199 ret = m_socket->Bind6();
200 }
203 {
204 ret = m_socket->Bind();
205 }
206 }
207
208 if (ret == -1)
209 {
210 NS_FATAL_ERROR("Failed to bind socket");
211 }
212
215
217 {
218 m_socket->SetIpTos(m_tos); // Affects only IPv4 sockets.
219 }
223 }
225
226 // Ensure no pending event
227 CancelEvents();
228
229 // If we are not yet connected, there is nothing to do here,
230 // the ConnectionComplete upcall will start timers at that time.
231 // If we are already connected, CancelEvents did remove the events,
232 // so we have to start them again.
233 if (m_connected)
234 {
236 }
237}
238
239void
240OnOffApplication::StopApplication() // Called at time specified by Stop
241{
242 NS_LOG_FUNCTION(this);
243
244 CancelEvents();
245 if (m_socket)
246 {
247 m_socket->Close();
248 }
249 else
250 {
251 NS_LOG_WARN("OnOffApplication found null socket to close in StopApplication");
252 }
253}
254
255void
257{
258 NS_LOG_FUNCTION(this);
259
261 { // Cancel the pending send packet event
262 // Calculate residual bits since last packet sent
264 int64x64_t bits = delta.To(Time::S) * m_cbrRate.GetBitRate();
265 m_residualBits += bits.GetHigh();
266 }
270 // Canceling events may cause discontinuity in sequence number if the
271 // SeqTsSizeHeader is header, and m_unsentPacket is true
272 if (m_unsentPacket)
273 {
274 NS_LOG_DEBUG("Discarding cached packet upon CancelEvents ()");
275 }
276 m_unsentPacket = nullptr;
277}
278
279// Event handlers
280void
282{
283 NS_LOG_FUNCTION(this);
285 ScheduleNextTx(); // Schedule the send packet event
287}
288
289void
297
298// Private helpers
299void
301{
302 NS_LOG_FUNCTION(this);
303
304 if (m_maxBytes == 0 || m_totBytes < m_maxBytes)
305 {
307 "Calculation to compute next send time will overflow");
308 uint32_t bits = m_pktSize * 8 - m_residualBits;
309 NS_LOG_LOGIC("bits = " << bits);
310 Time nextTime(
311 Seconds(bits / static_cast<double>(m_cbrRate.GetBitRate()))); // Time till next packet
312 NS_LOG_LOGIC("nextTime = " << nextTime.As(Time::S));
314 }
315 else
316 { // All done, cancel any pending events
318 }
319}
320
321void
323{ // Schedules the event to start sending data (switch to the "On" state)
324 NS_LOG_FUNCTION(this);
325
326 Time offInterval = Seconds(m_offTime->GetValue());
327 NS_LOG_LOGIC("start at " << offInterval.As(Time::S));
329}
330
331void
333{ // Schedules the event to stop sending data (switch to "Off" state)
334 NS_LOG_FUNCTION(this);
335
336 Time onInterval = Seconds(m_onTime->GetValue());
337 NS_LOG_LOGIC("stop at " << onInterval.As(Time::S));
339}
340
341void
343{
344 NS_LOG_FUNCTION(this);
345
347
348 Ptr<Packet> packet;
349 if (m_unsentPacket)
350 {
351 packet = m_unsentPacket;
352 }
354 {
355 Address from;
356 Address to;
357 m_socket->GetSockName(from);
359 SeqTsSizeHeader header;
360 header.SetSeq(m_seq++);
361 header.SetSize(m_pktSize);
363 packet = Create<Packet>(m_pktSize - header.GetSerializedSize());
364 // Trace before adding header, for consistency with PacketSink
365 m_txTraceWithSeqTsSize(packet, from, to, header);
366 packet->AddHeader(header);
367 }
368 else
369 {
370 packet = Create<Packet>(m_pktSize);
371 }
372
373 int actual = m_socket->Send(packet);
374 if ((unsigned)actual == m_pktSize)
375 {
376 m_txTrace(packet);
378 m_unsentPacket = nullptr;
379 Address localAddress;
380 m_socket->GetSockName(localAddress);
382 {
383 NS_LOG_INFO("At time " << Simulator::Now().As(Time::S) << " on-off application sent "
384 << packet->GetSize() << " bytes to "
387 << " total Tx " << m_totBytes << " bytes");
389 }
391 {
392 NS_LOG_INFO("At time " << Simulator::Now().As(Time::S) << " on-off application sent "
393 << packet->GetSize() << " bytes to "
396 << " total Tx " << m_totBytes << " bytes");
398 }
399 }
400 else
401 {
402 NS_LOG_DEBUG("Unable to send packet; actual " << actual << " size " << m_pktSize
403 << "; caching for later attempt");
404 m_unsentPacket = packet;
405 }
406 m_residualBits = 0;
409}
410
411void
413{
414 NS_LOG_FUNCTION(this << socket);
415
417 m_connected = true;
418}
419
420void
422{
423 NS_LOG_FUNCTION(this << socket);
424 NS_FATAL_ERROR("Can't connect");
425}
426
427} // Namespace ns3
a polymophic address class
Definition address.h:90
bool IsInvalid() const
Definition address.cc:60
The base class for all ns3 applications.
Definition application.h:51
void DoDispose() override
Destructor implementation.
Ptr< Node > GetNode() const
Class for representing data rates.
Definition data-rate.h:78
uint64_t GetBitRate() const
Get the underlying bitrate.
Definition data-rate.cc:234
bool IsPending() const
This method is syntactic sugar for !IsExpired().
Definition event-id.cc:65
bool IsExpired() const
This method is syntactic sugar for the ns3::Simulator::IsExpired method.
Definition event-id.cc:58
static Inet6SocketAddress ConvertFrom(const Address &addr)
Convert the address to a InetSocketAddress.
uint16_t GetPort() const
Get the port.
static bool IsMatchingType(const Address &addr)
If the address match.
Ipv6Address GetIpv6() const
Get the IPv6 address.
static bool IsMatchingType(const Address &address)
Ipv4Address GetIpv4() const
static InetSocketAddress ConvertFrom(const Address &address)
Returns an InetSocketAddress which corresponds to the input Address.
Generate traffic to a single destination according to an OnOff pattern.
static TypeId GetTypeId()
Get the type ID.
uint8_t m_tos
The packets Type of Service.
uint32_t m_residualBits
Number of generated, but not sent, bits.
void ConnectionSucceeded(Ptr< Socket > socket)
Handle a Connection Succeed event.
EventId m_sendEvent
Event id of pending "send packet" event.
void ScheduleStartEvent()
Schedule the next On period start.
bool m_connected
True if connected.
uint32_t m_pktSize
Size of packets.
Ptr< Socket > GetSocket() const
Return a pointer to associated socket.
Ptr< Socket > m_socket
Associated socket.
TracedCallback< Ptr< const Packet > > m_txTrace
Traced Callback: transmitted packets.
void SetMaxBytes(uint64_t maxBytes)
Set the total number of bytes to send.
Ptr< RandomVariableStream > m_offTime
rng for Off Time
void StartApplication() override
Application specific startup code.
Ptr< Packet > m_unsentPacket
Unsent packet cached for future attempt.
int64_t AssignStreams(int64_t stream) override
Assign a fixed random variable stream number to the random variables used by this Application object.
TracedCallback< Ptr< const Packet >, const Address &, const Address & > m_txTraceWithAddresses
Callbacks for tracing the packet Tx events, includes source and destination addresses.
void DoDispose() override
Destructor implementation.
EventId m_startStopEvent
Event id for next start or stop event.
void ScheduleNextTx()
Schedule the next packet transmission.
DataRate m_cbrRateFailSafe
Rate that data is generated (check copy)
void ConnectionFailed(Ptr< Socket > socket)
Handle a Connection Failed event.
void ScheduleStopEvent()
Schedule the next Off period start.
TracedCallback< Ptr< const Packet >, const Address &, const Address &, const SeqTsSizeHeader & > m_txTraceWithSeqTsSize
Callback for tracing the packet Tx events, includes source, destination, the packet sent,...
uint64_t m_maxBytes
Limit total number of bytes sent.
Time m_lastStartTime
Time last packet sent.
uint64_t m_totBytes
Total bytes sent so far.
void StopSending()
Start an Off period.
void StartSending()
Start an On period.
Address m_local
Local address to bind to.
Ptr< RandomVariableStream > m_onTime
rng for On Time
bool m_enableSeqTsSizeHeader
Enable or disable the use of SeqTsSizeHeader.
TypeId m_tid
Type of the socket used.
uint32_t m_seq
Sequence.
DataRate m_cbrRate
Rate that data is generated.
void StopApplication() override
Application specific shutdown code.
Address m_peer
Peer address.
void CancelEvents()
Cancel all pending events.
void SendPacket()
Send a packet.
static bool IsMatchingType(const Address &address)
Smart pointer class similar to boost::intrusive_ptr.
virtual double GetValue()=0
Get the next random value drawn from the distribution.
void SetStream(int64_t stream)
Specifies the stream number for the RngStream.
void SetSeq(uint32_t seq)
Header with a sequence, a timestamp, and a "size" attribute.
uint32_t GetSerializedSize() const override
void SetSize(uint64_t size)
Set the size information that the header will carry.
static EventId Schedule(const Time &delay, FUNC f, Ts &&... args)
Schedule an event to expire after delay.
Definition simulator.h:560
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...
Definition simulator.cc:274
static Time Now()
Return the current simulation virtual time.
Definition simulator.cc:197
virtual int Send(Ptr< Packet > p, uint32_t flags)=0
Send data (or dummy data) to the remote host.
void SetConnectCallback(Callback< void, Ptr< Socket > > connectionSucceeded, Callback< void, Ptr< Socket > > connectionFailed)
Specify callbacks to allow the caller to determine if the connection succeeds of fails.
Definition socket.cc:76
void SetIpTos(uint8_t ipTos)
Manually set IP Type of Service field.
Definition socket.cc:423
virtual bool SetAllowBroadcast(bool allowBroadcast)=0
Configure whether broadcast datagram transmissions are allowed.
virtual int ShutdownRecv()=0
virtual int Bind6()=0
Allocate a local IPv6 endpoint for this socket.
virtual int GetPeerName(Address &address) const =0
Get the peer address of a connected socket.
virtual int Connect(const Address &address)=0
Initiate a connection to a remote host.
virtual int GetSockName(Address &address) const =0
Get socket address.
static Ptr< Socket > CreateSocket(Ptr< Node > node, TypeId tid)
This method wraps the creation of sockets that is performed on a given node by a SocketFactory specif...
Definition socket.cc:61
virtual int Close()=0
Close a socket.
virtual int Bind(const Address &address)=0
Allocate a local endpoint for this socket.
Hold variables of type string.
Definition string.h:45
Simulation virtual time values and global simulation resolution.
Definition nstime.h:94
TimeWithUnit As(const Unit unit=Time::AUTO) const
Attach a unit to a Time, to facilitate output in a specific unit.
Definition time.cc:404
@ S
second
Definition nstime.h:105
a unique identifier for an interface.
Definition type-id.h:48
TypeId SetParent(TypeId tid)
Set the parent TypeId.
Definition type-id.cc:1001
static TypeId GetTypeId()
Get the type ID.
Hold an unsigned integer type.
Definition uinteger.h:34
High precision numerical type, implementing Q64.64 fixed precision.
int64_t GetHigh() const
Get the integer portion.
#define NS_ASSERT(condition)
At runtime, in debugging builds, if this condition is not true, the program prints the source file,...
Definition assert.h:55
Ptr< const AttributeAccessor > MakePointerAccessor(T1 a1)
Create an AttributeAccessor for a class data member, or a lone class get functor or set method.
Definition pointer.h:248
Ptr< AttributeChecker > MakePointerChecker()
Create a PointerChecker for a type.
Definition pointer.h:269
#define NS_FATAL_ERROR(msg)
Report a fatal error with a message and terminate.
#define NS_ABORT_MSG_IF(cond, msg)
Abnormal program termination if a condition is true, with a message.
Definition abort.h:97
#define NS_ABORT_IF(cond)
Abnormal program termination if a condition is true.
Definition abort.h:65
#define NS_LOG_COMPONENT_DEFINE(name)
Define a Log component with a specific name.
Definition log.h:191
#define NS_LOG_DEBUG(msg)
Use NS_LOG to output a message of level LOG_DEBUG.
Definition log.h:257
#define NS_LOG_LOGIC(msg)
Use NS_LOG to output a message of level LOG_LOGIC.
Definition log.h:271
#define NS_LOG_FUNCTION(parameters)
If log level LOG_FUNCTION is enabled, this macro will output all input parameters separated by ",...
#define NS_LOG_WARN(msg)
Use NS_LOG to output a message of level LOG_WARN.
Definition log.h:250
#define NS_LOG_INFO(msg)
Use NS_LOG to output a message of level LOG_INFO.
Definition log.h:264
#define NS_OBJECT_ENSURE_REGISTERED(type)
Register an Object subclass with the TypeId system.
Definition object-base.h:35
Ptr< T > Create(Ts &&... args)
Create class instances by constructors with varying numbers of arguments and return them by Ptr.
Definition ptr.h:436
Time Seconds(double value)
Construct a Time in the indicated unit.
Definition nstime.h:1308
Ptr< const TraceSourceAccessor > MakeTraceSourceAccessor(T a)
Create a TraceSourceAccessor which will control access to the underlying trace source.
Every class exported by the ns3 library is enclosed in the ns3 namespace.
Ptr< const AttributeChecker > MakeBooleanChecker()
Definition boolean.cc:113
Ptr< const AttributeChecker > MakeUintegerChecker()
Definition uinteger.h:85
Ptr< const AttributeAccessor > MakeDataRateAccessor(T1 a1)
Definition data-rate.h:285
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...
Definition callback.h:684
Ptr< const AttributeAccessor > MakeUintegerAccessor(T1 a1)
Definition uinteger.h:35
Ptr< const AttributeChecker > MakeAddressChecker()
Definition address.cc:169
Ptr< const AttributeChecker > MakeDataRateChecker()
Definition data-rate.cc:20
Ptr< const AttributeChecker > MakeTypeIdChecker()
Definition type-id.cc:1320
Ptr< const AttributeAccessor > MakeBooleanAccessor(T1 a1)
Definition boolean.h:70
Ptr< const AttributeAccessor > MakeAddressAccessor(T1 a1)
Definition address.h:275
Ptr< const AttributeAccessor > MakeTypeIdAccessor(T1 a1)
Definition type-id.h:617