X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/deaf4c6f1cb3026b053ca861fe77313c78385be7..5b867af718c91a3279c07e08ab9bcf164ff64466:/src/surf/network_ns3.cpp diff --git a/src/surf/network_ns3.cpp b/src/surf/network_ns3.cpp index 0402324415..a11bc1f283 100644 --- a/src/surf/network_ns3.cpp +++ b/src/surf/network_ns3.cpp @@ -221,17 +221,17 @@ void NetworkNS3Model::updateActionsState(double now, double delta) SgFlow* sgFlow = elm.second; NetworkNS3Action * action = sgFlow->action_; XBT_DEBUG("Processing socket %p (action %p)",sgFlow,action); - action->setRemains(action->getCost() - sgFlow->sentBytes_); + action->set_remains(action->get_cost() - sgFlow->sentBytes_); - if (TRACE_is_enabled() && action->getState() == kernel::resource::Action::State::running) { + if (TRACE_is_enabled() && action->get_state() == kernel::resource::Action::State::running) { double data_delta_sent = sgFlow->sentBytes_ - action->lastSent_; std::vector route = std::vector(); action->src_->routeTo(action->dst_, route, nullptr); for (auto const& link : route) - TRACE_surf_link_set_utilization(link->getCname(), action->getCategory(), (data_delta_sent) / delta, now - delta, - delta); + TRACE_surf_link_set_utilization(link->getCname(), action->get_category(), (data_delta_sent) / delta, + now - delta, delta); action->lastSent_ = sgFlow->sentBytes_; } @@ -339,30 +339,11 @@ std::list NetworkNS3Action::links() { THROW_UNIMPLEMENTED; } -void NetworkNS3Action::updateRemainingLazy(double /*now*/) +void NetworkNS3Action::update_remains_lazy(double /*now*/) { THROW_IMPOSSIBLE; } -/* Test whether a flow is suspended */ -bool NetworkNS3Action::isSuspended() -{ - return false; -} - -int NetworkNS3Action::unref() -{ - refcount_--; - if (not refcount_) { - if (stateSetHook_.is_linked()) - simgrid::xbt::intrusive_erase(*stateSet_, *this); - XBT_DEBUG ("Removing action %p", this); - delete this; - return 1; - } - return 0; -} - } }