include teshsuite/models/cm02-set-lat-bw/cm02-set-lat-bw.tesh
include teshsuite/models/cm02-tcpgamma/cm02-tcpgamma.cpp
include teshsuite/models/cm02-tcpgamma/cm02-tcpgamma.tesh
+include teshsuite/models/core_usage/core_usage.cpp
+include teshsuite/models/core_usage/core_usage.tesh
+include teshsuite/models/core_usage2/core_usage2.cpp
+include teshsuite/models/core_usage2/core_usage2.tesh
include teshsuite/models/issue105/issue105.cpp
include teshsuite/models/issue105/issue105.tesh
+include teshsuite/models/lmm_usage/lmm_usage.cpp
+include teshsuite/models/lmm_usage/lmm_usage.tesh
+include teshsuite/models/maxmin_bench/maxmin_bench.cpp
+include teshsuite/models/maxmin_bench/maxmin_bench_large.tesh
+include teshsuite/models/maxmin_bench/maxmin_bench_medium.tesh
+include teshsuite/models/maxmin_bench/maxmin_bench_small.tesh
include teshsuite/models/ptask-subflows/ptask-subflows.cpp
include teshsuite/models/ptask-subflows/ptask-subflows.tesh
include teshsuite/models/ptask_L07_usage/ptask_L07_usage.cpp
include teshsuite/smpi/type-struct/type-struct.tesh
include teshsuite/smpi/type-vector/type-vector.c
include teshsuite/smpi/type-vector/type-vector.tesh
-include teshsuite/surf/lmm_usage/lmm_usage.cpp
-include teshsuite/surf/lmm_usage/lmm_usage.tesh
-include teshsuite/surf/maxmin_bench/maxmin_bench.cpp
-include teshsuite/surf/maxmin_bench/maxmin_bench_large.tesh
-include teshsuite/surf/maxmin_bench/maxmin_bench_medium.tesh
-include teshsuite/surf/maxmin_bench/maxmin_bench_small.tesh
-include teshsuite/surf/surf_usage/surf_usage.cpp
-include teshsuite/surf/surf_usage/surf_usage.tesh
-include teshsuite/surf/surf_usage2/surf_usage2.cpp
-include teshsuite/surf/surf_usage2/surf_usage2.tesh
include teshsuite/xbt/cmdline/cmdline.c
include teshsuite/xbt/cmdline/cmdline.tesh
include teshsuite/xbt/log_large/log_large.c
include src/kernel/resource/models/network_ib.hpp
include src/kernel/resource/models/network_ns3.cpp
include src/kernel/resource/models/network_ns3.hpp
+include src/kernel/resource/models/ns3/ns3_simulator.cpp
+include src/kernel/resource/models/ns3/ns3_simulator.hpp
include src/kernel/resource/models/ptask_L07.cpp
include src/kernel/resource/models/ptask_L07.hpp
include src/kernel/resource/profile/Event.hpp
include src/sthread/sthread.c
include src/sthread/sthread.h
include src/sthread/sthread_impl.cpp
-include src/surf/ns3/ns3_simulator.cpp
-include src/surf/ns3/ns3_simulator.hpp
include src/surf/sg_platf.cpp
include src/surf/surf_interface.hpp
include src/surf/xml/platf.hpp
include teshsuite/smpi/mpich3-test/pt2pt/CMakeLists.txt
include teshsuite/smpi/mpich3-test/rma/CMakeLists.txt
include teshsuite/smpi/mpich3-test/topo/CMakeLists.txt
-include teshsuite/surf/CMakeLists.txt
include teshsuite/xbt/CMakeLists.txt
include tools/CMakeLists.txt
include tools/cmake/CTestConfig.cmake
/* This program is free software; you can redistribute it and/or modify it
* under the terms of the license (GNU LGPL) which comes with this package. */
-#include "src/surf/ns3/ns3_simulator.hpp"
+#include "src/kernel/resource/models/ns3/ns3_simulator.hpp"
+
#include "xbt/log.h"
#include "xbt/sysdep.h"
-#include <ns3/ipv4-address-helper.h>
-#include <ns3/point-to-point-helper.h>
#include <ns3/application-container.h>
-#include <ns3/ptr.h>
#include <ns3/callback.h>
+#include <ns3/ipv4-address-helper.h>
#include <ns3/packet-sink.h>
+#include <ns3/point-to-point-helper.h>
+#include <ns3/ptr.h>
#include <algorithm>
static void send_cb(ns3::Ptr<ns3::Socket> sock, uint32_t /*txSpace*/)
{
- SgFlow* flow = getFlowFromSocket(sock);
+ SgFlow* flow = getFlowFromSocket(sock);
const ns3::ApplicationContainer* sink = getSinkFromSocket(sock);
XBT_DEBUG("Asked to write on F[%p, total: %u, remain: %u]", flow, flow->total_bytes_, flow->remaining_);
flow->remaining_);
}
- if (flow->buffered_bytes_ >= flow->total_bytes_){
+ if (flow->buffered_bytes_ >= flow->total_bytes_) {
XBT_DEBUG("Closing Sockets of flow %p", flow);
// Closing the sockets of the receiving application
- ns3::Ptr<ns3::PacketSink> app = ns3::DynamicCast<ns3::PacketSink, ns3::Application>(sink->Get(0));
+ ns3::Ptr<ns3::PacketSink> app = ns3::DynamicCast<ns3::PacketSink, ns3::Application>(sink->Get(0));
ns3::Ptr<ns3::Socket> listening_sock = app->GetListeningSocket();
listening_sock->Close();
listening_sock->SetRecvCallback(ns3::MakeNullCallback<void, ns3::Ptr<ns3::Socket>>());
- for(ns3::Ptr<ns3::Socket> accepted_sock : app->GetAcceptedSockets())
+ for (ns3::Ptr<ns3::Socket> accepted_sock : app->GetAcceptedSockets())
accepted_sock->Close();
// Closing the socket of the sender
sock->Close();