19 #include "ns3/ipv4-address.h"
20 #include "ns3/ipv6-address.h"
21 #include "ns3/nstime.h"
22 #include "ns3/inet-socket-address.h"
23 #include "ns3/inet6-socket-address.h"
24 #include "ns3/socket.h"
25 #include "ns3/simulator.h"
26 #include "ns3/socket-factory.h"
27 #include "ns3/packet.h"
28 #include "ns3/uinteger.h"
29 #include "ns3/trace-source-accessor.h"
30 #include "udp-echo-client.h"
35 NS_OBJECT_ENSURE_REGISTERED (UdpEchoClient);
38 UdpEchoClient::GetTypeId (
void)
40 static TypeId tid = TypeId (
"ns3::UdpEchoClient")
41 .SetParent<Application> ()
42 .AddConstructor<UdpEchoClient> ()
43 .AddAttribute (
"MaxPackets",
44 "The maximum number of packets the application will send",
46 MakeUintegerAccessor (&UdpEchoClient::m_count),
47 MakeUintegerChecker<uint32_t> ())
48 .AddAttribute (
"Interval",
49 "The time to wait between packets",
51 MakeTimeAccessor (&UdpEchoClient::m_interval),
53 .AddAttribute (
"RemoteAddress",
54 "The destination Address of the outbound packets",
56 MakeAddressAccessor (&UdpEchoClient::m_peerAddress),
57 MakeAddressChecker ())
58 .AddAttribute (
"RemotePort",
59 "The destination port of the outbound packets",
61 MakeUintegerAccessor (&UdpEchoClient::m_peerPort),
62 MakeUintegerChecker<uint16_t> ())
63 .AddAttribute (
"PacketSize",
"Size of echo data in outbound packets",
67 MakeUintegerChecker<uint32_t> ())
68 .AddTraceSource (
"Tx",
"A new packet is created and is sent",
74 UdpEchoClient::UdpEchoClient ()
79 m_sendEvent = EventId ();
84 UdpEchoClient::~UdpEchoClient()
114 m_peerAddress = Address (ip);
148 ScheduleTransmit (
Seconds (0.));
194 uint32_t dataSize = fill.size () + 1;
196 if (dataSize != m_dataSize)
199 m_data =
new uint8_t [dataSize];
200 m_dataSize = dataSize;
203 memcpy (m_data, fill.c_str (), dataSize);
215 if (dataSize != m_dataSize)
218 m_data =
new uint8_t [dataSize];
219 m_dataSize = dataSize;
222 memset (m_data, fill, dataSize);
234 if (dataSize != m_dataSize)
237 m_data =
new uint8_t [dataSize];
238 m_dataSize = dataSize;
241 if (fillSize >= dataSize)
243 memcpy (m_data, fill, dataSize);
252 while (filled + fillSize < dataSize)
254 memcpy (&m_data[filled], fill, fillSize);
261 memcpy (&m_data[filled], fill, dataSize - filled);
270 UdpEchoClient::ScheduleTransmit (
Time dt)
277 UdpEchoClient::Send (
void)
292 NS_ASSERT_MSG (m_dataSize == m_size,
"UdpEchoClient::Send(): m_size and m_dataSize inconsistent");
293 NS_ASSERT_MSG (m_data,
"UdpEchoClient::Send(): m_dataSize but no m_data");
294 p = Create<Packet> (m_data, m_dataSize);
305 p = Create<Packet> (m_size);
325 if (m_sent < m_count)
327 ScheduleTransmit (m_interval);
332 UdpEchoClient::HandleRead (Ptr<Socket> socket)
337 while ((packet = socket->RecvFrom (from)))
341 NS_LOG_INFO (
"At time " <<
Simulator::Now ().GetSeconds () <<
"s client received " << packet->GetSize () <<
" bytes from " <<
347 NS_LOG_INFO (
"At time " <<
Simulator::Now ().GetSeconds () <<
"s client received " << packet->GetSize () <<
" bytes from " <<
static bool IsMatchingType(const Address &address)
If the Address matches the type.
Ipv6Address GetIpv6(void) const
Get the IPv6 address.
Ipv4Address GetIpv4(void) const
#define NS_LOG_FUNCTION(parameters)
TracedCallback< Ptr< const Packet > > m_txTrace
Callbacks for tracing the packet Tx events.
virtual int Bind6()=0
Allocate a local IPv6 endpoint for this socket.
virtual void DoDispose(void)
#define NS_ASSERT(condition)
#define NS_LOG_COMPONENT_DEFINE(name)
static void Cancel(const EventId &id)
static EventId Schedule(Time const &time, MEM mem_ptr, OBJ obj)
void SetRemote(Address ip, uint16_t port)
virtual void StopApplication(void)
Application specific shutdown code.
a polymophic address class
Ptr< Node > GetNode() const
Callback< R > MakeCallback(R(T::*memPtr)(void), OBJ objPtr)
void SetRecvCallback(Callback< void, Ptr< Socket > >)
Notify application when new data is available to be read.
static Ptr< Socket > CreateSocket(Ptr< Node > node, TypeId tid)
static bool IsMatchingType(const Address &address)
virtual int Connect(const Address &address)=0
Initiate a connection to a remote host.
virtual void DoDispose(void)
virtual void StartApplication(void)
Application specific startup code.
virtual int Bind(const Address &address)=0
Allocate a local endpoint for this socket.
static InetSocketAddress ConvertFrom(const Address &address)
Ptr< const TraceSourceAccessor > MakeTraceSourceAccessor(T a)
Callback< R > MakeNullCallback(void)
void SetDataSize(uint32_t dataSize)
#define NS_ASSERT_MSG(condition, message)
Ipv4 addresses are stored in host order in this class.
Time Seconds(double seconds)
create ns3::Time instances in units of seconds.
uint32_t GetDataSize(void) const
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.
uint16_t GetPort(void) const
static Ipv4Address ConvertFrom(const Address &address)
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
a unique identifier for an interface.
static bool IsMatchingType(const Address &address)
void SetFill(std::string fill)
static TypeId LookupByName(std::string name)
static Ipv6Address ConvertFrom(const Address &address)
Convert the Address object into an Ipv6Address ones.