X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/a1fcc0c0597c993b03448f6244bbdfef3c6850e4..HEAD:/src/s4u/s4u_Engine.cpp diff --git a/src/s4u/s4u_Engine.cpp b/src/s4u/s4u_Engine.cpp index 4daf853d49..094e8311d1 100644 --- a/src/s4u/s4u_Engine.cpp +++ b/src/s4u/s4u_Engine.cpp @@ -1,204 +1,517 @@ /* s4u::Engine Simulation Engine and global functions. */ -/* Copyright (c) 2006-2018. The SimGrid Team. All rights reserved. */ +/* Copyright (c) 2006-2023. The SimGrid Team. All rights reserved. */ /* This program is free software; you can redistribute it and/or modify it * under the terms of the license (GNU LGPL) which comes with this package. */ -#include "mc/mc.h" -#include "simgrid/kernel/routing/NetPoint.hpp" -#include "simgrid/kernel/routing/NetZoneImpl.hpp" -#include "simgrid/s4u/Engine.hpp" -#include "simgrid/s4u/Host.hpp" -#include "simgrid/s4u/Mailbox.hpp" -#include "simgrid/s4u/NetZone.hpp" -#include "simgrid/s4u/Storage.hpp" -#include "simgrid/simix.h" +#include +#include +#include + #include "src/instr/instr_private.hpp" #include "src/kernel/EngineImpl.hpp" -#include "src/surf/network_interface.hpp" -#include "surf/surf.hpp" // routing_platf. FIXME:KILLME. SOON +#include "src/kernel/resource/HostImpl.hpp" +#include "src/kernel/resource/NetworkModel.hpp" +#include "src/kernel/resource/SplitDuplexLinkImpl.hpp" +#include "src/kernel/resource/StandardLinkImpl.hpp" +#include "src/mc/mc.h" +#include "src/mc/mc_replay.hpp" +#include "xbt/config.hpp" + +#include +#include + +XBT_LOG_NEW_CATEGORY(s4u, "Log channels of the S4U (SimGrid for you) interface"); +XBT_LOG_NEW_DEFAULT_SUBCATEGORY(s4u_engine, s4u, "Logging specific to S4U (engine)"); -XBT_LOG_NEW_CATEGORY(s4u, "Log channels of the S4U (Simgrid for you) interface"); +static simgrid::kernel::actor::ActorCode maestro_code; -namespace simgrid { -namespace s4u { -xbt::signal on_platform_creation; -xbt::signal on_platform_created; -xbt::signal onSimulationEnd; -xbt::signal onTimeAdvance; -xbt::signal onDeadlock; +namespace simgrid::s4u { +xbt::signal Engine::on_platform_creation; +xbt::signal Engine::on_platform_created; +xbt::signal Engine::on_simulation_start; +xbt::signal Engine::on_simulation_end; +xbt::signal Engine::on_time_advance; +xbt::signal Engine::on_deadlock; -Engine* Engine::instance_ = nullptr; /* That singleton is awful, but I don't see no other solution right now. */ +Engine* Engine::instance_ = nullptr; /* This singleton is awful, but I don't see no other solution right now. */ -Engine::Engine(int* argc, char** argv) +void Engine::initialize(int* argc, char** argv) { - xbt_assert(s4u::Engine::instance_ == nullptr, - "It is currently forbidden to create more than one instance of s4u::Engine"); - TRACE_global_init(); - SIMIX_global_init(argc, argv); + xbt_assert(Engine::instance_ == nullptr, "It is currently forbidden to create more than one instance of s4u::Engine"); + Engine::instance_ = this; + instr::init(); + pimpl_->initialize(argc, argv); + // Either create a new context with maestro or create + // a context object with the current context maestro): + kernel::actor::create_maestro(maestro_code); +} - pimpl = new kernel::EngineImpl(); - s4u::Engine::instance_ = this; +Engine::Engine(std::string name) : pimpl_(new kernel::EngineImpl()) +{ + int argc = 1; + char* argv = &name[0]; + initialize(&argc, &argv); } -Engine::~Engine() +Engine::Engine(int* argc, char** argv) : pimpl_(new kernel::EngineImpl()) { - delete pimpl; - s4u::Engine::instance_ = nullptr; + initialize(argc, argv); } -Engine* Engine::getInstance() +Engine::~Engine() { - if (s4u::Engine::instance_ == nullptr) - return new Engine(0, nullptr); - else - return s4u::Engine::instance_; + kernel::EngineImpl::shutdown(); + Engine::instance_ = nullptr; } -void Engine::shutdown() +/** @brief Retrieve the engine singleton */ +Engine* Engine::get_instance() { - delete s4u::Engine::instance_; - s4u::Engine::instance_ = nullptr; + int argc = 0; + char* argv = nullptr; + return get_instance(&argc, &argv); +} +Engine* Engine::get_instance(int* argc, char** argv) +{ + if (Engine::instance_ == nullptr) { + const auto* e = new Engine(argc, argv); + xbt_assert(Engine::instance_ == e); + } + return Engine::instance_; +} +const std::vector& Engine::get_cmdline() const +{ + return pimpl_->get_cmdline(); } double Engine::get_clock() { - return SIMIX_get_clock(); + if (MC_is_active() || MC_record_replay_is_active()) { + return MC_process_clock_get(kernel::actor::ActorImpl::self()); + } else { + return kernel::EngineImpl::get_clock(); + } +} + +void Engine::add_model(std::shared_ptr model, + const std::vector& dependencies) +{ + kernel::actor::simcall_answered([this, &model, &dependencies] { pimpl_->add_model(std::move(model), dependencies); }); } -void Engine::load_platform(const char* platf) +const std::vector& Engine::get_all_models() const { - SIMIX_create_environment(platf); + return pimpl_->get_all_models(); } -void Engine::register_function(const char* name, int (*code)(int, char**)) +void Engine::load_platform(const std::string& platf) const { - SIMIX_function_register(name, code); + pimpl_->load_platform(platf); +} + +void Engine::seal_platform() const +{ + pimpl_->seal_platform(); +} + +static void flatify_hosts(Engine const& engine, std::stringstream& ss) +{ + // Regular hosts + std::vector hosts = engine.get_all_hosts(); + + for (auto const* h : hosts) { + ss << " get_name() << "\" speed=\"" << h->get_speed() << "\""; + const std::unordered_map* props = h->get_properties(); + if (h->get_core_count() > 1) + ss << " core=\"" << h->get_core_count() << "\""; + + // Sort the properties before displaying them, so that the tests are perfectly reproducible + std::vector keys; + for (auto const& [key, _] : *props) + keys.push_back(key); + if (not keys.empty()) { + ss << ">\n"; + std::sort(keys.begin(), keys.end()); + for (const std::string& key : keys) + ss << " at(key) << "\"/>\n"; + ss << " \n"; + } else { + ss << "/>\n"; + } + } + + // Routers + std::vector netpoints = engine.get_all_netpoints(); + std::sort(netpoints.begin(), netpoints.end(), + [](const simgrid::kernel::routing::NetPoint* a, const simgrid::kernel::routing::NetPoint* b) { + return a->get_name() < b->get_name(); + }); + + for (auto const& src : netpoints) + if (src->is_router()) + ss << " get_name() << "\"/>\n"; +} + +static void flatify_links(Engine const& engine, std::stringstream& ss) +{ + std::vector links = engine.get_all_links(); + + std::sort(links.begin(), links.end(), [](const Link* a, const Link* b) { return a->get_name() < b->get_name(); }); + + for (auto const* link : links) { + ss << " get_name() << "\""; + ss << " bandwidth=\"" << link->get_bandwidth() << "\""; + ss << " latency=\"" << link->get_latency() << "\""; + if (link->get_concurrency_limit() != -1) + ss << " concurrency=\"" << link->get_concurrency_limit() << "\""; + if (link->is_shared()) { + ss << "/>\n"; + } else { + ss << " sharing_policy=\"FATPIPE\"/>\n"; + } + } } -void Engine::register_default(int (*code)(int, char**)) + +static void flatify_routes(Engine const& engine, std::stringstream& ss) +{ + auto hosts = engine.get_all_hosts(); + auto netpoints = engine.get_all_netpoints(); + std::sort(netpoints.begin(), netpoints.end(), + [](const simgrid::kernel::routing::NetPoint* a, const simgrid::kernel::routing::NetPoint* b) { + return a->get_name() < b->get_name(); + }); + + for (auto const* src_host : hosts) { // Routes from host + const simgrid::kernel::routing::NetPoint* src = src_host->get_netpoint(); + for (auto const* dst_host : hosts) { // Routes to host + std::vector route; + const simgrid::kernel::routing::NetPoint* dst = dst_host->get_netpoint(); + simgrid::kernel::routing::NetZoneImpl::get_global_route(src, dst, route, nullptr); + if (route.empty()) + continue; + ss << " get_name() << "\" dst=\"" << dst_host->get_name() << "\">\n "; + for (auto const& link : route) + ss << "get_name() << "\"/>"; + ss << "\n \n"; + } + + for (auto const& dst : netpoints) { // to router + if (not dst->is_router()) + continue; + ss << " get_name() << "\" dst=\"" << dst->get_name() << "\">\n "; + std::vector route; + simgrid::kernel::routing::NetZoneImpl::get_global_route(src, dst, route, nullptr); + for (auto const& link : route) + ss << "get_name() << "\"/>"; + ss << "\n \n"; + } + } + + for (auto const& value1 : netpoints) { // Routes from router + if (not value1->is_router()) + continue; + for (auto const& value2 : netpoints) { // to router + if (not value2->is_router()) + continue; + std::vector route; + simgrid::kernel::routing::NetZoneImpl::get_global_route(value1, value2, route, nullptr); + if (route.empty()) + continue; + ss << " get_name() << "\" dst=\"" << value2->get_name() << "\">\n "; + for (auto const& link : route) + ss << "get_name() << "\"/>"; + ss << "\n \n"; + } + for (auto const* dst_host : hosts) { // Routes to host + ss << " get_name() << "\" dst=\"" << dst_host->get_name() << "\">\n "; + std::vector route; + const simgrid::kernel::routing::NetPoint* netcardDst = dst_host->get_netpoint(); + simgrid::kernel::routing::NetZoneImpl::get_global_route(value1, netcardDst, route, nullptr); + for (auto const& link : route) + ss << "get_name() << "\"/>"; + ss << "\n \n"; + } + } +} +std::string Engine::flatify_platform() const { - SIMIX_function_register_default(code); + std::string version = "4.1"; + std::stringstream ss; + + ss << "\n"; + ss << "\n"; + ss << "\n"; + ss << "get_name() << "\" routing=\"Full\">\n"; + + flatify_hosts(*this, ss); + flatify_links(*this, ss); + flatify_routes(*this, ss); + + ss << "\n"; + ss << "\n"; + return ss.str(); } -void Engine::load_deployment(const char* deploy) + +/** Registers the main function of an actor that will be launched from the deployment file */ +void Engine::register_function(const std::string& name, const std::function& code) { - SIMIX_launch_application(deploy); + kernel::actor::ActorCodeFactory code_factory = [code](std::vector args) { + return xbt::wrap_main(code, std::move(args)); + }; + register_function(name, code_factory); } -/** @brief Returns the amount of hosts in the platform */ -size_t Engine::get_host_count() + +/** Registers the main function of an actor that will be launched from the deployment file */ +void Engine::register_function(const std::string& name, const std::function)>& code) { - return pimpl->hosts_.size(); + kernel::actor::ActorCodeFactory code_factory = [code{code}](std::vector args) mutable { + return std::bind(std::move(code), std::move(args)); + }; + register_function(name, code_factory); } -/** @brief Fills the passed list with all hosts found in the platform - * @deprecated Please prefer Engine::getAllHosts() +/** Registers a function as the default main function of actors + * + * It will be used as fallback when the function requested from the deployment file was not registered. + * It is used for trace-based simulations (see examples/cpp/replay-comms and similar). */ -void Engine::getHostList(std::vector* list) +void Engine::register_default(const std::function& code) { - for (auto const& kv : pimpl->hosts_) - list->push_back(kv.second); + register_default([code](std::vector args) { return xbt::wrap_main(code, std::move(args)); }); +} +void Engine::register_default(const kernel::actor::ActorCodeFactory& code) +{ + simgrid::kernel::actor::simcall_answered([this, &code]() { pimpl_->register_default(code); }); } -/** @brief Returns the list of all hosts found in the platform */ -std::vector Engine::get_all_hosts() +void Engine::register_function(const std::string& name, const kernel::actor::ActorCodeFactory& code) { - std::vector res; - for (auto const& kv : pimpl->hosts_) - res.push_back(kv.second); - return res; + simgrid::kernel::actor::simcall_answered([this, name, &code]() { pimpl_->register_function(name, code); }); } -void Engine::host_register(std::string name, simgrid::s4u::Host* host) +/** Load a deployment file and launch the actors that it contains + * + * @beginrst + * See also: :ref:`deploy`. + * @endrst + */ +void Engine::load_deployment(const std::string& deploy) const { - pimpl->hosts_[name] = host; + pimpl_->load_deployment(deploy); } -void Engine::host_unregister(std::string name) +/** Returns the amount of hosts in the platform */ +size_t Engine::get_host_count() const { - pimpl->hosts_.erase(name); + return get_all_hosts().size(); } -simgrid::s4u::Host* Engine::host_by_name(std::string name) +std::vector Engine::get_all_hosts() const { - return pimpl->hosts_.at(name); // Will raise a std::out_of_range if the host does not exist + return get_filtered_hosts([](const Host*) { return true; }); } -simgrid::s4u::Host* Engine::host_by_name_or_null(std::string name) +std::vector Engine::get_filtered_hosts(const std::function& filter) const { - auto host = pimpl->hosts_.find(name); - return host == pimpl->hosts_.end() ? nullptr : host->second; + std::vector hosts; + if (pimpl_->netzone_root_) { + hosts = pimpl_->netzone_root_->get_filtered_hosts(filter); + } + /* Sort hosts in lexicographical order: keep same behavior when the hosts were saved on Engine + * Some tests do a get_all_hosts() and selects hosts in this order */ + std::sort(hosts.begin(), hosts.end(), [](const auto* h1, const auto* h2) { return h1->get_name() < h2->get_name(); }); + + return hosts; } -/** @brief Returns the amount of storages in the platform */ -size_t Engine::get_storage_count() +/** @brief Find a host from its name. + * + * @throw std::invalid_argument if the searched host does not exist. + */ +Host* Engine::host_by_name(const std::string& name) const { - return pimpl->storages_.size(); + auto* host = host_by_name_or_null(name); + if (not host) + throw std::invalid_argument("Host not found: '" + name + "'"); + return host; } -/** @brief Returns the list of all storages found in the platform */ -std::vector Engine::get_all_storages() +/** @brief Find a host from its name (or nullptr if that host does not exist) */ +Host* Engine::host_by_name_or_null(const std::string& name) const { - std::vector res; - for (auto const& kv : pimpl->storages_) - res.push_back(kv.second); - return res; + Host* host = nullptr; + if (pimpl_->netzone_root_) { + auto* host_impl = pimpl_->netzone_root_->get_host_by_name_or_null(name); + if (host_impl) + host = host_impl->get_iface(); + } + return host; } -simgrid::s4u::Storage* Engine::storage_by_name(std::string name) +/** @brief Find a link from its name. + * + * @throw std::invalid_argument if the searched link does not exist. + */ +Link* Engine::link_by_name(const std::string& name) const { - return pimpl->storages_.at(name); // Will raise a std::out_of_range if the host does not exist + auto* link = link_by_name_or_null(name); + if (not link) + throw std::invalid_argument("Link not found: " + name); + return link; } -simgrid::s4u::Storage* Engine::storage_by_name_or_null(std::string name) +SplitDuplexLink* Engine::split_duplex_link_by_name(const std::string& name) const { - auto storage = pimpl->storages_.find(name); - return storage == pimpl->storages_.end() ? nullptr : storage->second; + auto* link_impl = + pimpl_->netzone_root_ ? pimpl_->netzone_root_->get_split_duplex_link_by_name_or_null(name) : nullptr; + if (not link_impl) + throw std::invalid_argument("Link not found: " + name); + return link_impl->get_iface(); } -void Engine::storage_register(std::string name, simgrid::s4u::Storage* storage) +/** @brief Find a link from its name (or nullptr if that link does not exist) */ +Link* Engine::link_by_name_or_null(const std::string& name) const { - pimpl->storages_[name] = storage; + Link* link = nullptr; + if (pimpl_->netzone_root_) { + /* keep behavior where internal __loopback__ link from network model is given to user */ + if (name == "__loopback__") + return pimpl_->netzone_root_->get_network_model()->loopback_->get_iface(); + auto* link_impl = pimpl_->netzone_root_->get_link_by_name_or_null(name); + if (link_impl) + link = link_impl->get_iface(); + } + return link; } -void Engine::storage_unregister(std::string name) +/** @brief Find a mailbox from its name or create one if it does not exist) */ +Mailbox* Engine::mailbox_by_name_or_create(const std::string& name) const { - pimpl->storages_.erase(name); + /* two actors may have pushed the same mbox_create simcall at the same time */ + kernel::activity::MailboxImpl* mbox = kernel::actor::simcall_answered([&name, this] { + auto [m, inserted] = pimpl_->mailboxes_.try_emplace(name, nullptr); + if (inserted) { + m->second = new kernel::activity::MailboxImpl(name); + XBT_DEBUG("Creating a mailbox at %p with name %s", m->second, name.c_str()); + } + return m->second; + }); + return mbox->get_iface(); +} + +MessageQueue* Engine::message_queue_by_name_or_create(const std::string& name) const +{ + /* two actors may have pushed the same mbox_create simcall at the same time */ + kernel::activity::MessageQueueImpl* queue = kernel::actor::simcall_answered([&name, this] { + auto [m, inserted] = pimpl_->mqueues_.try_emplace(name, nullptr); + if (inserted) { + m->second = new kernel::activity::MessageQueueImpl(name); + XBT_DEBUG("Creating a message queue at %p with name %s", m->second, name.c_str()); + } + return m->second; + }); + return queue->get_iface(); } /** @brief Returns the amount of links in the platform */ -size_t Engine::get_link_count() +size_t Engine::get_link_count() const { - return kernel::resource::LinkImpl::linksCount(); + int count = 0; + if (pimpl_->netzone_root_) { + count += pimpl_->netzone_root_->get_link_count(); + /* keep behavior where internal __loopback__ link from network model is given to user */ + count += pimpl_->netzone_root_->get_network_model()->loopback_ ? 1 : 0; + } + return count; } /** @brief Returns the list of all links found in the platform */ -std::vector Engine::get_all_links() +std::vector Engine::get_all_links() const +{ + return get_filtered_links([](const Link*) { return true; }); +} + +std::vector Engine::get_filtered_links(const std::function& filter) const { std::vector res; - kernel::resource::LinkImpl::linksList(&res); + if (pimpl_->netzone_root_) { + res = pimpl_->netzone_root_->get_filtered_links(filter); + /* keep behavior where internal __loopback__ link from network model is given to user */ + if (pimpl_->netzone_root_->get_network_model()->loopback_ && + filter(pimpl_->netzone_root_->get_network_model()->loopback_->get_iface())) + res.push_back(pimpl_->netzone_root_->get_network_model()->loopback_->get_iface()); + } return res; } -void Engine::run() +size_t Engine::get_actor_count() const { - if (MC_is_active()) { - MC_run(); - } else { - SIMIX_run(); + return pimpl_->get_actor_count(); +} + +std::vector Engine::get_all_actors() const +{ + std::vector actor_list; + for (auto const& [_, actor] : pimpl_->get_actor_list()) { + actor_list.push_back(actor->get_iface()); + } + return actor_list; +} + +std::vector Engine::get_filtered_actors(const std::function& filter) const +{ + std::vector actor_list; + for (auto const& [_, actor] : pimpl_->get_actor_list()) { + if (filter(actor->get_iface())) + actor_list.push_back(actor->get_iface()); + } + return actor_list; +} + +void Engine::run() const +{ + run_until(-1); +} +void Engine::run_until(double max_date) const +{ + if (static bool callback_called = false; not callback_called) { + on_simulation_start(); + callback_called = true; } + /* Clean IO before the run */ + fflush(stdout); + fflush(stderr); + + pimpl_->run(max_date); } -s4u::NetZone* Engine::getNetRoot() +void Engine::track_vetoed_activities(std::set* vetoed_activities) const { - return pimpl->netRoot_; + Activity::set_vetoed_activities(vetoed_activities); } -static s4u::NetZone* netzoneByNameRecursive(s4u::NetZone* current, const char* name) +/** @brief Retrieve the root netzone, containing all others */ +s4u::NetZone* Engine::get_netzone_root() const { - if (not strcmp(current->get_cname(), name)) + if (pimpl_->netzone_root_) + return pimpl_->netzone_root_->get_iface(); + return nullptr; +} +/** @brief Set the root netzone, containing all others. Once set, it cannot be changed. */ +void Engine::set_netzone_root(const s4u::NetZone* netzone) +{ + xbt_assert(pimpl_->netzone_root_ == nullptr, "The root NetZone cannot be changed once set"); + pimpl_->netzone_root_ = netzone->get_impl(); +} + +static NetZone* netzone_by_name_recursive(NetZone* current, const std::string& name) +{ + if (current->get_name() == name) return current; - for (auto const& elem : *(current->getChildren())) { - simgrid::s4u::NetZone* tmp = netzoneByNameRecursive(elem, name); + for (auto const& elem : current->get_children()) { + NetZone* tmp = netzone_by_name_recursive(elem, name); if (tmp != nullptr) { return tmp; } @@ -207,47 +520,120 @@ static s4u::NetZone* netzoneByNameRecursive(s4u::NetZone* current, const char* n } /** @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 std::string& name) const { - return netzoneByNameRecursive(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) +kernel::routing::NetPoint* Engine::netpoint_by_name_or_null(const std::string& name) const +{ + auto netp = pimpl_->netpoints_.find(name); + return netp == pimpl_->netpoints_.end() ? nullptr : netp->second; +} + +kernel::routing::NetPoint* Engine::netpoint_by_name(const std::string& name) const { - auto netp = pimpl->netpoints_.find(name); - return netp == pimpl->netpoints_.end() ? nullptr : netp->second; + auto* netp = netpoint_by_name_or_null(name); + if (netp == nullptr) { + throw std::invalid_argument("Netpoint not found: " + name); + } + return netp; } -/** @brief Fill the provided vector with all existing netpoints */ -void Engine::getNetpointList(std::vector* list) +std::vector Engine::get_all_netpoints() const { - for (auto const& kv : pimpl->netpoints_) - list->push_back(kv.second); + std::vector res; + for (auto const& [_, netpoint] : pimpl_->netpoints_) + res.push_back(netpoint); + return res; } + /** @brief Register a new netpoint to the system */ -void Engine::netpoint_register(simgrid::kernel::routing::NetPoint* point) +void Engine::netpoint_register(kernel::routing::NetPoint* point) { - // simgrid::simix::kernelImmediate([&]{ FIXME: this segfaults in set_thread - pimpl->netpoints_[point->get_name()] = point; - // }); + simgrid::kernel::actor::simcall_answered([this, point] { pimpl_->netpoints_[point->get_name()] = point; }); } + /** @brief Unregister a given netpoint */ -void Engine::netpoint_unregister(simgrid::kernel::routing::NetPoint* point) +void Engine::netpoint_unregister(kernel::routing::NetPoint* point) { - simgrid::simix::kernelImmediate([this, point] { - pimpl->netpoints_.erase(point->get_name()); + kernel::actor::simcall_answered([this, point] { + pimpl_->netpoints_.erase(point->get_name()); delete point; }); } -bool Engine::isInitialized() +bool Engine::is_initialized() { return Engine::instance_ != nullptr; } -void Engine::setConfig(std::string str) +void Engine::set_config(const std::string& str) +{ + config::set_parse(str); +} +void Engine::set_config(const std::string& name, int value) +{ + config::set_value(name.c_str(), value); +} +void Engine::set_config(const std::string& name, double value) +{ + config::set_value(name.c_str(), value); +} +void Engine::set_config(const std::string& name, bool value) +{ + config::set_value(name.c_str(), value); +} +void Engine::set_config(const std::string& name, const std::string& value) +{ + config::set_value(name.c_str(), value); +} + +Engine* Engine::set_default_comm_data_copy_callback( + const std::function& callback) +{ + kernel::activity::CommImpl::set_copy_data_callback(callback); + return this; +} + +} // namespace simgrid::s4u + +/* **************************** Public C interface *************************** */ +void simgrid_init(int* argc, char** argv) +{ + static simgrid::s4u::Engine e(argc, argv); +} +void simgrid_load_platform(const char* file) +{ + simgrid::s4u::Engine::get_instance()->load_platform(file); +} + +void simgrid_load_deployment(const char* file) +{ + simgrid::s4u::Engine::get_instance()->load_deployment(file); +} +void simgrid_run() +{ + simgrid::s4u::Engine::get_instance()->run(); +} +void simgrid_run_until(double max_date) +{ + simgrid::s4u::Engine::get_instance()->run_until(max_date); +} +void simgrid_register_function(const char* name, void (*code)(int, char**)) +{ + simgrid::s4u::Engine::get_instance()->register_function(name, code); +} +void simgrid_register_default(void (*code)(int, char**)) +{ + simgrid::s4u::Engine::get_instance()->register_default(code); +} +double simgrid_get_clock() +{ + return simgrid::s4u::Engine::get_clock(); +} + +void simgrid_set_maestro(void (*code)(void*), void* data) { - simgrid::config::set_parse(std::move(str)); + maestro_code = std::bind(code, data); } -} // namespace s4u -} // namespace simgrid