X-Git-Url: http://bilbo.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/0c9c02e440cd8a6e9b8b51556cf43cb58201f3f5..9cdf0f51bf67ecb8df0ece7c12283c705f1531d7:/src/surf/network_ns3.cpp diff --git a/src/surf/network_ns3.cpp b/src/surf/network_ns3.cpp index 3038dbca51..76215d9a9c 100644 --- a/src/surf/network_ns3.cpp +++ b/src/surf/network_ns3.cpp @@ -38,6 +38,7 @@ XBT_LOG_NEW_DEFAULT_SUBCATEGORY(ns3, surf, "Logging specific to the SURF network ns-3 module"); std::vector IPV4addr; +static std::string transformIpv4Address(ns3::Ipv4Address from); /***************** * Crude globals * @@ -51,30 +52,69 @@ static ns3::NodeContainer nodes; static ns3::NodeContainer Cluster_nodes; static ns3::Ipv4InterfaceContainer interfaces; +static int number_of_nodes = 0; +static int number_of_clusters_nodes = 0; +static int number_of_links = 1; +static int number_of_networks = 1; + /* wifi globals */ static ns3::WifiHelper wifi; static ns3::YansWifiPhyHelper wifiPhy = ns3::YansWifiPhyHelper::Default (); static ns3::YansWifiChannelHelper wifiChannel = ns3::YansWifiChannelHelper::Default (); static ns3::WifiMacHelper wifiMac; static ns3::MobilityHelper mobility; -static int mobility_delta = 10; -static int mobility_base = 0; - -static int number_of_nodes = 0; -static int number_of_clusters_nodes = 0; -static int number_of_links = 1; -static int number_of_networks = 1; simgrid::xbt::Extension NetPointNs3::EXTENSION_ID; NetPointNs3::NetPointNs3() : ns3_node_(ns3::CreateObject(0)) { - XBT_INFO("NetPointNs3"); stack.Install(ns3_node_); nodes.Add(ns3_node_); node_num = number_of_nodes++; } +WifiZone::WifiZone(std::string name_, simgrid::s4u::Host* host_, ns3::Ptr ap_node_, + ns3::Ptr channel_, int mcs_, int nss_, int network_, int link_) : + name(name_), host(host_), ap_node(ap_node_), channel(channel_), mcs(mcs_), nss(nss_), + network(network_), link(link_) { + n_sta_nodes = 0; + wifi_zones[name_] = this; +} + +bool WifiZone::is_ap(ns3::Ptr node){ + for (std::pair zone : wifi_zones) + if (zone.second->get_ap_node() == node) + return true; + return false; +} + +WifiZone* WifiZone::by_name(std::string name) { + WifiZone* zone; + try { + zone = wifi_zones.at(name); + } + catch (const std::out_of_range& oor) { + return nullptr; + } + return zone; +} + +std::unordered_map WifiZone::wifi_zones; + +static void initialize_ns3_wifi() { + wifi.SetStandard (ns3::WIFI_PHY_STANDARD_80211n_5GHZ); + + for (auto host : simgrid::s4u::Engine::get_instance()->get_all_hosts()) { + const char* wifi_link = host->get_property("wifi_link"); + const char* wifi_mcs = host->get_property("wifi_mcs"); + const char* wifi_nss = host->get_property("wifi_nss"); + + if (wifi_link) + new WifiZone(wifi_link, host, host->get_netpoint()->extension()->ns3_node_, + wifiChannel.Create(), wifi_mcs ? atoi(wifi_mcs) : 3, wifi_nss ? atoi(wifi_nss) : 1, 0, 0); + } +} + /************* * Callbacks * *************/ @@ -92,7 +132,7 @@ static void clusterCreation_cb(simgrid::kernel::routing::ClusterCreationArgs con xbt_assert(host_src, "Cannot find a ns-3 host of name %s", host_id.c_str()); // Any ns-3 route is symmetrical - ns3_add_direct_route(host_src, host_dst, cluster.bw, cluster.lat, cluster.sharing_policy); + ns3_add_direct_route(host_src, host_dst, cluster.bw, cluster.lat, cluster.id, cluster.sharing_policy); delete host_dst; } @@ -106,7 +146,6 @@ static void routeCreation_cb(bool symmetrical, simgrid::kernel::routing::NetPoin simgrid::kernel::routing::NetPoint* /*gw_dst*/, std::vector const& link_list) { - XBT_INFO("ROUTE_CREATION"); if (link_list.size() == 1) { auto* link = static_cast(link_list[0]); @@ -121,10 +160,13 @@ static void routeCreation_cb(bool symmetrical, simgrid::kernel::routing::NetPoin auto* host_src = src->extension(); auto* host_dst = dst->extension(); + host_src->set_name(src->get_name()); + host_dst->set_name(dst->get_name()); + xbt_assert(host_src != nullptr, "Network element %s does not seem to be ns-3-ready", src->get_cname()); xbt_assert(host_dst != nullptr, "Network element %s does not seem to be ns-3-ready", dst->get_cname()); - ns3_add_direct_route(host_src, host_dst, link->get_bandwidth(), link->get_latency(), link->get_sharing_policy()); + ns3_add_direct_route(host_src, host_dst, link->get_bandwidth(), link->get_latency(), link->get_name(), link->get_sharing_policy()); } else { static bool warned_about_long_routes = false; @@ -192,7 +234,6 @@ NetworkNS3Model::~NetworkNS3Model() { LinkImpl* NetworkNS3Model::create_link(const std::string& name, const std::vector& bandwidths, double latency, s4u::Link::SharingPolicy policy) { - XBT_INFO("create_link"); xbt_assert(bandwidths.size() == 1, "ns-3 links must use only 1 bandwidth."); return new LinkNS3(this, name, bandwidths[0], latency, policy); } @@ -298,33 +339,61 @@ LinkNS3::LinkNS3(NetworkNS3Model* model, const std::string& name, double bandwid s4u::Link::SharingPolicy policy) : LinkImpl(model, name, nullptr) { - XBT_INFO("LinkNS3"); bandwidth_.peak = bandwidth; latency_.peak = latency; sharing_policy_ = policy; - /* If wifi, create the wifizone now. If not, don't do anything: the links will be created in routeCreate_cb */ - if (policy == s4u::Link::SharingPolicy::WIFI) { -// ns3::NodeContainer ap_nodes; -// ap_nodes.Create(1); - -// phy.SetChannel (channel.Create ()); - -// wifi.SetRemoteStationManager ("ns3::AarfWifiManager"); - -// mac.SetType ("ns3::ApWifiMac"); -// ns3::NetDeviceContainer apDevices; -// apDevices = wifi.Install (phy, mac, ap_nodes); - -// mobility.SetMobilityModel ("ns3::ConstantPositionMobilityModel"); -// mobility.Install (ap_nodes); + if (policy == simgrid::s4u::Link::SharingPolicy::WIFI) { + static bool wifi_init = false; + if (!wifi_init) { + initialize_ns3_wifi(); + wifi_init = true; + } + + ns3::NetDeviceContainer netA; + WifiZone* zone = WifiZone::by_name(name); + xbt_assert(zone != 0, "Link name '%s' does not match the 'wifi_link' property of a host.", name.c_str()); + NetPointNs3* netpoint_ns3 = zone->get_host()->get_netpoint()->extension(); + + wifi.SetRemoteStationManager ("ns3::ConstantRateWifiManager", + "ControlMode", ns3::StringValue ("HtMcs0"), + "DataMode", ns3::StringValue ("HtMcs" + std::to_string(zone->get_mcs()))); + + wifiPhy.SetChannel (zone->get_channel()); + wifiPhy.Set("Antennas", ns3::UintegerValue(zone->get_nss())); + wifiPhy.Set("MaxSupportedTxSpatialStreams", ns3::UintegerValue(zone->get_nss())); + wifiPhy.Set("MaxSupportedRxSpatialStreams", ns3::UintegerValue(zone->get_nss())); + wifiMac.SetType("ns3::ApWifiMac", + "Ssid", ns3::SsidValue(name)); -// stack.Install(ap_nodes); + netA.Add(wifi.Install (wifiPhy, wifiMac, zone->get_ap_node())); -// ns3::Ipv4AddressHelper address; -// std::string addr = simgrid::xbt::string_printf("%d.%d.0.0", number_of_networks, number_of_links); -// address.SetBase(addr.c_str(), "255.255.0.0"); -// interfaces.Add(address.Assign(apDevices)); + ns3::Ptr positionAllocS = ns3::CreateObject (); + positionAllocS->Add(ns3::Vector(0, 0, 0)); + mobility.SetPositionAllocator(positionAllocS); + mobility.SetMobilityModel ("ns3::ConstantPositionMobilityModel"); + mobility.Install(zone->get_ap_node()); + + ns3::Ipv4AddressHelper address; + std::string addr = simgrid::xbt::string_printf("%d.%d.0.0", number_of_networks, number_of_links); + address.SetBase(addr.c_str(), "255.255.0.0"); + XBT_DEBUG("\tInterface stack '%s'", addr.c_str()); + interfaces.Add(address.Assign (netA)); + zone->set_network(number_of_networks); + zone->set_link(number_of_links); + + int nodeNum = netpoint_ns3->node_num; + if (IPV4addr.size() <= (unsigned)nodeNum) + IPV4addr.resize(nodeNum + 1); + IPV4addr[nodeNum] = transformIpv4Address(interfaces.GetAddress(interfaces.GetN() - 1)); + + if (number_of_links == 255){ + xbt_assert(number_of_networks < 255, "Number of links and networks exceed 255*255"); + number_of_links = 1; + number_of_networks++; + } else { + number_of_links++; + } } s4u::Link::on_creation(*this->get_iface()); } @@ -508,11 +577,9 @@ static std::string transformIpv4Address(ns3::Ipv4Address from) return sstream.str(); } -void ns3_add_direct_route(NetPointNs3* src, NetPointNs3* dst, double bw, double lat, +void ns3_add_direct_route(NetPointNs3* src, NetPointNs3* dst, double bw, double lat, std::string link_name, simgrid::s4u::Link::SharingPolicy policy) { - - XBT_INFO("ns3_add_direct_route"); ns3::Ipv4AddressHelper address; ns3::NetDeviceContainer netA; @@ -523,73 +590,74 @@ void ns3_add_direct_route(NetPointNs3* src, NetPointNs3* dst, double bw, double ns3::Ptr b = dst->ns3_node_; if (policy == simgrid::s4u::Link::SharingPolicy::WIFI) { -// wifi.SetStandard (ns3::WIFI_PHY_STANDARD_80211n_2_4GHZ); -// wifi.SetStandard (ns3::WIFI_PHY_STANDARD_80211ac); - - wifiChannel.SetPropagationDelay ("ns3::ConstantSpeedPropagationDelayModel"); + xbt_assert(WifiZone::is_ap(a) != WifiZone::is_ap(b), "A wifi route can only exist between an access point node and a station node."); -// wifiChannel.AddPropagationLoss ("ns3::LogDistancePropagationLossModel", -// "Exponent", ns3::DoubleValue (3.0), -// "ReferenceLoss", ns3::DoubleValue (40.0459)); + ns3::Ptr apNode = WifiZone::is_ap(a) ? a : b; + ns3::Ptr staNode = apNode == a ? b : a; - wifiPhy.SetChannel (wifiChannel.Create ()); + WifiZone* zone = WifiZone::by_name(link_name); -// wifi.SetRemoteStationManager ("ns3::ConstantRateWifiManager", -// "ControlMode", ns3::StringValue ("VhtMcs0"), -// "DataMode", ns3::StringValue ("VhtMcs9")); + wifi.SetRemoteStationManager ("ns3::ConstantRateWifiManager", + "ControlMode", ns3::StringValue ("HtMcs0"), + "DataMode", ns3::StringValue ("HtMcs" + std::to_string(zone->get_mcs()))); - mobility.SetMobilityModel ("ns3::ConstantPositionMobilityModel"); + wifiPhy.SetChannel (zone->get_channel()); + wifiPhy.Set("Antennas", ns3::UintegerValue(zone->get_nss())); + wifiPhy.Set("MaxSupportedTxSpatialStreams", ns3::UintegerValue(zone->get_nss())); + wifiPhy.Set("MaxSupportedRxSpatialStreams", ns3::UintegerValue(zone->get_nss())); - ns3::Ssid ssid = ns3::Ssid (std::to_string(number_of_networks) + "_" + std::to_string(number_of_links)); + wifiMac.SetType ("ns3::StaWifiMac", + "Ssid", ns3::SsidValue(link_name), + "ActiveProbing", ns3::BooleanValue(false)); - wifiMac.SetType("ns3::ApWifiMac", - "Ssid", ns3::SsidValue (ssid)); - netA.Add(wifi.Install (wifiPhy, wifiMac, a)); + netA.Add(wifi.Install (wifiPhy, wifiMac, staNode)); - wifiMac.SetType ("ns3::StaWifiMac", - "Ssid", ns3::SsidValue (ssid), - "ActiveProbing", ns3::BooleanValue (false)); - netA.Add(wifi.Install (wifiPhy, wifiMac, b)); + ns3::Config::Set ("/NodeList/*/DeviceList/*/$ns3::WifiNetDevice/Phy/ChannelWidth", ns3::UintegerValue (40)); + NetPointNs3* sta_netpointNs3 = WifiZone::is_ap(src->ns3_node_) ? dst : src; + const char* wifi_distance = simgrid::s4u::Host::by_name(sta_netpointNs3->name_)->get_property("wifi_distance"); ns3::Ptr positionAllocS = ns3::CreateObject (); -// positionAllocS->Add(ns3::Vector(-5, mobility_base, 0.0)); -// positionAllocS->Add(ns3::Vector(5, mobility_base, 0.0)); - positionAllocS->Add(ns3::Vector(-5, 0, 0.0)); - positionAllocS->Add(ns3::Vector(5, 0, 0.0)); -// mobility_base += mobility_delta; + positionAllocS->Add(ns3::Vector( wifi_distance ? atof(wifi_distance) : 10.0 , 0, 0)); mobility.SetPositionAllocator(positionAllocS); - mobility.Install(a); - mobility.Install(b); - + mobility.SetMobilityModel ("ns3::ConstantPositionMobilityModel"); + mobility.Install(staNode); + + std::string addr = simgrid::xbt::string_printf("%d.%d.0.0", zone->get_network(), zone->get_link()); + address.SetBase(addr.c_str(), "255.255.0.0", ("0.0.0." + std::to_string(zone->get_n_sta_nodes() + 2)).c_str()); + zone->add_sta_node(); + XBT_DEBUG("\tInterface stack '%s'", addr.c_str()); + interfaces.Add(address.Assign (netA)); + if (IPV4addr.size() <= (unsigned)dstNum) + IPV4addr.resize(dstNum + 1); + IPV4addr[dstNum] = transformIpv4Address(interfaces.GetAddress(interfaces.GetN() - 1)); } else { ns3::PointToPointHelper pointToPoint; - XBT_DEBUG("\tAdd PTP from %d to %d bw:'%f Bps' lat:'%fs'", srcNum, dstNum, bw, lat); pointToPoint.SetDeviceAttribute("DataRate", ns3::DataRateValue(ns3::DataRate(bw * 8))); // ns-3 takes bps, but we provide Bps pointToPoint.SetChannelAttribute("Delay", ns3::TimeValue(ns3::Seconds(lat))); netA.Add(pointToPoint.Install(a, b)); - } - std::string addr = simgrid::xbt::string_printf("%d.%d.0.0", number_of_networks, number_of_links); - address.SetBase(addr.c_str(), "255.255.0.0"); - XBT_DEBUG("\tInterface stack '%s'", addr.c_str()); - interfaces.Add(address.Assign (netA)); + std::string addr = simgrid::xbt::string_printf("%d.%d.0.0", number_of_networks, number_of_links); + address.SetBase(addr.c_str(), "255.255.0.0"); + XBT_DEBUG("\tInterface stack '%s'", addr.c_str()); + interfaces.Add(address.Assign (netA)); - if (IPV4addr.size() <= (unsigned)srcNum) - IPV4addr.resize(srcNum + 1); - IPV4addr[srcNum] = transformIpv4Address(interfaces.GetAddress(interfaces.GetN() - 2)); + if (IPV4addr.size() <= (unsigned)srcNum) + IPV4addr.resize(srcNum + 1); + IPV4addr[srcNum] = transformIpv4Address(interfaces.GetAddress(interfaces.GetN() - 2)); - if (IPV4addr.size() <= (unsigned)dstNum) - IPV4addr.resize(dstNum + 1); - IPV4addr[dstNum] = transformIpv4Address(interfaces.GetAddress(interfaces.GetN() - 1)); + if (IPV4addr.size() <= (unsigned)dstNum) + IPV4addr.resize(dstNum + 1); + IPV4addr[dstNum] = transformIpv4Address(interfaces.GetAddress(interfaces.GetN() - 1)); - if (number_of_links == 255){ - xbt_assert(number_of_networks < 255, "Number of links and networks exceed 255*255"); - number_of_links = 1; - number_of_networks++; - } else { - number_of_links++; + if (number_of_links == 255){ + xbt_assert(number_of_networks < 255, "Number of links and networks exceed 255*255"); + number_of_links = 1; + number_of_networks++; + } else { + number_of_links++; + } } }