X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/a769fcb118ea8b5e3fc8de4fcf920c3d656b9e71..2aefc0268e22dd27a6f3e7f0d60990c055c4ee4b:/src/bindings/python/simgrid_python.cpp diff --git a/src/bindings/python/simgrid_python.cpp b/src/bindings/python/simgrid_python.cpp index a3acac5858..05d124e876 100644 --- a/src/bindings/python/simgrid_python.cpp +++ b/src/bindings/python/simgrid_python.cpp @@ -3,6 +3,7 @@ /* 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 #include // Must be first #include @@ -31,7 +32,9 @@ namespace { static std::string get_simgrid_version() { - int major, minor, patch; + int major; + int minor; + int patch; sg_version_get(&major, &minor, &patch); return simgrid::xbt::string_printf("%i.%i.%i", major, minor, patch); } @@ -61,7 +64,7 @@ PYBIND11_MODULE(simgrid, m) "Block the current actor, computing the given amount of flops at the given priority, see :cpp:func:`void " "simgrid::s4u::this_actor::execute(double, double)`", py::arg("flops"), py::arg("priority") = 1); - m2.def("get_host", &simgrid::s4u::this_actor::get_host, "Retrives host on which the current actor is located"); + m2.def("get_host", &simgrid::s4u::this_actor::get_host, "Retrieves host on which the current actor is located"); m2.def("migrate", &simgrid::s4u::this_actor::migrate, "Moves the current actor to another host, see :cpp:func:`void simgrid::s4u::this_actor::migrate()`", py::arg("dest")); m2.def("sleep_for", sleep_for_fun, @@ -72,13 +75,20 @@ PYBIND11_MODULE(simgrid, m) m2.def("yield_", &simgrid::s4u::this_actor::yield, "Yield the actor, see :cpp:func:`void simgrid::s4u::this_actor::yield()`"); m2.def("exit", &simgrid::s4u::this_actor::exit, "kill the current actor"); - m2.def("kill", [](py::int_ pid) { Actor::kill(pid); }, "Kill an actor by pid"); - m2.def("kill_all", &Actor::kill_all, "Kill all actors but the caller."); - - m2.def( - "on_exit", - [](py::function fun) { simgrid::s4u::this_actor::on_exit([fun](int ignored, void* data) { fun(); }, nullptr); }, - ""); + m2.def("on_exit", + [](py::object fun) { + ActorPtr act = Actor::self(); + simgrid::s4u::this_actor::on_exit( + [act, fun](int /*ignored*/, void* /*data*/) { + try { + fun(); + } catch (py::error_already_set& e) { + xbt_die("Error while executing the on_exit lambda: %s", e.what()); + } + }, + nullptr); + }, + ""); /* Class Engine */ py::class_(m, "Engine", "Simulation Engine, see :ref:`class s4u::Engine `") @@ -180,12 +190,12 @@ PYBIND11_MODULE(simgrid, m) "Create an actor from a function or an object, see :cpp:func:`simgrid::s4u::Actor::create()`") .def_property("host", &Actor::get_host, &Actor::migrate, "The host on which this actor is located") .def_property_readonly("pid", &Actor::get_pid, "The PID (unique identifier) of this actor.") + .def("by_pid", &Actor::by_pid, "Retrieve an actor by its PID") .def("daemonize", &Actor::daemonize, "This actor will be automatically terminated when the last non-daemon actor finishes, see :cpp:func:`void " "simgrid::s4u::Actor::daemonize()`") .def("join", py::overload_cast(&Actor::join), "Wait for the actor to finish, see :cpp:func:`void simgrid::s4u::Actor::join(double)`", py::arg("timeout")) - .def("kill", [](py::int_ pid) { Actor::kill(pid); }, "Kill an actor by pid") .def("kill", [](ActorPtr act) { act->kill(); }, "Kill that actor") .def("kill_all", &Actor::kill_all, "Kill all actors but the caller.") .def("migrate", &Actor::migrate,