X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/aaa065dfc773b29afeac0654f90beaf9ed050b50..3d2bffb7542628af525b2507d2a5035ead215ff2:/src/kernel/context/ContextRaw.cpp diff --git a/src/kernel/context/ContextRaw.cpp b/src/kernel/context/ContextRaw.cpp index c7a0a1c5ff..5e178afd58 100644 --- a/src/kernel/context/ContextRaw.cpp +++ b/src/kernel/context/ContextRaw.cpp @@ -13,11 +13,11 @@ XBT_LOG_EXTERNAL_DEFAULT_CATEGORY(simix_context); // Raw context routines -typedef void (*rawctx_entry_point_t)(void *); +typedef void (*rawctx_entry_point_t)(simgrid::kernel::context::RawContext*); typedef void* raw_stack_t; -extern "C" raw_stack_t raw_makecontext(void* malloced_stack, int stack_size, - rawctx_entry_point_t entry_point, void* arg); +extern "C" raw_stack_t raw_makecontext(void* malloced_stack, int stack_size, rawctx_entry_point_t entry_point, + simgrid::kernel::context::RawContext* arg); extern "C" void raw_swapcontext(raw_stack_t* old, raw_stack_t new_context); // TODO, we should handle FP, MMX and the x87 control-word (for x86 and x86_64) @@ -167,13 +167,15 @@ __asm__ ( /* If you implement raw contexts for other processors, don't forget to update the definition of HAVE_RAW_CONTEXTS in tools/cmake/CompleteInFiles.cmake */ -raw_stack_t raw_makecontext(void* malloced_stack, int stack_size, - rawctx_entry_point_t entry_point, void* arg) { - THROW_UNIMPLEMENTED; +raw_stack_t raw_makecontext(void* malloced_stack, int stack_size, rawctx_entry_point_t entry_point, + simgrid::kernel::context::RawContext* arg) +{ + THROW_UNIMPLEMENTED; } -void raw_swapcontext(raw_stack_t* old, raw_stack_t new_context) { - THROW_UNIMPLEMENTED; +void raw_swapcontext(raw_stack_t* old, raw_stack_t new_context) +{ + THROW_UNIMPLEMENTED; } #endif @@ -186,17 +188,15 @@ namespace context { // RawContextFactory -Context* RawContextFactory::create_context(std::function code, void_pfn_smxprocess_t cleanup_func, - smx_actor_t process) +Context* RawContextFactory::create_context(std::function code, smx_actor_t actor) { - return this->new_context(std::move(code), cleanup_func, process, this); + return this->new_context(std::move(code), actor, this); } // RawContext -RawContext::RawContext(std::function code, void_pfn_smxprocess_t cleanup, smx_actor_t actor, - SwappedContextFactory* factory) - : SwappedContext(std::move(code), cleanup, actor, factory) +RawContext::RawContext(std::function code, smx_actor_t actor, SwappedContextFactory* factory) + : SwappedContext(std::move(code), actor, factory) { if (has_code()) { this->stack_top_ = raw_makecontext(get_stack(), smx_context_usable_stack_size, RawContext::wrapper, this); @@ -206,20 +206,18 @@ RawContext::RawContext(std::function code, void_pfn_smxprocess_t cleanup } } -void RawContext::wrapper(void* arg) +void RawContext::wrapper(RawContext* context) { - RawContext* context = static_cast(arg); ASAN_FINISH_SWITCH(nullptr, &context->asan_ctx_->asan_stack_, &context->asan_ctx_->asan_stack_size_); try { (*context)(); - } catch (StopRequest const&) { - XBT_DEBUG("Caught a StopRequest"); + context->Context::stop(); + } catch (ForcefulKillException const&) { + XBT_DEBUG("Caught a ForcefulKillException"); } catch (simgrid::Exception const& e) { XBT_INFO("Actor killed by an uncatched exception %s", simgrid::xbt::demangle(typeid(e).name()).get()); throw; } - context->Context::stop(); - ASAN_ONLY(context->asan_stop_ = true); context->suspend(); }