Logo AND Algorithmique Numérique Distribuée

Public GIT Repository
simix simplification: no need to marshal generic parameters when all what you have...
authorMartin Quinson <martin.quinson@ens-rennes.fr>
Sun, 27 Feb 2022 17:33:06 +0000 (18:33 +0100)
committerMartin Quinson <martin.quinson@ens-rennes.fr>
Sun, 27 Feb 2022 17:41:01 +0000 (18:41 +0100)
src/simix/libsmx.cpp
src/simix/popping_generated.cpp
src/simix/popping_private.hpp
src/simix/simcalls.py

index e0629a1..16a3681 100644 (file)
@@ -229,7 +229,8 @@ bool simcall_comm_test(simgrid::kernel::activity::ActivityImpl* comm) // XBT_ATT
 static void simcall(simgrid::simix::Simcall call, std::function<void()> const& code)
 {
   auto self = simgrid::kernel::actor::ActorImpl::self();
-  simgrid::simix::marshal(&self->simcall_, call, &code);
+  self->simcall_.call_ = call;
+  self->simcall_.code_ = &code;
   if (not simgrid::kernel::EngineImpl::get_instance()->is_maestro(self)) {
     XBT_DEBUG("Yield process '%s' on simcall %s", self->get_cname(), SIMIX_simcall_name(self->simcall_));
     self->yield();
index f518d0a..dd6ce75 100644 (file)
@@ -48,12 +48,12 @@ void simgrid::kernel::actor::ActorImpl::simcall_handle(int times_considered)
     return;
   switch (simcall_.call_) {
     case Simcall::RUN_KERNEL:
-      SIMIX_run_kernel(simgrid::simix::unmarshal<std::function<void()> const*>(simcall_.args_[0]));
+      SIMIX_run_kernel(simcall_.code_);
       simcall_answer();
       break;
 
     case Simcall::RUN_BLOCKING:
-      SIMIX_run_blocking(simgrid::simix::unmarshal<std::function<void()> const*>(simcall_.args_[0]));
+      SIMIX_run_blocking(simcall_.code_);
       break;
 
     case Simcall::NONE:
index 19c4084..4e918a5 100644 (file)
@@ -20,25 +20,6 @@ XBT_PUBLIC_DATA const std::array<const char*, simgrid::simix::NUM_SIMCALLS> simc
 using simix_match_func_t     = bool (*)(void*, void*, simgrid::kernel::activity::CommImpl*);
 using simix_copy_data_func_t = void (*)(simgrid::kernel::activity::CommImpl*, void*, size_t);
 using simix_clean_func_t     = void (*)(void*);
-using 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;
-};
 
 /**
  * @brief Represents a simcall to the kernel.
@@ -50,8 +31,7 @@ struct s_smx_simcall {
   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::array<u_smx_scalar, 11> args_      = {};
-  u_smx_scalar result_                    = {};
+  std::function<void()> const* code_      = nullptr;
 };
 
 /******************************** General *************************************/
@@ -60,144 +40,4 @@ XBT_PRIVATE const char* SIMIX_simcall_name(const s_smx_simcall& simcall);
 XBT_PRIVATE void SIMIX_run_kernel(std::function<void()> const* code);
 XBT_PRIVATE void SIMIX_run_blocking(std::function<void()> const* code);
 
-/* Defines the marshal/unmarshal functions for each type of parameters.
- *
- * 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 <simcall>_getraw_<param> functions, that allow the
- * model-checker, to read the data in the remote memory of the MCed.
- */
-
-namespace simgrid {
-namespace simix {
-
-template <class T> class type {
-  constexpr bool operator==(type) const { return true; }
-  template <class U> constexpr bool operator==(type<U>) const { return false; }
-  constexpr bool operator!=(type) const { return false; }
-  template <class U> constexpr bool operator!=(type<U>) const { return true; }
-};
-
-template <typename T> struct marshal_t {
-};
-#define SIMIX_MARSHAL(T, field)                                                                                        \
-  inline void marshal(type<T>, u_smx_scalar& simcall, T value) { simcall.field = value; }                              \
-  inline T unmarshal(type<T>, u_smx_scalar const& simcall) { return simcall.field; }                                   \
-  inline T unmarshal_raw(type<T>, 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<void>, u_smx_scalar const& /*simcall*/)
-{
-  /* Nothing to do for void data */
-}
-inline void unmarshal_raw(type<void>, u_smx_scalar const& /*simcall*/)
-{
-  /* Nothing to do for void data */
-}
-
-template <class T> inline void marshal(type<T*>, u_smx_scalar& simcall, T* value)
-{
-  simcall.dp = (void*)value;
-}
-template <class T> inline T* unmarshal(type<T*>, u_smx_scalar const& simcall)
-{
-  return static_cast<T*>(simcall.dp);
-}
-template <class T> inline T* unmarshal_raw(type<T*>, u_smx_scalar const& simcall)
-{
-  return static_cast<T*>(simcall.dp);
-}
-
-template <class T>
-inline void marshal(type<boost::intrusive_ptr<T>>, u_smx_scalar& simcall, boost::intrusive_ptr<T> 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<void*>(value.get());
-  }
-}
-template <class T> inline boost::intrusive_ptr<T> unmarshal(type<boost::intrusive_ptr<T>>, u_smx_scalar const& simcall)
-{
-  // refcount was already increased during the marshaling, thus the "false" as last argument
-  boost::intrusive_ptr<T> res = boost::intrusive_ptr<T>(static_cast<T*>(simcall.dp), false);
-  return res;
-}
-template <class T> inline T* unmarshal_raw(type<boost::intrusive_ptr<T>>, u_smx_scalar const& simcall)
-{
-  return static_cast<T*>(simcall.dp);
-}
-
-template <class R, class... T> inline void marshal(type<R (*)(T...)>, u_smx_scalar& simcall, R (*value)(T...))
-{
-  simcall.fp = (FPtr)value;
-}
-template <class R, class... T> inline auto unmarshal(type<R (*)(T...)>, u_smx_scalar simcall) -> R (*)(T...)
-{
-  return (R(*)(T...))simcall.fp;
-}
-template <class R, class... T> inline auto unmarshal_raw(type<R (*)(T...)>, u_smx_scalar simcall) -> R (*)(T...)
-{
-  return (R(*)(T...))simcall.fp;
-}
-
-template <class T> inline void marshal(u_smx_scalar& simcall, T const& value)
-{
-  return marshal(type<T>(), simcall, value);
-}
-template <class T> inline typename std::remove_reference_t<T> unmarshal(u_smx_scalar& simcall)
-{
-  return unmarshal(type<T>(), simcall);
-}
-template <class T> inline typename std::remove_reference_t<T> unmarshal_raw(u_smx_scalar& simcall)
-{
-  return unmarshal(type<T>(), simcall);
-}
-
-template <std::size_t I> inline void marshal_args(const s_smx_simcall* /*simcall*/)
-{
-  /* Nothing to do when no args */
-}
-
-template <std::size_t I, class A> inline void marshal_args(smx_simcall_t simcall, A const& a)
-{
-  marshal(simcall->args_[I], a);
-}
-
-template <std::size_t I, class A, class... B> inline void marshal_args(smx_simcall_t simcall, A const& a, B const&... b)
-{
-  marshal(simcall->args_[I], a);
-  marshal_args<I + 1>(simcall, b...);
-}
-
-/** Initialize the simcall */
-template <class... A> inline void marshal(smx_simcall_t simcall, Simcall call, A const&... a)
-{
-  simcall->call_ = call;
-  memset(&simcall->result_, 0, sizeof simcall->result_);
-  memset(simcall->args_.data(), 0, simcall->args_.size() * sizeof simcall->args_[0]);
-  marshal_args<0>(simcall, a...);
-}
-}
-}
-
 #endif
index 0671a0c..9c2a0b5 100755 (executable)
@@ -114,8 +114,7 @@ class Simcall:
     def case(self):
         res = []
         indent = '    '
-        args = ["simgrid::simix::unmarshal<%s>(simcall_.args_[%d])" % (arg.rettype(), i)
-                for i, arg in enumerate(self.args)]
+        args = ["simcall_.code_"]
         res.append(indent + 'case Simcall::%s:' % (self.name.upper()))
         if self.need_handler:
             call = "simcall_HANDLER_%s(&simcall_%s%s)" % (self.name,
@@ -123,10 +122,7 @@ class Simcall:
                                                           ', '.join(args))
         else:
             call = "SIMIX_%s(%s)" % (self.name, ', '.join(args))
-        if self.call_kind == 'Func':
-            res.append(indent + "  simgrid::simix::marshal<%s>(simcall_.result_, %s);" % (self.res.rettype(), call))
-        else:
-            res.append(indent + "  " + call + ";")
+        res.append(indent + "  " + call + ";")
         if self.call_kind != 'Blck':
             res.append(indent + '  simcall_answer();')
         res.append(indent + '  break;')
@@ -135,8 +131,7 @@ class Simcall:
 
     def handler_prototype(self):
         if self.need_handler:
-            return "XBT_PRIVATE %s simcall_HANDLER_%s(smx_simcall_t simcall%s);" % (self.res.rettype() if self.call_kind == 'Func' else 'void',
-                                                                                    self.name,
+            return "XBT_PRIVATE void simcall_HANDLER_%s(smx_simcall_t simcall%s);" % (self.name,
                                                                                     ''.join(', %s %s' % (arg.rettype(), arg.name)
                                                                                             for i, arg in enumerate(self.args)))
         return ""
@@ -166,10 +161,9 @@ def parse(fn):
                 t = t.strip()
                 n = n.strip()
                 sargs.append(Arg(n, t))
-        if ret == "void":
-            ans = "Proc"
-        else:
-            ans = "Func"
+        if ret != "void":
+            raise Exception ("Func simcalls (ie, returning a value) not supported anymore")
+        ans = 'Proc'
         handler = True
         if attrs:
             attrs = attrs[2:-2]