X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/973f33d7adc7e95c773f7a9e73f281503385f69b..2652a7d2c9ebb969683d8fd94b11c96489327912:/src/surf/ns3/ns3_simulator.h diff --git a/src/surf/ns3/ns3_simulator.h b/src/surf/ns3/ns3_simulator.h index f3bbe3eab6..8cec673f99 100644 --- a/src/surf/ns3/ns3_simulator.h +++ b/src/surf/ns3/ns3_simulator.h @@ -1,4 +1,4 @@ -/* Copyright (c) 2007, 2008, 2009, 2010. The SimGrid Team. +/* Copyright (c) 2007-2015. The SimGrid Team. * All rights reserved. */ /* This program is free software; you can redistribute it and/or modify it @@ -9,49 +9,46 @@ #ifdef __cplusplus -#include "ns3/core-module.h" -#include "ns3/helper-module.h" -#include "ns3/simulator-module.h" -#include "ns3/node-module.h" -#include "ns3/helper-module.h" -#include "ns3/global-routing-module.h" -#include "ns3/tcp-socket-factory.h" - -using namespace ns3; -using namespace std; - -struct MySocket{ - uint32_t bufferedBytes; - uint32_t sentBytes; - uint32_t remaining; - uint32_t totalBytes; - char finished; - void* action; -}; +#include -//Simulator s; -class NS3Sim { +#include "ns3_interface.h" +#include -private: +#include +#include +#include +#include +#include +#include +#include +#include +#include +class SgFlow { public: - NS3Sim(); - ~NS3Sim(); - void create_flow_NS3(Ptr src, - Ptr dst, - uint16_t port_number, - double start, - const char *addr, - uint32_t TotalBytes, - void * action); - void simulator_stop(double min); - void simulator_start(void); - void* get_action_from_socket(void *socket); - double get_remains_from_socket(void *socket); - double get_sent_from_socket(void *socket); - char get_finished(void *socket); + SgFlow(uint32_t totalBytes, simgrid::surf::NetworkNS3Action * action); + +//private: + std::uint32_t bufferedBytes_ = 0; + std::uint32_t sentBytes_ = 0; + std::uint32_t remaining_; + std::uint32_t totalBytes_; + bool finished_ = false; + simgrid::surf::NetworkNS3Action* action_; }; +void StartFlow(ns3::Ptr sock, const char *to, uint16_t port_number); + +static inline const char *transformSocketPtr (ns3::Ptr localSocket) +{ + static char key[24]; + std::stringstream sstream; + sstream << localSocket ; + sprintf(key,"%s",sstream.str().c_str()); + + return key; +} + #endif /* __cplusplus */ #endif