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 .SetGroupName(
"Applications")
58 .AddAttribute (
"DataRate",
"The data rate in on state.",
61 MakeDataRateChecker ())
62 .AddAttribute (
"PacketSize",
"The size of packets sent in on state",
65 MakeUintegerChecker<uint32_t> (1))
66 .AddAttribute (
"Remote",
"The address of the destination",
69 MakeAddressChecker ())
70 .AddAttribute (
"OnTime",
"A RandomVariableStream used to pick the duration of the 'On' state.",
71 StringValue (
"ns3::ConstantRandomVariable[Constant=1.0]"),
73 MakePointerChecker <RandomVariableStream>())
74 .AddAttribute (
"OffTime",
"A RandomVariableStream used to pick the duration of the 'Off' state.",
75 StringValue (
"ns3::ConstantRandomVariable[Constant=1.0]"),
77 MakePointerChecker <RandomVariableStream>())
78 .AddAttribute (
"MaxBytes",
79 "The total number of bytes to send. Once these bytes are sent, "
80 "no packet is sent again, even in on state. The value zero means "
81 "that there is no limit.",
84 MakeUintegerChecker<uint32_t> ())
85 .AddAttribute (
"Protocol",
"The type of protocol to use.",
89 .AddTraceSource (
"Tx",
"A new packet is created and is sent",
91 "ns3::Packet::TracedCallback")
192 NS_LOG_WARN (
"OnOffApplication found null socket to close in StopApplication");
281 <<
"s on-off application sent "
282 << packet->GetSize () <<
" bytes to "
290 <<
"s on-off application sent "
291 << packet->GetSize () <<
" bytes to "
High precision numerical type, implementing Q64.64 fixed precision.
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 an Object subclass with the TypeId system.
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.
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)
Generate traffic to a single destination according to an OnOff pattern.
#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 !IsExpired().
virtual double GetValue(void)=0
Get the next random value as a double drawn from the distribution.
int64x64_t To(enum Unit unit) const
Get the Time value expressed in a particular unit.
Ptr< const TraceSourceAccessor > MakeTraceSourceAccessor(T a)
Create a TraceSourceAccessor which will control access to the underlying trace source.
DataRate m_cbrRateFailSafe
Rate that data is generated (check copy)
Class for representing data rates.
virtual void DoDispose(void)
Destructor implementation.
EventId m_startStopEvent
Event id for next start or stop event.
void SendPacket()
Send a packet.
Ptr< const AttributeAccessor > MakePointerAccessor(T1 a1)
Create an AttributeAccessor for a class data member, or a lone class get functor or set method...
static EventId Schedule(Time const &delay, MEM mem_ptr, OBJ obj)
Schedule an event to expire after delay.
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
AttributeValue implementation for 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)
Destructor implementation.
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.
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 virtual time.
void ConnectionSucceeded(Ptr< Socket > socket)
Handle a Connection Succeed event.
virtual ~OnOffApplication()
Time m_lastStartTime
Time last packet sent.
Ptr< const AttributeAccessor > MakeTypeIdAccessor(T1 a1)
Create an AttributeAccessor for a class data member, or a lone class get functor or set method...
AttributeValue implementation for 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.
AttributeValue implementation for DataRate.
Time Seconds(double value)
Construct a Time in the indicated unit.
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.
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.
Ptr< const AttributeChecker > MakeTypeIdChecker(void)
bool IsExpired(void) const
This method is syntactic sugar for the ns3::Simulator::IsExpired method.
Ptr< const AttributeAccessor > MakeUintegerAccessor(T1 a1)
Create an AttributeAccessor for a class data member, or a lone class get functor or set method...
a unique identifier for an interface.
TypeId SetParent(TypeId tid)
Set the parent TypeId.
uint32_t m_residualBits
Number of generated, but not sent, bits.
static bool IsMatchingType(const Address &address)