Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- #include <ns3/core-module.h>
- #include <ns3/network-module.h>
- #include <ns3/internet-module.h>
- #include <ns3/point-to-point-module.h>
- #include <ns3/applications-module.h>
- using namespace ns3;
- class MojaAplikacija : public Application
- {
- public:
- MojaAplikacija ();
- virtual ~MojaAplikacija ();
- void Setup (Ptr<Socket> socket, Address address, uint32_t packetSize, uint32_t nPackets, DataRate dataRate);
- private:
- virtual void StartApplication (void);
- virtual void StopApplication (void);
- void ScheduleTx (void);
- void SendPacket (void);
- Ptr<Socket> m_socket;
- Address m_peer;
- uint32_t m_packetSize;
- uint32_t m_nPackets;
- DataRate m_dataRate;
- EventId m_sendEvent;
- bool m_running;
- uint32_t m_packetsSent;
- };
- MojaAplikacija::MojaAplikacija ()
- : m_socket (0),
- m_peer (),
- m_packetSize (0),
- m_nPackets (0),
- m_dataRate (0),
- m_sendEvent (),
- m_running (false),
- m_packetsSent (0)
- {
- }
- MojaAplikacija::~MojaAplikacija ()
- {
- m_socket = 0;
- }
- void
- MojaAplikacija::Setup (Ptr<Socket> socket, Address address, uint32_t packetSize, uint32_t nPackets, DataRate dataRate)
- {
- m_socket = socket;
- m_peer = address;
- m_packetSize = packetSize;
- m_nPackets = nPackets;
- m_dataRate = dataRate;
- }
- void
- MojaAplikacija::StartApplication (void)
- {
- m_running = true;
- m_packetsSent = 0;
- m_socket->Bind ();
- m_socket->Connect (m_peer);
- SendPacket ();
- }
- void
- MojaAplikacija::StopApplication (void)
- {
- m_running = false;
- if (m_sendEvent.IsRunning ())
- {
- Simulator::Cancel (m_sendEvent);
- }
- if (m_socket)
- {
- m_socket->Close ();
- }
- }
- void
- MojaAplikacija::SendPacket (void)
- {
- Ptr<Packet> packet = Create<Packet> (m_packetSize);
- m_socket->Send (packet);
- if (++m_packetsSent < m_nPackets)
- {
- ScheduleTx ();
- }
- }
- void
- MojaAplikacija::ScheduleTx (void)
- {
- if (m_running)
- {
- Time tNext (Seconds (m_packetSize * 8 / static_cast<double> (m_dataRate.GetBitRate ())));
- m_sendEvent = Simulator::Schedule (tNext, &MojaAplikacija::SendPacket, this);
- }
- }
- int main ()
- {
- NodeContainer nodes;
- nodes.Create (2);
- PointToPointHelper pointToPoint;
- pointToPoint.SetDeviceAttribute ("DataRate", StringValue ("5Mbps"));
- pointToPoint.SetChannelAttribute ("Delay", StringValue ("2ms"));
- NetDeviceContainer devices;
- devices = pointToPoint.Install (nodes);
- InternetStackHelper stack;
- stack.Install (nodes);
- Ipv4AddressHelper address;
- address.SetBase ("10.1.1.0", "255.255.255.252");
- Ipv4InterfaceContainer interfaces = address.Assign (devices);
- uint16_t sinkPort = 8080;
- PacketSinkHelper packetSinkHelper ("ns3::TcpSocketFactory", InetSocketAddress (Ipv4Address::GetAny (), sinkPort));
- ApplicationContainer sinkApps = packetSinkHelper.Install (nodes.Get (1));
- sinkApps.Start (Seconds (0.));
- sinkApps.Stop (Seconds (20.));
- Ptr<Socket> ns3TcpSocket = Socket::CreateSocket (nodes.Get (0), TcpSocketFactory::GetTypeId ());
- Ptr<MojaAplikacija> app = CreateObject<MojaAplikacija> ();
- app->Setup (ns3TcpSocket, InetSocketAddress (interfaces.GetAddress (1), sinkPort), 1024, 500, DataRate ("1Mbps"));
- nodes.Get (0)->AddApplication (app);
- app->SetStartTime (Seconds (1.));
- app->SetStopTime (Seconds (20.));
- pointToPoint.EnableAsciiAll ("vjezba-vlastita-tcp-app");
- Simulator::Run ();
- Simulator::Destroy ();
- return 0;
- }
Add Comment
Please, Sign In to add comment