20 #include "ns3/address.h"
21 #include "ns3/address-utils.h"
23 #include "ns3/inet-socket-address.h"
24 #include "ns3/inet6-socket-address.h"
26 #include "ns3/socket.h"
27 #include "ns3/udp-socket.h"
28 #include "ns3/simulator.h"
29 #include "ns3/socket-factory.h"
30 #include "ns3/packet.h"
31 #include "ns3/trace-source-accessor.h"
32 #include "ns3/udp-socket-factory.h"
45 .AddConstructor<PacketSink> ()
46 .AddAttribute (
"Local",
"The Address on which to Bind the rx socket.",
49 MakeAddressChecker ())
50 .AddAttribute (
"Protocol",
"The type id of the protocol to use for the rx socket.",
54 .AddTraceSource (
"Rx",
"A packet has been received",
85 std::list<Ptr<Socket> >
120 udpSocket->MulticastJoinGroup (0,
m_local);
145 acceptedSocket->
Close ();
159 while ((packet = socket->
RecvFrom (from)))
169 <<
"s packet sink received "
170 << packet->
GetSize () <<
" bytes from "
173 <<
" total Rx " <<
m_totalRx <<
" bytes");
178 <<
"s packet sink received "
179 << packet->
GetSize () <<
" bytes from "
182 <<
" total Rx " <<
m_totalRx <<
" bytes");
static TypeId GetTypeId(void)
Ipv6Address GetIpv6(void) const
Get the IPv6 address.
void HandlePeerError(Ptr< Socket >)
Ipv4Address GetIpv4(void) const
#define NS_LOG_FUNCTION(parameters)
void HandleRead(Ptr< Socket >)
virtual int ShutdownSend(void)=0
bool IsMulticast(const Address &ad)
Address family-independent test for a multicast address.
TracedCallback< Ptr< const Packet >, const Address & > m_rxTrace
uint32_t GetSize(void) const
void SetCloseCallbacks(Callback< void, Ptr< Socket > > normalClose, Callback< void, Ptr< Socket > > errorClose)
Detect socket recv() events such as graceful shutdown or error.
static TypeId GetTypeId(void)
Callback< R > MakeNullCallback(void)
#define NS_FATAL_ERROR(msg)
fatal error handling
a polymophic address class
virtual int Listen(void)=0
Listen for incoming connections.
The base class for all ns3 applications.
NS_OBJECT_ENSURE_REGISTERED(AntennaModel)
Ptr< Node > GetNode() const
hold objects of type ns3::TypeId
Callback< R > MakeCallback(R(T::*memPtr)(void), OBJ objPtr)
virtual void StopApplication(void)
Application specific shutdown code.
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)
virtual void DoDispose(void)
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)
uint32_t GetTotalRx() const
void SetAcceptCallback(Callback< bool, Ptr< Socket >, const Address & > connectionRequest, Callback< void, Ptr< Socket >, const Address & > newConnectionCreated)
Accept connection requests from remote hosts.
std::list< Ptr< Socket > > GetAcceptedSockets(void) const
std::list< Ptr< Socket > > m_socketList
void HandlePeerClose(Ptr< Socket >)
void HandleAccept(Ptr< Socket >, const Address &from)
hold objects of type ns3::Address
NS_LOG_COMPONENT_DEFINE("PacketLossCounter")
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.
virtual void DoDispose(void)
uint16_t GetPort(void) const
virtual void StartApplication(void)
Application specific startup code.
virtual Ptr< Packet > RecvFrom(uint32_t maxSize, uint32_t flags, Address &fromAddress)=0
Read a single packet from the socket and retrieve the sender address.
virtual int Close(void)=0
Close a socket.
a unique identifier for an interface.
TypeId SetParent(TypeId tid)
static bool IsMatchingType(const Address &address)
Ptr< Socket > GetListeningSocket(void) const