X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/35a389f7c71363e88bc1d4537390305fc24a959b..cdac506670725ae4fe40b3b1a31ceeb9488ce53a:/src/s4u/s4u_Actor.cpp diff --git a/src/s4u/s4u_Actor.cpp b/src/s4u/s4u_Actor.cpp index 56d2827b3f..b22b2b0531 100644 --- a/src/s4u/s4u_Actor.cpp +++ b/src/s4u/s4u_Actor.cpp @@ -1,4 +1,4 @@ -/* Copyright (c) 2006-2018. The SimGrid Team. All rights reserved. */ +/* Copyright (c) 2006-2019. 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. */ @@ -31,7 +31,7 @@ simgrid::xbt::signal s4u::Actor::on_destruction; // ***** Actor creation ***** ActorPtr Actor::self() { - smx_context_t self_context = SIMIX_context_self(); + smx_context_t self_context = simgrid::kernel::context::Context::self(); if (self_context == nullptr) return simgrid::s4u::ActorPtr(); @@ -47,9 +47,7 @@ ActorPtr Actor::create(std::string name, s4u::Host* host, std::function ActorPtr Actor::create(std::string name, s4u::Host* host, std::string function, std::vector args) { simgrid::simix::ActorCodeFactory& factory = SIMIX_get_actor_code_factory(function); - simgrid::simix::ActorCode code = factory(std::move(args)); - simgrid::kernel::actor::ActorImpl* actor = simcall_process_create(name, std::move(code), nullptr, host, nullptr); - return actor->iface(); + return create(name, host, factory(std::move(args))); } void intrusive_ptr_add_ref(Actor* actor) @@ -177,7 +175,7 @@ double Actor::get_kill_time() return SIMIX_timer_get_date(pimpl_->kill_timer); } -void Actor::kill(aid_t pid) +void Actor::kill(aid_t pid) // deprecated { smx_actor_t killer = SIMIX_process_self(); smx_actor_t process = SIMIX_process_from_PID(pid); @@ -318,6 +316,7 @@ void parallel_execute(std::vector hosts, std::vector flops_a simcall_execution_wait(s); } +// deprecated void parallel_execute(int host_nb, s4u::Host** host_list, double* flops_amount, double* bytes_amount, double timeout) { smx_activity_t s = @@ -327,9 +326,14 @@ void parallel_execute(int host_nb, s4u::Host** host_list, double* flops_amount, delete[] bytes_amount; } +// deprecated void parallel_execute(int host_nb, sg_host_t* host_list, double* flops_amount, double* bytes_amount) { - parallel_execute(host_nb, host_list, flops_amount, bytes_amount, /* timeout */ -1); + smx_activity_t s = simcall_execution_parallel_start("", host_nb, host_list, flops_amount, bytes_amount, + /* rate */ -1, /*timeout*/ -1); + simcall_execution_wait(s); + delete[] flops_amount; + delete[] bytes_amount; } ExecPtr exec_init(double flops_amount) @@ -388,12 +392,6 @@ void resume() simgrid::s4u::Actor::on_resume(process->iface()); } -bool is_suspended() -{ - smx_actor_t process = SIMIX_process_self(); - return simgrid::simix::simcall([process] { return process->suspended_; }); -} - void exit() { smx_actor_t process = SIMIX_process_self(); @@ -438,10 +436,6 @@ Host* getHost() /* deprecated */ { return get_host(); } -bool isSuspended() /* deprecated */ -{ - return is_suspended(); -} void on_exit(int_f_pvoid_pvoid_t fun, void* data) /* deprecated */ { SIMIX_process_self()->iface()->on_exit([fun](int a, void* b) { fun((void*)(intptr_t)a, b); }, data);