A Discrete-Event Network Simulator
API
udp-client.cc
Go to the documentation of this file.
1/*
2 * Copyright (c) 2007,2008,2009 INRIA, UDCAST
3 *
4 * This program is free software; you can redistribute it and/or modify
5 * it under the terms of the GNU General Public License version 2 as
6 * published by the Free Software Foundation;
7 *
8 * This program is distributed in the hope that it will be useful,
9 * but WITHOUT ANY WARRANTY; without even the implied warranty of
10 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
11 * GNU General Public License for more details.
12 *
13 * You should have received a copy of the GNU General Public License
14 * along with this program; if not, write to the Free Software
15 * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
16 *
17 * Author: Amine Ismail <amine.ismail@sophia.inria.fr>
18 * <amine.ismail@udcast.com>
19 */
20#include "udp-client.h"
21
22#include "seq-ts-header.h"
23
24#include "ns3/inet-socket-address.h"
25#include "ns3/inet6-socket-address.h"
26#include "ns3/ipv4-address.h"
27#include "ns3/log.h"
28#include "ns3/nstime.h"
29#include "ns3/packet.h"
30#include "ns3/simulator.h"
31#include "ns3/socket-factory.h"
32#include "ns3/socket.h"
33#include "ns3/uinteger.h"
34
35#include <cstdio>
36#include <cstdlib>
37
38namespace ns3
39{
40
41NS_LOG_COMPONENT_DEFINE("UdpClient");
42
44
45TypeId
47{
48 static TypeId tid =
49 TypeId("ns3::UdpClient")
51 .SetGroupName("Applications")
52 .AddConstructor<UdpClient>()
53 .AddAttribute("MaxPackets",
54 "The maximum number of packets the application will send",
55 UintegerValue(100),
57 MakeUintegerChecker<uint32_t>())
58 .AddAttribute("Interval",
59 "The time to wait between packets",
60 TimeValue(Seconds(1.0)),
63 .AddAttribute("RemoteAddress",
64 "The destination Address of the outbound packets",
66 MakeAddressAccessor(&UdpClient::m_peerAddress),
67 MakeAddressChecker())
68 .AddAttribute("RemotePort",
69 "The destination port of the outbound packets",
70 UintegerValue(100),
72 MakeUintegerChecker<uint16_t>())
73 .AddAttribute("PacketSize",
74 "Size of packets generated. The minimum packet size is 12 bytes which is "
75 "the size of the header carrying the sequence number and the time stamp.",
76 UintegerValue(1024),
78 MakeUintegerChecker<uint32_t>(12, 65507));
79 return tid;
80}
81
83{
84 NS_LOG_FUNCTION(this);
85 m_sent = 0;
86 m_totalTx = 0;
87 m_socket = nullptr;
89}
90
92{
93 NS_LOG_FUNCTION(this);
94}
95
96void
98{
99 NS_LOG_FUNCTION(this << ip << port);
100 m_peerAddress = ip;
102}
103
104void
106{
107 NS_LOG_FUNCTION(this << addr);
108 m_peerAddress = addr;
109}
110
111void
113{
114 NS_LOG_FUNCTION(this);
116}
117
118void
120{
121 NS_LOG_FUNCTION(this);
122
123 if (!m_socket)
124 {
125 TypeId tid = TypeId::LookupByName("ns3::UdpSocketFactory");
128 {
129 if (m_socket->Bind() == -1)
130 {
131 NS_FATAL_ERROR("Failed to bind socket");
132 }
135 }
137 {
138 if (m_socket->Bind6() == -1)
139 {
140 NS_FATAL_ERROR("Failed to bind socket");
141 }
144 }
146 {
147 if (m_socket->Bind() == -1)
148 {
149 NS_FATAL_ERROR("Failed to bind socket");
150 }
152 }
154 {
155 if (m_socket->Bind6() == -1)
156 {
157 NS_FATAL_ERROR("Failed to bind socket");
158 }
160 }
161 else
162 {
163 NS_ASSERT_MSG(false, "Incompatible address type: " << m_peerAddress);
164 }
165 }
166
167#ifdef NS3_LOG_ENABLE
168 std::stringstream peerAddressStringStream;
170 {
171 peerAddressStringStream << Ipv4Address::ConvertFrom(m_peerAddress);
172 }
174 {
175 peerAddressStringStream << Ipv6Address::ConvertFrom(m_peerAddress);
176 }
178 {
179 peerAddressStringStream << InetSocketAddress::ConvertFrom(m_peerAddress).GetIpv4();
180 }
182 {
183 peerAddressStringStream << Inet6SocketAddress::ConvertFrom(m_peerAddress).GetIpv6();
184 }
185 m_peerAddressString = peerAddressStringStream.str();
186#endif // NS3_LOG_ENABLE
187
191}
192
193void
195{
196 NS_LOG_FUNCTION(this);
198}
199
200void
202{
203 NS_LOG_FUNCTION(this);
205 SeqTsHeader seqTs;
206 seqTs.SetSeq(m_sent);
207 Ptr<Packet> p = Create<Packet>(m_size - (8 + 4)); // 8+4 : the size of the seqTs header
208 p->AddHeader(seqTs);
209
210 if ((m_socket->Send(p)) >= 0)
211 {
212 ++m_sent;
213 m_totalTx += p->GetSize();
214#ifdef NS3_LOG_ENABLE
215 NS_LOG_INFO("TraceDelay TX " << m_size << " bytes to " << m_peerAddressString << " Uid: "
216 << p->GetUid() << " Time: " << (Simulator::Now()).As(Time::S));
217#endif // NS3_LOG_ENABLE
218 }
219#ifdef NS3_LOG_ENABLE
220 else
221 {
222 NS_LOG_INFO("Error while sending " << m_size << " bytes to " << m_peerAddressString);
223 }
224#endif // NS3_LOG_ENABLE
225
226 if (m_sent < m_count)
227 {
229 }
230}
231
232uint64_t
234{
235 return m_totalTx;
236}
237
238} // Namespace ns3
a polymophic address class
Definition: address.h:92
AttributeValue implementation for Address.
The base class for all ns3 applications.
Definition: application.h:61
void DoDispose() override
Destructor implementation.
Definition: application.cc:85
Ptr< Node > GetNode() const
Definition: application.cc:107
An identifier for simulation events.
Definition: event-id.h:55
bool IsExpired() const
This method is syntactic sugar for the ns3::Simulator::IsExpired method.
Definition: event-id.cc:69
An Inet6 address class.
static Inet6SocketAddress ConvertFrom(const Address &addr)
Convert the address to a InetSocketAddress.
static bool IsMatchingType(const Address &addr)
If the address match.
Ipv6Address GetIpv6() const
Get the IPv6 address.
an Inet address class
static bool IsMatchingType(const Address &address)
Ipv4Address GetIpv4() const
static InetSocketAddress ConvertFrom(const Address &address)
Returns an InetSocketAddress which corresponds to the input Address.
static Ipv4Address ConvertFrom(const Address &address)
static bool IsMatchingType(const Address &address)
static Ipv6Address ConvertFrom(const Address &address)
Convert the Address object into an Ipv6Address ones.
static bool IsMatchingType(const Address &address)
If the Address matches the type.
void AddHeader(const Header &header)
Add header to this packet.
Definition: packet.cc:268
uint32_t GetSize() const
Returns the the size in bytes of the packet (including the zero-filled initial payload).
Definition: packet.h:863
uint64_t GetUid() const
Returns the packet's Uid.
Definition: packet.cc:412
Packet header to carry sequence number and timestamp.
Definition: seq-ts-header.h:45
void SetSeq(uint32_t seq)
static EventId Schedule(const Time &delay, FUNC f, Ts &&... args)
Schedule an event to expire after delay.
Definition: simulator.h:568
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:276
static Time Now()
Return the current simulation virtual time.
Definition: simulator.cc:199
virtual int Send(Ptr< Packet > p, uint32_t flags)=0
Send data (or dummy data) to the remote host.
virtual bool SetAllowBroadcast(bool allowBroadcast)=0
Configure whether broadcast datagram transmissions are allowed.
virtual int Bind6()=0
Allocate a local IPv6 endpoint for this socket.
virtual int Connect(const Address &address)=0
Initiate a connection to a remote host.
void SetRecvCallback(Callback< void, Ptr< Socket > > receivedData)
Notify application when new data is available to be read.
Definition: socket.cc:126
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:72
virtual int Bind(const Address &address)=0
Allocate a local endpoint for this socket.
@ S
second
Definition: nstime.h:116
AttributeValue implementation for Time.
Definition: nstime.h:1425
a unique identifier for an interface.
Definition: type-id.h:60
static TypeId LookupByName(std::string name)
Get a TypeId by name.
Definition: type-id.cc:839
TypeId SetParent(TypeId tid)
Set the parent TypeId.
Definition: type-id.cc:935
A Udp client.
Definition: udp-client.h:44
Time m_interval
Packet inter-send time.
Definition: udp-client.h:86
void DoDispose() override
Destructor implementation.
Definition: udp-client.cc:112
uint64_t GetTotalTx() const
Definition: udp-client.cc:233
uint64_t m_totalTx
Total bytes sent.
Definition: udp-client.h:90
~UdpClient() override
Definition: udp-client.cc:91
uint32_t m_sent
Counter for sent packets.
Definition: udp-client.h:89
Ptr< Socket > m_socket
Socket.
Definition: udp-client.h:91
uint16_t m_peerPort
Remote peer port.
Definition: udp-client.h:93
void Send()
Send a packet.
Definition: udp-client.cc:201
static TypeId GetTypeId()
Get the type ID.
Definition: udp-client.cc:46
EventId m_sendEvent
Event to send the next packet.
Definition: udp-client.h:94
uint32_t m_size
Size of the sent packet (including the SeqTsHeader)
Definition: udp-client.h:87
uint32_t m_count
Maximum number of packets the application will send.
Definition: udp-client.h:85
void SetRemote(Address ip, uint16_t port)
set the remote address and port
Definition: udp-client.cc:97
Address m_peerAddress
Remote peer address.
Definition: udp-client.h:92
void StartApplication() override
Application specific startup code.
Definition: udp-client.cc:119
void StopApplication() override
Application specific shutdown code.
Definition: udp-client.cc:194
std::string m_peerAddressString
Remote peer address string.
Definition: udp-client.h:96
Hold an unsigned integer type.
Definition: uinteger.h:45
uint16_t port
Definition: dsdv-manet.cc:45
#define NS_ASSERT(condition)
At runtime, in debugging builds, if this condition is not true, the program prints the source file,...
Definition: assert.h:66
#define NS_ASSERT_MSG(condition, message)
At runtime, in debugging builds, if this condition is not true, the program prints the message to out...
Definition: assert.h:86
Ptr< const AttributeAccessor > MakeTimeAccessor(T1 a1)
Definition: nstime.h:1426
Ptr< const AttributeAccessor > MakeUintegerAccessor(T1 a1)
Definition: uinteger.h:46
Callback< R, Args... > MakeNullCallback()
Definition: callback.h:734
#define NS_FATAL_ERROR(msg)
Report a fatal error with a message and terminate.
Definition: fatal-error.h:160
#define NS_LOG_COMPONENT_DEFINE(name)
Define a Log component with a specific name.
Definition: log.h:202
#define NS_LOG_FUNCTION(parameters)
If log level LOG_FUNCTION is enabled, this macro will output all input parameters separated by ",...
#define NS_LOG_INFO(msg)
Use NS_LOG to output a message of level LOG_INFO.
Definition: log.h:275
#define NS_OBJECT_ENSURE_REGISTERED(type)
Register an Object subclass with the TypeId system.
Definition: object-base.h:45
Time Seconds(double value)
Construct a Time in the indicated unit.
Definition: nstime.h:1338
Every class exported by the ns3 library is enclosed in the ns3 namespace.
Ptr< const AttributeChecker > MakeTimeChecker(const Time min, const Time max)
Helper to make a Time checker with bounded range.
Definition: time.cc:535