X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/fc173cad261827e1f434ddde3630538e86ba2265..51c23076e2b42ff07dc167dea1cb0e3a4ab3cf68:/src/s4u/s4u_Engine.cpp diff --git a/src/s4u/s4u_Engine.cpp b/src/s4u/s4u_Engine.cpp index 1263f114b0..ab520f2f59 100644 --- a/src/s4u/s4u_Engine.cpp +++ b/src/s4u/s4u_Engine.cpp @@ -188,10 +188,17 @@ void Engine::run() } } -s4u::NetZone* Engine::getNetRoot() +/** @brief Retrieve the root netzone, containing all others */ +s4u::NetZone* Engine::get_netzone_root() { return pimpl->netzone_root_; } +/** @brief Set the root netzone, containing all others. Once set, it cannot be changed. */ +void Engine::set_netzone_root(s4u::NetZone* netzone) +{ + xbt_assert(pimpl->netzone_root_ == nullptr, "The root NetZone cannot be changed once set"); + pimpl->netzone_root_ = static_cast(netzone); +} static s4u::NetZone* netzone_by_name_recursive(s4u::NetZone* current, const char* name) { @@ -208,13 +215,13 @@ static s4u::NetZone* netzone_by_name_recursive(s4u::NetZone* current, const char } /** @brief Retrieve the NetZone of the given name (or nullptr if not found) */ -NetZone* Engine::getNetzoneByNameOrNull(const char* name) +NetZone* Engine::netzone_by_name_or_null(const char* name) { - return netzone_by_name_recursive(getNetRoot(), name); + return netzone_by_name_recursive(get_netzone_root(), name); } /** @brief Retrieve the netpoint of the given name (or nullptr if not found) */ -simgrid::kernel::routing::NetPoint* Engine::getNetpointByNameOrNull(std::string name) +simgrid::kernel::routing::NetPoint* Engine::netpoint_by_name_or_null(std::string name) { auto netp = pimpl->netpoints_.find(name); return netp == pimpl->netpoints_.end() ? nullptr : netp->second; @@ -237,14 +244,14 @@ std::vector Engine::get_all_netpoints() /** @brief Register a new netpoint to the system */ void Engine::netpoint_register(simgrid::kernel::routing::NetPoint* point) { - // simgrid::simix::kernelImmediate([&]{ FIXME: this segfaults in set_thread + // simgrid::simix::simcall([&]{ FIXME: this segfaults in set_thread pimpl->netpoints_[point->get_name()] = point; // }); } /** @brief Unregister a given netpoint */ void Engine::netpoint_unregister(simgrid::kernel::routing::NetPoint* point) { - simgrid::simix::kernelImmediate([this, point] { + simgrid::simix::simcall([this, point] { pimpl->netpoints_.erase(point->get_name()); delete point; }); @@ -260,3 +267,27 @@ void Engine::set_config(std::string str) } } // namespace s4u } // namespace simgrid + +/* **************************** Public C interface *************************** */ +void sg_engine_load_platform(const char* file) +{ + simgrid::s4u::Engine::get_instance()->load_platform(file); +} + +void sg_engine_load_deployment(const char* file) +{ + simgrid::s4u::Engine::get_instance()->load_deployment(file); +} + +void sg_engine_register_function(const char* name, int (*code)(int, char**)) +{ + simgrid::s4u::Engine::get_instance()->register_function(name, code); +} +void sg_engine_register_default(int (*code)(int, char**)) +{ + simgrid::s4u::Engine::get_instance()->register_default(code); +} +double sg_engine_get_clock() +{ + return simgrid::s4u::Engine::get_clock(); +}