- sock->Bind(ns3::InetSocketAddress(port_number));
- XBT_DEBUG("Create flow starting to %fs + %fs = %fs",
- startTime-ns3::Simulator::Now().GetSeconds(), ns3::Simulator::Now().GetSeconds(), startTime);
-
- ns3::Simulator::Schedule (ns3::Seconds(startTime-ns3::Simulator::Now().GetSeconds()),
- &StartFlow, sock, ipAddr, port_number);
-}
-
-void NS3Sim::simulator_start(double min){
- if(min > 0.0)
- ns3::Simulator::Stop(ns3::Seconds(min));
- XBT_DEBUG("Start simulator '%f'",min);
- ns3::Simulator::Run ();
-}
-
-static MySocket* get_my_socket(ns3::Ptr<ns3::Socket> localSocket) {
- transformSocketPtr(localSocket);
- return (MySocket*)xbt_dict_get_or_null(dict_socket,socket_key);
-}
-
-static void receive_callback(ns3::Ptr<ns3::Socket> localSocket){
- MySocket* mysocket = get_my_socket(localSocket);
-
- if (mysocket->finished == false){
- mysocket->finished = true;
- XBT_DEBUG("recv_cb of F[%p, %p, %d]", mysocket, mysocket->action, mysocket->totalBytes);
+ if (flow->finished_ == false) {
+ flow->finished_ = true;
+ XBT_DEBUG("recv_cb of F[%p, %p, %u]", flow, flow->action_, flow->totalBytes_);