X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/d18e17592e7aabd2cb96fd154858e0a3987d2800..10ceac5fd14fb0426b5c93bda85676a79b02d0be:/include/simgrid/simix/blocking_simcall.hpp diff --git a/include/simgrid/simix/blocking_simcall.hpp b/include/simgrid/simix/blocking_simcall.hpp index 7fa0b25d6d..3a41904109 100644 --- a/include/simgrid/simix/blocking_simcall.hpp +++ b/include/simgrid/simix/blocking_simcall.hpp @@ -24,19 +24,22 @@ XBT_PUBLIC(void) simcall_run_blocking(std::function const& code); namespace simgrid { namespace simix { -XBT_PUBLIC(void) unblock(smx_process_t process); +XBT_PUBLIC(void) unblock(smx_actor_t process); -/** Execute some code in kernel mode and wakes up the process when +/** Execute some code in kernel mode and wakes up the actor when * the result is available. * - * It is given a callback which is executed in the kernel SimGrid and - * returns a simgrid::kernel::Future. The kernel blocks the process - * until the Future is ready and either the value wrapped in the future - * to the process or raises the exception stored in the Future in the process. + * It is given a callback which is executed in the SimGrid kernel and + * returns a `simgrid::kernel::Future`. The kernel blocks the actor + * until the Future is ready and: + * + * - either returns the value wrapped in the future to the actor; + * + * - or raises the exception stored in the future in the actor. * * This can be used to implement blocking calls without adding new simcalls. * One downside of this approach is that we don't have any semantic on what - * the process is waiting. This might be a problem for the model-checker and + * the actor is waiting. This might be a problem for the model-checker and * we'll have to devise a way to make it work. * * @param code Kernel code returning a `simgrid::kernel::Future` @@ -50,7 +53,7 @@ auto kernelSync(F code) -> decltype(code().get()) if (SIMIX_is_maestro()) xbt_die("Can't execute blocking call in kernel mode"); - smx_process_t self = SIMIX_process_self(); + smx_actor_t self = SIMIX_process_self(); simgrid::xbt::Result result; simcall_run_blocking([&result, self, &code]{ @@ -86,7 +89,7 @@ public: { if (!valid()) throw std::future_error(std::future_errc::no_state); - smx_process_t self = SIMIX_process_self(); + smx_actor_t self = SIMIX_process_self(); simgrid::xbt::Result result; simcall_run_blocking([this, &result, self]{ try { @@ -117,7 +120,7 @@ public: return; // The future is not ready. We have to delegate to the SimGrid kernel: std::exception_ptr exception; - smx_process_t self = SIMIX_process_self(); + smx_actor_t self = SIMIX_process_self(); simcall_run_blocking([this, &exception, self]{ try { // When the kernel future is ready... @@ -141,7 +144,7 @@ private: /** Start some asynchronous work * * @param code SimGrid kernel code which returns a simgrid::kernel::Future - * @return User future + * @return Actor future */ template auto kernelAsync(F code) @@ -149,11 +152,11 @@ auto kernelAsync(F code) { typedef decltype(code().get()) T; - // Execute the code in the kernel and get the kernel simcall: + // Execute the code in the kernel and get the kernel future: simgrid::kernel::Future future = simgrid::simix::kernelImmediate(std::move(code)); - // Wrap tyhe kernel simcall in a user simcall: + // Wrap the kernel future in a actor future: return simgrid::simix::Future(std::move(future)); }