X-Git-Url: http://bilbo.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/2ace2e9a66953011268a2b64824638305807612e..080541387d2296c808397215b8c9401a9f97a1d5:/src/simix/popping_private.hpp diff --git a/src/simix/popping_private.hpp b/src/simix/popping_private.hpp index 338a29b617..856ddf5bde 100644 --- a/src/simix/popping_private.hpp +++ b/src/simix/popping_private.hpp @@ -1,4 +1,4 @@ -/* Copyright (c) 2007-2019. The SimGrid Team. All rights reserved. */ +/* Copyright (c) 2007-2022. 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. */ @@ -8,202 +8,32 @@ #include "simgrid/forward.h" #include "src/kernel/activity/ActivityImpl.hpp" - -#include +#include "xbt/utility.hpp" /********************************* Simcalls *********************************/ -#include "popping_enum.h" /* Definition of e_smx_simcall_t, with one value per simcall */ - -XBT_PUBLIC_DATA const char* simcall_names[]; /* Name of each simcall */ - -typedef int (*simix_match_func_t)(void*, void*, simgrid::kernel::activity::CommImpl*); -typedef void (*simix_copy_data_func_t)(simgrid::kernel::activity::CommImpl*, void*, size_t); -typedef void (*simix_clean_func_t)(void*); -typedef void (*FPtr)(void); // Hide the ugliness - -/* Pack all possible scalar types in an union */ -union u_smx_scalar { - bool b; - char c; - short s; - int i; - long l; - long long ll; - unsigned char uc; - unsigned short us; - unsigned int ui; - unsigned long ul; - unsigned long long ull; - double d; - void* dp; - FPtr fp; -}; +namespace simgrid { +namespace simix { /** * @brief Represents a simcall to the kernel. */ -struct s_smx_simcall { - e_smx_simcall_t call_; - smx_actor_t issuer_; - smx_timer_t timeout_cb_; // Callback to timeouts - simgrid::mc::SimcallInspector* inspector_ = nullptr; // makes that simcall observable by the MC - int mc_value_; - u_smx_scalar args_[11]; - u_smx_scalar result_; +class Simcall { +public: + /** All possible simcalls. */ + XBT_DECLARE_ENUM_CLASS(Type, NONE, RUN_ANSWERED, RUN_BLOCKING); + + Type call_ = Type::NONE; + smx_actor_t issuer_ = nullptr; + simgrid::kernel::timer::Timer* timeout_cb_ = nullptr; // Callback to timeouts + simgrid::kernel::actor::SimcallObserver* observer_ = nullptr; // makes that simcall observable by the MC + unsigned int mc_max_consider_ = + 0; // How many times this simcall should be used. If >1, this will be a fork in the state space. + std::function const* code_ = nullptr; + + const char* get_cname() const; }; -#define SIMCALL_SET_MC_VALUE(simcall, value) ((simcall).mc_value_ = (value)) -#define SIMCALL_GET_MC_VALUE(simcall) ((simcall).mc_value_) - -/******************************** General *************************************/ - -XBT_PRIVATE const char* SIMIX_simcall_name(e_smx_simcall_t kind); -XBT_PRIVATE void SIMIX_run_kernel(std::function const* code); -XBT_PRIVATE void SIMIX_run_blocking(std::function const* code); - -/* Defines the marshal/unmarshal functions for each type of parameters. - * - * They will be used in popping_accessors.hpp to define the functions allowing - * to retrieve/set each parameter of each simcall. - * - * There is a unmarshal_raw() function, which is exactly similar to unmarshal() - * for all types but boost::intrusive_ptr(T). For that type, the unmarshal() - * function builds a new intrusive_ptr wrapping the pointer (that is stored raw - * within the simcall) while the unmarshal_raw retrieves the raw pointer. - * - * This is used in _getraw_ functions, that allow the - * model-checker, to read the data in the remote memory of the MCed. - */ - -namespace simgrid { -namespace simix { - -template class type { - constexpr bool operator==(type) const { return true; } - template constexpr bool operator==(type) const { return false; } - constexpr bool operator!=(type) const { return false; } - template constexpr bool operator!=(type) const { return true; } -}; - -template struct marshal_t { -}; -#define SIMIX_MARSHAL(T, field) \ - inline void marshal(type, u_smx_scalar& simcall, T value) { simcall.field = value; } \ - inline T unmarshal(type, u_smx_scalar const& simcall) { return simcall.field; } \ - inline T unmarshal_raw(type, u_smx_scalar const& simcall) \ - { /* Exactly same as unmarshal. It differs only for intrusive_ptr */ return simcall.field; } - -SIMIX_MARSHAL(bool, b); -SIMIX_MARSHAL(char, c); -SIMIX_MARSHAL(short, s); -SIMIX_MARSHAL(int, i); -SIMIX_MARSHAL(long, l); -SIMIX_MARSHAL(unsigned char, uc); -SIMIX_MARSHAL(unsigned short, us); -SIMIX_MARSHAL(unsigned int, ui); -SIMIX_MARSHAL(unsigned long, ul); -SIMIX_MARSHAL(unsigned long long, ull); -SIMIX_MARSHAL(long long, ll); -SIMIX_MARSHAL(float, d); -SIMIX_MARSHAL(double, d); -SIMIX_MARSHAL(FPtr, fp); - -inline void unmarshal(type, u_smx_scalar const& simcall) -{ - /* Nothing to do for void data */ -} -inline void unmarshal_raw(type, u_smx_scalar const& simcall) -{ - /* Nothing to do for void data */ -} - -template inline void marshal(type, u_smx_scalar& simcall, T* value) -{ - simcall.dp = (void*)value; -} -template inline T* unmarshal(type, u_smx_scalar const& simcall) -{ - return static_cast(simcall.dp); -} -template inline T* unmarshal_raw(type, u_smx_scalar const& simcall) -{ - return static_cast(simcall.dp); -} - -template -inline void marshal(type>, u_smx_scalar& simcall, boost::intrusive_ptr value) -{ - if (value.get() == nullptr) { // Sometimes we return nullptr in an intrusive_ptr... - simcall.dp = nullptr; - } else { - intrusive_ptr_add_ref(value.get()); - simcall.dp = static_cast(value.get()); - } -} -template inline boost::intrusive_ptr unmarshal(type>, u_smx_scalar const& simcall) -{ - // refcount was already increased during the marshaling, thus the "false" as last argument - boost::intrusive_ptr res = boost::intrusive_ptr(static_cast(simcall.dp), false); - return res; -} -template inline T* unmarshal_raw(type>, u_smx_scalar const& simcall) -{ - return static_cast(simcall.dp); -} - -template inline void marshal(type, u_smx_scalar& simcall, R (*value)(T...)) -{ - simcall.fp = (FPtr)value; -} -template inline auto unmarshal(type, u_smx_scalar simcall) -> R (*)(T...) -{ - return (R(*)(T...))simcall.fp; -} -template inline auto unmarshal_raw(type, u_smx_scalar simcall) -> R (*)(T...) -{ - return (R(*)(T...))simcall.fp; -} - -template inline void marshal(u_smx_scalar& simcall, T const& value) -{ - return marshal(type(), simcall, value); -} -template inline typename std::remove_reference::type unmarshal(u_smx_scalar& simcall) -{ - return unmarshal(type(), simcall); -} -template inline typename std::remove_reference::type unmarshal_raw(u_smx_scalar& simcall) -{ - return unmarshal(type(), simcall); -} - -template inline void marshal_args(smx_simcall_t simcall) -{ - /* Nothing to do when no args */ -} - -template inline void marshal_args(smx_simcall_t simcall, A const& a) -{ - marshal(simcall->args_[I], a); -} - -template inline void marshal_args(smx_simcall_t simcall, A const& a, B const&... b) -{ - marshal(simcall->args_[I], a); - marshal_args(simcall, b...); -} - -/** Initialize the simcall */ -template inline void marshal(smx_simcall_t simcall, e_smx_simcall_t call, A const&... a) -{ - simcall->call_ = call; - memset(&simcall->result_, 0, sizeof(simcall->result_)); - memset(simcall->args_, 0, sizeof(simcall->args_)); - marshal_args<0>(simcall, a...); -} -} -} - -#include "popping_accessors.hpp" +} // namespace simix +} // namespace simgrid #endif