22 #include "ns3/address.h"
24 #include "ns3/nstime.h"
25 #include "ns3/socket.h"
26 #include "ns3/simulator.h"
27 #include "ns3/socket-factory.h"
28 #include "ns3/packet.h"
29 #include "ns3/uinteger.h"
30 #include "ns3/trace-source-accessor.h"
31 #include "ns3/tcp-socket-factory.h"
45 .AddConstructor<BulkSendApplication> ()
46 .AddAttribute (
"SendSize",
"The amount of data to send each time.",
49 MakeUintegerChecker<uint32_t> (1))
50 .AddAttribute (
"Remote",
"The address of the destination",
53 MakeAddressChecker ())
54 .AddAttribute (
"MaxBytes",
55 "The total number of bytes to send. "
56 "Once these bytes are sent, "
57 "no data is sent again. The value zero means "
58 "that there is no limit.",
61 MakeUintegerChecker<uint32_t> ())
62 .AddAttribute (
"Protocol",
"The type of protocol to use.",
66 .AddTraceSource (
"Tx",
"A new packet is created and is sent",
124 NS_FATAL_ERROR (
"Using BulkSend with an incompatible socket type. "
125 "BulkSend requires SOCK_STREAM or SOCK_SEQPACKET. "
126 "In other words, use TCP instead of UDP.");
163 NS_LOG_WARN (
"BulkSendApplication found null socket to close in StopApplication");
193 if ((
unsigned)actual != toSend)
209 NS_LOG_LOGIC (
"BulkSendApplication Connection succeeded");
217 NS_LOG_LOGIC (
"BulkSendApplication, Connection Failed");
virtual ~BulkSendApplication()
#define NS_LOG_FUNCTION(parameters)
virtual int Bind6()=0
Allocate a local IPv6 endpoint for this socket.
void ConnectionFailed(Ptr< Socket > socket)
#define NS_LOG_COMPONENT_DEFINE(name)
virtual int ShutdownRecv(void)=0
virtual void DoDispose(void)
#define NS_FATAL_ERROR(msg)
fatal error handling
virtual void StopApplication(void)
Application specific shutdown code.
The base class for all ns3 applications.
virtual void StartApplication(void)
Application specific startup code.
Hold an unsigned integer type.
NS_OBJECT_ENSURE_REGISTERED(AntennaModel)
Ptr< Node > GetNode() const
hold objects of type ns3::TypeId
Callback< R > MakeCallback(R(T::*memPtr)(void), OBJ objPtr)
void SetMaxBytes(uint32_t maxBytes)
void DataSend(Ptr< Socket >, uint32_t)
static Ptr< Socket > CreateSocket(Ptr< Node > node, TypeId tid)
virtual enum Socket::SocketType GetSocketType(void) const =0
#define NS_LOG_LOGIC(msg)
static TypeId GetTypeId(void)
virtual int Connect(const Address &address)=0
Initiate a connection to a remote host.
virtual void DoDispose(void)
virtual int Bind(const Address &address)=0
Allocate a local endpoint for this socket.
Ptr< const TraceSourceAccessor > MakeTraceSourceAccessor(T a)
static EventId ScheduleNow(MEM mem_ptr, OBJ obj)
void SetSendCallback(Callback< void, Ptr< Socket >, uint32_t > sendCb)
Notify application when space in transmit buffer is added.
void ConnectionSucceeded(Ptr< Socket > socket)
hold objects of type ns3::Address
static bool IsMatchingType(const Address &addr)
If the address match.
static TypeId GetTypeId(void)
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.
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< Socket > GetSocket(void) const
TracedCallback< Ptr< const Packet > > m_txTrace
a unique identifier for an interface.
TypeId SetParent(TypeId tid)
static bool IsMatchingType(const Address &address)