|
|
|---|
| 41 |
#include "ns3/udp-socket-factory.h" |
41 |
#include "ns3/udp-socket-factory.h" |
| 42 |
#include "ns3/string.h" |
42 |
#include "ns3/string.h" |
| 43 |
#include "ns3/pointer.h" |
43 |
#include "ns3/pointer.h" |
|
|
44 |
#include "ns3/boolean.h" |
| 44 |
|
45 |
|
| 45 |
namespace ns3 { |
46 |
namespace ns3 { |
| 46 |
|
47 |
|
|
|
|---|
| 59 |
DataRateValue (DataRate ("500kb/s")), |
60 |
DataRateValue (DataRate ("500kb/s")), |
| 60 |
MakeDataRateAccessor (&OnOffApplication::m_cbrRate), |
61 |
MakeDataRateAccessor (&OnOffApplication::m_cbrRate), |
| 61 |
MakeDataRateChecker ()) |
62 |
MakeDataRateChecker ()) |
|
|
63 |
.AddAttribute ("RandomSize", "An optional random variable that replaces the use of fixed PacketSize variable", |
| 64 |
StringValue ("ns3::ConstantRandomVariable[Constant=512.0]"), |
| 65 |
MakePointerAccessor (&OnOffApplication::m_randomSize), |
| 66 |
MakePointerChecker <RandomVariableStream>()) |
| 67 |
.AddAttribute ("UseRandomSize", "Flag for whether packet distribution or fixed packet size is used", |
| 68 |
BooleanValue (false), |
| 69 |
MakeBooleanAccessor (&OnOffApplication::m_useRandomSize), |
| 70 |
MakeBooleanChecker ()) |
| 71 |
.AddAttribute ("RandomInterval", "An optional random variable that replaces the use of fixed DataRate", |
| 72 |
StringValue ("ns3::ConstantRandomVariable[Constant=512.0]"), |
| 73 |
MakePointerAccessor (&OnOffApplication::m_randomInterval), |
| 74 |
MakePointerChecker <RandomVariableStream>()) |
| 75 |
.AddAttribute ("UseRandomInterval", "Flag for whether interval distribution or fixed DataRate is used", |
| 76 |
BooleanValue (false), |
| 77 |
MakeBooleanAccessor (&OnOffApplication::m_useRandomInterval), |
| 78 |
MakeBooleanChecker ()) |
| 62 |
.AddAttribute ("PacketSize", "The size of packets sent in on state", |
79 |
.AddAttribute ("PacketSize", "The size of packets sent in on state", |
| 63 |
UintegerValue (512), |
80 |
UintegerValue (512), |
| 64 |
MakeUintegerAccessor (&OnOffApplication::m_pktSize), |
81 |
MakeUintegerAccessor (&OnOffApplication::m_pktSize), |
|
|
|---|
| 129 |
NS_LOG_FUNCTION (this << stream); |
146 |
NS_LOG_FUNCTION (this << stream); |
| 130 |
m_onTime->SetStream (stream); |
147 |
m_onTime->SetStream (stream); |
| 131 |
m_offTime->SetStream (stream + 1); |
148 |
m_offTime->SetStream (stream + 1); |
| 132 |
return 2; |
149 |
m_randomInterval->SetStream (stream + 2); |
|
|
150 |
m_randomSize->SetStream (stream + 3); |
| 151 |
return 4; |
| 133 |
} |
152 |
} |
| 134 |
|
153 |
|
| 135 |
void |
154 |
void |
|
|
|---|
| 235 |
{ |
254 |
{ |
| 236 |
uint32_t bits = m_pktSize * 8 - m_residualBits; |
255 |
uint32_t bits = m_pktSize * 8 - m_residualBits; |
| 237 |
NS_LOG_LOGIC ("bits = " << bits); |
256 |
NS_LOG_LOGIC ("bits = " << bits); |
| 238 |
Time nextTime (Seconds (bits / |
257 |
Time nextTime; |
| 239 |
static_cast<double>(m_cbrRate.GetBitRate ()))); // Time till next packet |
258 |
// Time till next packet |
|
|
259 |
if (m_useRandomInterval) |
| 260 |
{ |
| 261 |
nextTime = Seconds (m_randomInterval->GetValue ()); |
| 262 |
NS_ASSERT_MSG (nextTime.IsPositive (), |
| 263 |
"Packet interval is unexpectedly zero or negative. " |
| 264 |
"Please verify the configuration of " |
| 265 |
"`ns3::OnOffApplication::RandomInterval` " |
| 266 |
"random variable."); |
| 267 |
} |
| 268 |
else |
| 269 |
{ |
| 270 |
nextTime = Seconds (bits / static_cast<double>(m_cbrRate.GetBitRate ())); |
| 271 |
} |
| 240 |
NS_LOG_LOGIC ("nextTime = " << nextTime); |
272 |
NS_LOG_LOGIC ("nextTime = " << nextTime); |
| 241 |
m_sendEvent = Simulator::Schedule (nextTime, |
273 |
m_sendEvent = Simulator::Schedule (nextTime, |
| 242 |
&OnOffApplication::SendPacket, this); |
274 |
&OnOffApplication::SendPacket, this); |
|
|
|---|
| 271 |
NS_LOG_FUNCTION (this); |
303 |
NS_LOG_FUNCTION (this); |
| 272 |
|
304 |
|
| 273 |
NS_ASSERT (m_sendEvent.IsExpired ()); |
305 |
NS_ASSERT (m_sendEvent.IsExpired ()); |
| 274 |
Ptr<Packet> packet = Create<Packet> (m_pktSize); |
306 |
uint32_t packetSize; |
|
|
307 |
if (m_useRandomSize) |
| 308 |
{ |
| 309 |
packetSize = m_randomSize->GetInteger (); |
| 310 |
NS_ASSERT_MSG (packetSize > 0, "Packet size was unexpectedly zero. " |
| 311 |
"Please verify the configuration of " |
| 312 |
"`ns3::OnOffApplication::RandomSize` " |
| 313 |
"random variable."); |
| 314 |
} |
| 315 |
else |
| 316 |
{ |
| 317 |
packetSize = m_pktSize; |
| 318 |
} |
| 319 |
Ptr<Packet> packet = Create<Packet> (packetSize); |
| 275 |
m_txTrace (packet); |
320 |
m_txTrace (packet); |
| 276 |
m_socket->Send (packet); |
321 |
m_socket->Send (packet); |
| 277 |
m_totBytes += m_pktSize; |
322 |
m_totBytes += m_pktSize; |