Logo AND Algorithmique Numérique Distribuée

Public GIT Repository
Another step toward working CommPtr. chord example is broken ATM
[simgrid.git] / src / kernel / activity / ActivityImpl.hpp
1 /* Copyright (c) 2007-2016. The SimGrid Team. All rights reserved.          */
2
3 /* This program is free software; you can redistribute it and/or modify it
4  * under the terms of the license (GNU LGPL) which comes with this package. */
5
6 #ifndef SIMGRID_KERNEL_ACTIVITY_ACTIVITYIMPL_HPP
7 #define SIMGRID_KERNEL_ACTIVITY_ACTIVITYIMPL_HPP
8
9 #include <string>
10 #include <list>
11
12 #include <xbt/base.h>
13 #include "simgrid/forward.h"
14
15 #include <atomic>
16 #include <simgrid/simix.hpp>
17
18 namespace simgrid {
19 namespace kernel {
20 namespace activity {
21
22   XBT_PUBLIC_CLASS ActivityImpl {
23   public:
24     ActivityImpl();
25     virtual ~ActivityImpl();
26     e_smx_state_t state = SIMIX_WAITING; /* State of the activity */
27     std::string name;                    /* Activity name if any */
28     std::list<smx_simcall_t> simcalls;   /* List of simcalls waiting for this activity */
29
30     virtual void suspend()=0;
31     virtual void resume()=0;
32     virtual void post() =0; // What to do when a simcall terminates
33
34     // boost::intrusive_ptr<Activity> support:
35     friend void intrusive_ptr_add_ref(ActivityImpl * activity)
36     {
37       // Atomic operation! Do not split in two instructions!
38       auto previous = (activity->refcount_)++;
39       xbt_assert(previous != 0);
40       (void)previous;
41     }
42
43     friend void intrusive_ptr_release(ActivityImpl * activity)
44     {
45       // Atomic operation! Do not split in two instructions!
46       auto count = --(activity->refcount_);
47       if (count == 0)
48         delete activity;
49     }
50
51     /** @brief Increase the refcount */
52     void ref();
53     /** @brief Reduce the refcount; returns true if the object was destroyed */
54     bool unref();
55
56   private:
57     std::atomic_int_fast32_t refcount_{1};
58     int refcount = 1;
59   };
60 }}} // namespace simgrid::kernel::activity
61
62 #endif /* SIMGRID_KERNEL_ACTIVITY_ACTIVITYIMPL_HPP */