diff --git a/src/test/nsctcp/nsctcp-loss-test-suite.cc b/src/test/nsctcp/nsctcp-loss-test-suite.cc new file mode 100644 index 000000000..8f3c0434d --- /dev/null +++ b/src/test/nsctcp/nsctcp-loss-test-suite.cc @@ -0,0 +1,283 @@ +/* -*- Mode:C++; c-file-style:"gnu"; indent-tabs-mode:nil; -*- */ +/* + * Copyright (c) 2010 University of Washington + * + * This program is free software; you can redistribute it and/or modify + * it under the terms of the GNU General Public License version 2 as + * published by the Free Software Foundation; + * + * This program is distributed in the hope that it will be useful, + * but WITHOUT ANY WARRANTY; without even the implied warranty of + * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the + * GNU General Public License for more details. + * + * You should have received a copy of the GNU General Public License + * along with this program; if not, write to the Free Software + * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA + */ + + +#include "ns3/log.h" +#include "ns3/abort.h" +#include "ns3/test.h" +#include "ns3/pcap-file.h" +#include "ns3/config.h" +#include "ns3/string.h" +#include "ns3/uinteger.h" +#include "ns3/data-rate.h" +#include "ns3/inet-socket-address.h" +#include "ns3/point-to-point-helper.h" +#include "ns3/internet-stack-helper.h" +#include "ns3/ipv4-global-routing-helper.h" +#include "ns3/ipv4-address-helper.h" +#include "ns3/packet-sink-helper.h" +#include "ns3/tcp-socket-factory.h" +#include "ns3/node-container.h" +#include "ns3/simulator.h" +#include "ns3/error-model.h" +#include "ns3/pointer.h" +#include "../ns3tcp/ns3tcp-socket-writer.h" +#include "../ns3tcp/receive-list-error-model.h" + +using namespace ns3; + +NS_LOG_COMPONENT_DEFINE ("NscTcpLossTest"); + +// =========================================================================== +// Tests of TCP implementation loss behavior +// =========================================================================== +// + +class NscTcpLossTestCase1 : public TestCase +{ +public: + NscTcpLossTestCase1 (); + virtual ~NscTcpLossTestCase1 () {} + +private: + virtual bool DoRun (void); + bool m_writeResults; + + void SinkRx (std::string path, Ptr p, const Address &address); + + TestVectors m_inputs; + TestVectors m_responses; +}; + +NscTcpLossTestCase1::NscTcpLossTestCase1 () + : TestCase ("Check that nsc TCP survives loss of first two SYNs"), + m_writeResults (false) +{ +} + +void +NscTcpLossTestCase1::SinkRx (std::string path, Ptr p, const Address &address) +{ + m_responses.Add (p->GetSize ()); +} + +bool +NscTcpLossTestCase1::DoRun (void) +{ + uint16_t sinkPort = 50000; + double sinkStopTime = 40; // sec; will trigger Socket::Close + double writerStopTime = 30; // sec; will trigger Socket::Close + double simStopTime = 60; // sec + Time sinkStopTimeObj = Seconds (sinkStopTime); + Time writerStopTimeObj = Seconds (writerStopTime); + Time simStopTimeObj= Seconds (simStopTime); + + Ptr n0 = CreateObject (); + Ptr n1 = CreateObject (); + + PointToPointHelper pointToPoint; + pointToPoint.SetDeviceAttribute ("DataRate", StringValue ("5Mbps")); + pointToPoint.SetChannelAttribute ("Delay", StringValue ("200ms")); + + NetDeviceContainer devices; + devices = pointToPoint.Install (n0, n1); + + InternetStackHelper internet; + internet.SetTcp ("ns3::NscTcpL4Protocol", "Library", StringValue("liblinux2.6.26.so")); + internet.InstallAll (); + + Ipv4AddressHelper address; + address.SetBase ("10.1.1.0", "255.255.255.252"); + Ipv4InterfaceContainer ifContainer = address.Assign (devices); + + Ptr socketWriter = CreateObject (); + Address sinkAddress (InetSocketAddress (ifContainer.GetAddress (1), sinkPort)); + socketWriter->Setup (n0, sinkAddress); + n0->AddApplication (socketWriter); + socketWriter->SetStartTime (Seconds (0.)); + socketWriter->SetStopTime (writerStopTimeObj); + + PacketSinkHelper sink ("ns3::TcpSocketFactory", + InetSocketAddress (Ipv4Address::GetAny (), sinkPort)); + ApplicationContainer apps = sink.Install (n1); + // Start the sink application at time zero, and stop it at sinkStopTime + apps.Start (Seconds (0.0)); + apps.Stop (sinkStopTimeObj); + + Config::Connect ("/NodeList/*/ApplicationList/*/$ns3::PacketSink/Rx", + MakeCallback (&NscTcpLossTestCase1::SinkRx, this)); + + Simulator::Schedule(Seconds (2), &SocketWriter::Connect, socketWriter); + Simulator::Schedule(Seconds (10), &SocketWriter::Write, socketWriter, 500); + m_inputs.Add (500); + Simulator::Schedule(writerStopTimeObj, &SocketWriter::Close, socketWriter); + + std::list sampleList; + // Lose first two SYNs + sampleList.push_back (0); + sampleList.push_back (1); + // This time, we'll explicitly create the error model we want + Ptr pem = CreateObject (); + pem->SetList (sampleList); + devices.Get (1)->SetAttribute ("ReceiveErrorModel", PointerValue (pem)); + + if (m_writeResults) + { + pointToPoint.EnablePcapAll ("nsc-tcp-loss-test-case-1"); + pointToPoint.EnableAsciiAll ("nsc-tcp-loss-test-case-1"); + } + + Simulator::Stop (simStopTimeObj); + Simulator::Run (); + Simulator::Destroy (); + + // Compare inputs and outputs + NS_TEST_ASSERT_MSG_EQ (m_inputs.GetN (), m_responses.GetN (), "Incorrect number of expected receive events"); + for (uint32_t i = 0; i < m_responses.GetN (); i++) + { + uint32_t in = m_inputs.Get (i); + uint32_t out = m_responses.Get (i); + NS_TEST_ASSERT_MSG_EQ (in, out, "Mismatch: expected " << in << " bytes, got " << out << " bytes"); + } + + return GetErrorStatus (); +} + +class NscTcpLossTestCase2 : public TestCase +{ +public: + NscTcpLossTestCase2 (); + virtual ~NscTcpLossTestCase2 () {} + +private: + virtual bool DoRun (void); + bool m_writeResults; + + void SinkRx (std::string path, Ptr p, const Address &address); + + TestVectors m_inputs; + TestVectors m_responses; +}; + +NscTcpLossTestCase2::NscTcpLossTestCase2 () + : TestCase ("Check that nsc TCP survives loss of first data packet"), + m_writeResults (false) +{ +} + +void +NscTcpLossTestCase2::SinkRx (std::string path, Ptr p, const Address &address) +{ + m_responses.Add (p->GetSize ()); +} + +bool +NscTcpLossTestCase2::DoRun (void) +{ + uint16_t sinkPort = 50000; + double sinkStopTime = 40; // sec; will trigger Socket::Close + double writerStopTime = 12; // sec; will trigger Socket::Close + double simStopTime = 60; // sec + Time sinkStopTimeObj = Seconds (sinkStopTime); + Time writerStopTimeObj = Seconds (writerStopTime); + Time simStopTimeObj= Seconds (simStopTime); + + Ptr n0 = CreateObject (); + Ptr n1 = CreateObject (); + + PointToPointHelper pointToPoint; + pointToPoint.SetDeviceAttribute ("DataRate", StringValue ("5Mbps")); + pointToPoint.SetChannelAttribute ("Delay", StringValue ("200ms")); + + NetDeviceContainer devices; + devices = pointToPoint.Install (n0, n1); + + InternetStackHelper internet; + internet.SetTcp ("ns3::NscTcpL4Protocol", "Library", StringValue("liblinux2.6.26.so")); + internet.InstallAll (); + + Ipv4AddressHelper address; + address.SetBase ("10.1.1.0", "255.255.255.252"); + Ipv4InterfaceContainer ifContainer = address.Assign (devices); + + Ptr socketWriter = CreateObject (); + Address sinkAddress (InetSocketAddress (ifContainer.GetAddress (1), sinkPort)); + socketWriter->Setup (n0, sinkAddress); + n0->AddApplication (socketWriter); + socketWriter->SetStartTime (Seconds (0.)); + socketWriter->SetStopTime (writerStopTimeObj); + + PacketSinkHelper sink ("ns3::TcpSocketFactory", + InetSocketAddress (Ipv4Address::GetAny (), sinkPort)); + ApplicationContainer apps = sink.Install (n1); + // Start the sink application at time zero, and stop it at sinkStopTime + apps.Start (Seconds (0.0)); + apps.Stop (sinkStopTimeObj); + + Config::Connect ("/NodeList/*/ApplicationList/*/$ns3::PacketSink/Rx", + MakeCallback (&NscTcpLossTestCase2::SinkRx, this)); + + Simulator::Schedule(Seconds (2), &SocketWriter::Connect, socketWriter); + Simulator::Schedule(Seconds (10), &SocketWriter::Write, socketWriter, 500); + m_inputs.Add (500); + Simulator::Schedule(writerStopTimeObj, &SocketWriter::Close, socketWriter); + + std::list sampleList; + // Lose first data segment + sampleList.push_back (2); + // This time, we'll explicitly create the error model we want + Ptr pem = CreateObject (); + pem->SetList (sampleList); + devices.Get (1)->SetAttribute ("ReceiveErrorModel", PointerValue (pem)); + + if (m_writeResults) + { + pointToPoint.EnablePcapAll ("nsc-tcp-loss-test-case-2"); + pointToPoint.EnableAsciiAll ("nsc-tcp-loss-test-case-2"); + } + + Simulator::Stop (simStopTimeObj); + Simulator::Run (); + Simulator::Destroy (); + + // Compare inputs and outputs + NS_TEST_ASSERT_MSG_EQ (m_inputs.GetN (), m_responses.GetN (), "Incorrect number of expected receive events"); + for (uint32_t i = 0; i < m_responses.GetN (); i++) + { + uint32_t in = m_inputs.Get (i); + uint32_t out = m_responses.Get (i); + NS_TEST_ASSERT_MSG_EQ (in, out, "Mismatch: expected " << in << " bytes, got " << out << " bytes"); + } + + return GetErrorStatus (); +} + +class NscTcpLossTestSuite : public TestSuite +{ +public: + NscTcpLossTestSuite (); +}; + +NscTcpLossTestSuite::NscTcpLossTestSuite () + : TestSuite ("nsc-tcp-loss", SYSTEM) +{ + AddTestCase (new NscTcpLossTestCase1); + AddTestCase (new NscTcpLossTestCase2); +} + +NscTcpLossTestSuite nscTcpLossTestSuite; diff --git a/src/test/nsctcp/wscript b/src/test/nsctcp/wscript new file mode 100644 index 000000000..955cdb063 --- /dev/null +++ b/src/test/nsctcp/wscript @@ -0,0 +1,15 @@ +## -*- Mode: python; py-indent-offset: 4; indent-tabs-mode: nil; coding: utf-8; -*- + +def configure(conf): + pass + +def build(bld): + nsctcp = bld.create_ns3_module('nsctcp') + headers = bld.new_task_gen('ns3header') + headers.module = 'nsctcp' + headers.source = [ + ] + if bld.env['NSC_ENABLED']: + nsctcp.source = [ + 'nsctcp-loss-test-suite.cc', + ] diff --git a/src/wscript b/src/wscript index af29dc1c1..44d76c642 100644 --- a/src/wscript +++ b/src/wscript @@ -51,6 +51,7 @@ all_modules = ( 'test', 'test/perf', 'test/ns3tcp', + 'test/nsctcp', 'test/ns3wifi', 'contrib/flow-monitor', 'applications/udp-client-server',