- if(!dict_socket)
- dict_socket = xbt_dict_new_homogeneous(delete_mysocket);
-
- ns3::PacketSinkHelper sink("ns3::TcpSocketFactory", ns3::InetSocketAddress (ns3::Ipv4Address::GetAny(), port_number));
- sink.Install (dst);
-
- ns3::Ptr<ns3::Socket> sock = ns3::Socket::CreateSocket (src, ns3::TcpSocketFactory::GetTypeId());
-
- MySocket *mysocket = new MySocket();
- mysocket->totalBytes = totalBytes;
- mysocket->remaining = totalBytes;
- mysocket->action = action;
-
- transformSocketPtr(sock);
- xbt_dict_set(dict_socket,socket_key, mysocket,NULL);
-
- 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 ();
-}