26 #include "ns3/address.h"
27 #include "ns3/inet-socket-address.h"
28 #include "ns3/inet6-socket-address.h"
29 #include "ns3/packet-socket-address.h"
31 #include "ns3/nstime.h"
32 #include "ns3/data-rate.h"
33 #include "ns3/random-variable-stream.h"
34 #include "ns3/socket.h"
35 #include "ns3/simulator.h"
36 #include "ns3/socket-factory.h"
37 #include "ns3/packet.h"
38 #include "ns3/uinteger.h"
39 #include "ns3/trace-source-accessor.h"
41 #include "ns3/udp-socket-factory.h"
42 #include "ns3/string.h"
43 #include "ns3/pointer.h"
56 .AddConstructor<OnOffApplication> ()
57 .AddAttribute (
"DataRate",
"The data rate in on state.",
60 MakeDataRateChecker ())
61 .AddAttribute (
"PacketSize",
"The size of packets sent in on state",
64 MakeUintegerChecker<uint32_t> (1))
65 .AddAttribute (
"Remote",
"The address of the destination",
68 MakeAddressChecker ())
69 .AddAttribute (
"OnTime",
"A RandomVariableStream used to pick the duration of the 'On' state.",
70 StringValue (
"ns3::ConstantRandomVariable[Constant=1.0]"),
72 MakePointerChecker <RandomVariableStream>())
73 .AddAttribute (
"OffTime",
"A RandomVariableStream used to pick the duration of the 'Off' state.",
74 StringValue (
"ns3::ConstantRandomVariable[Constant=1.0]"),
76 MakePointerChecker <RandomVariableStream>())
77 .AddAttribute (
"MaxBytes",
78 "The total number of bytes to send. Once these bytes are sent, "
79 "no packet is sent again, even in on state. The value zero means "
80 "that there is no limit.",
83 MakeUintegerChecker<uint32_t> ())
84 .AddAttribute (
"Protocol",
"The type of protocol to use.",
88 .AddTraceSource (
"Tx",
"A new packet is created and is sent",
99 m_lastStartTime (Seconds (0)),
190 NS_LOG_WARN (
"OnOffApplication found null socket to close in StopApplication");
236 Time nextTime (Seconds (bits /
279 <<
"s on-off application sent "
280 << packet->GetSize () <<
" bytes to "
288 <<
"s on-off application sent "
289 << packet->GetSize () <<
" bytes to "
static TypeId GetTypeId(void)
Get the type ID.
void StopSending()
Start an Off period.
Ipv6Address GetIpv6(void) const
Get the IPv6 address.
Simulation virtual time values and global simulation resolution.
Ipv4Address GetIpv4(void) const
#define NS_LOG_FUNCTION(parameters)
If log level LOG_FUNCTION is enabled, this macro will output all input parameters separated by "...
void SetStream(int64_t stream)
Specifies the stream number for this RNG stream.
virtual void StartApplication(void)
Application specific startup code.
EventId m_sendEvent
Event id of pending "send packet" event.
#define NS_OBJECT_ENSURE_REGISTERED(type)
Register the class in the ns-3 factory.
uint32_t m_pktSize
Size of packets.
virtual int Bind6()=0
Allocate a local IPv6 endpoint for this socket.
hold variables of type string
virtual bool SetAllowBroadcast(bool allowBroadcast)=0
Configure whether broadcast datagram transmissions are allowed.
High precision numerical type, implementing Q64.64 fixed precision.
void ScheduleStartEvent()
Schedule the next On period start.
void CancelEvents()
Cancel all pending events.
#define NS_ASSERT(condition)
At runtime, in debugging builds, if this condition is not true, the program prints the source file...
static bool IsMatchingType(const Address &address)
#define NS_LOG_COMPONENT_DEFINE(name)
Define a Log component with a specific name.
virtual int ShutdownRecv(void)=0
void ScheduleStopEvent()
Schedule the next Off period start.
#define NS_LOG_INFO(msg)
Use NS_LOG to output a message of level LOG_INFO.
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...
bool IsRunning(void) const
This method is syntactic sugar for the ns3::Simulator::isExpired method.
static EventId Schedule(Time const &time, MEM mem_ptr, OBJ obj)
Schedule an event to expire at the relative time "time" is reached.
virtual double GetValue(void)=0
Returns a random double from the underlying distribution.
DataRate m_cbrRateFailSafe
Rate that data is generated (check copy)
Class for representing data rates.
virtual void DoDispose(void)
This method is called by Object::Dispose or by the object's destructor, whichever comes first...
EventId m_startStopEvent
Event id for next start or stop event.
void SendPacket()
Send a packet.
TypeId m_tid
Type of the socket used.
The base class for all ns3 applications.
Address m_peer
Peer address.
DataRate m_cbrRate
Rate that data is generated.
Hold an unsigned integer type.
Ptr< RandomVariableStream > m_onTime
rng for On Time
Ptr< Node > GetNode() const
hold objects of type ns3::TypeId
Ptr< Socket > GetSocket(void) const
Return a pointer to associated socket.
Callback< R > MakeCallback(R(T::*memPtr)(void), OBJ objPtr)
Ptr< Socket > m_socket
Associated socket.
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...
int64_t AssignStreams(int64_t stream)
Assign a fixed random variable stream number to the random variables used by this model...
#define NS_LOG_LOGIC(msg)
Use NS_LOG to output a message of level LOG_LOGIC.
Ptr< RandomVariableStream > m_offTime
rng for Off Time
virtual int Connect(const Address &address)=0
Initiate a connection to a remote host.
virtual void DoDispose(void)
This method is called by Object::Dispose or by the object's destructor, whichever comes first...
TracedCallback< Ptr< const Packet > > m_txTrace
Traced Callback: transmitted packets.
virtual int Bind(const Address &address)=0
Allocate a local endpoint for this socket.
static InetSocketAddress ConvertFrom(const Address &address)
Returns an InetSocketAddress which corresponds to the input Address.
Ptr< const TraceSourceAccessor > MakeTraceSourceAccessor(T a)
void ScheduleNextTx()
Schedule the next packet transmission.
void StartSending()
Start an On period.
uint64_t GetBitRate() const
Get the underlying bitrate.
void SetMaxBytes(uint32_t maxBytes)
Set the total number of bytes to send.
static Time Now(void)
Return the "current simulation time".
void ConnectionSucceeded(Ptr< Socket > socket)
Handle a Connection Succeed event.
virtual ~OnOffApplication()
Time m_lastStartTime
Time last packet sent.
hold objects of type ns3::Address
static TypeId GetTypeId(void)
Get the type ID.
#define NS_LOG_WARN(msg)
Use NS_LOG to output a message of level LOG_WARN.
hold objects of type ns3::DataRate
static Inet6SocketAddress ConvertFrom(const Address &addr)
Convert the address to a InetSocketAddress.
static bool IsMatchingType(const Address &addr)
If the address match.
uint16_t GetPort(void) const
Get the port.
int64_t GetHigh(void) const
Get the integer portion.
uint32_t m_maxBytes
Limit total number of bytes sent.
void ConnectionFailed(Ptr< Socket > socket)
Handle a Connection Failed event.
uint32_t m_totBytes
Total bytes sent so far.
uint16_t GetPort(void) const
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.
bool m_connected
True if connected.
virtual void StopApplication(void)
Application specific shutdown code.
virtual int Send(Ptr< Packet > p, uint32_t flags)=0
Send data (or dummy data) to the remote host.
virtual int Close(void)=0
Close a socket.
bool IsExpired(void) const
This method is syntactic sugar for the ns3::Simulator::isExpired method.
a unique identifier for an interface.
TypeId SetParent(TypeId tid)
uint32_t m_residualBits
Number of generated, but not sent, bits.
static bool IsMatchingType(const Address &address)
int64x64_t To(enum Unit timeUnit) const