src/mc/explo/udpor/UnfoldingEvent.cpp

   1 /* Copyright (c) 2008-2023. 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 #include "src/mc/explo/udpor/UnfoldingEvent.hpp"
   7 #include "src/mc/explo/udpor/History.hpp"
   8
   9 namespace simgrid::mc::udpor {
  10
  11 UnfoldingEvent::UnfoldingEvent(std::initializer_list<const UnfoldingEvent*> init_list)
  12     : UnfoldingEvent(EventSet(std::move(init_list)))
  13 {
  14 }
  15
  16 UnfoldingEvent::UnfoldingEvent(EventSet immediate_causes, std::shared_ptr<Transition> transition)
  17     : associated_transition(std::move(transition)), immediate_causes(std::move(immediate_causes))
  18 {
  19 }
  20
  21 bool UnfoldingEvent::operator==(const UnfoldingEvent& other) const
  22 {
  23   // Must be run by the same actor
  24   if (associated_transition->aid_ != other.associated_transition->aid_)
  25     return false;
  26
  27   // If run by the same actor, must be the same _step_ of that actor's
  28   // execution
  29
  30   // TODO: Add in information to determine which step in the sequence this actor was executed
  31
  32   // All unfolding event objects are created in reference to
  33   // an Unfolding object which owns them. Hence, the references
  34   // they contain to other events in the unfolding can
  35   // be used as intrinsic identities (i.e. we don't need to
  36   // recursively check if each of our causes has a `==` in
  37   // the other event's causes)
  38   return this->immediate_causes == other.immediate_causes;
  39 }
  40
  41 EventSet UnfoldingEvent::get_history() const
  42 {
  43   return History(this).get_all_events();
  44 }
  45
  46 bool UnfoldingEvent::related_to(const UnfoldingEvent* other) const
  47 {
  48   return this->in_history_of(other) or other->in_history_of(this);
  49 }
  50
  51 bool UnfoldingEvent::in_history_of(const UnfoldingEvent* other) const
  52 {
  53   return History(other).contains(this);
  54 }
  55
  56 bool UnfoldingEvent::conflicts_with(const UnfoldingEvent* other) const
  57 {
  58   // Events that have a causal relation never are in conflict
  59   // in an unfolding structure. Two events in conflict must
  60   // not be contained in each other's histories
  61   if (related_to(other)) {
  62     return false;
  63   }
  64
  65   const EventSet my_history      = get_history();
  66   const EventSet other_history   = other->get_history();
  67   const EventSet unique_to_me    = my_history.subtracting(other_history);
  68   const EventSet unique_to_other = other_history.subtracting(my_history);
  69
  70   const bool conflicts_with_me = std::any_of(unique_to_me.begin(), unique_to_me.end(), [&](const UnfoldingEvent* e) {
  71     return e->has_dependent_transition_with(other);
  72   });
  73   const bool conflicts_with_other =
  74       std::any_of(unique_to_other.begin(), unique_to_other.end(),
  75                   [&](const UnfoldingEvent* e) { return e->has_dependent_transition_with(this); });
  76   return conflicts_with_me or conflicts_with_other;
  77 }
  78
  79 bool UnfoldingEvent::conflicts_with(const Configuration& config) const
  80 {
  81   // A configuration is itself already conflict-free. Thus, it is
  82   // simply a matter of testing whether or not the transition associated
  83   // with the event is dependent with any already in `config` that are
  84   // OUTSIDE this event's history (in an unfolding, events only conflict
  85   // if they are not related)
  86   const EventSet potential_conflicts = config.get_events().subtracting(get_history());
  87   return std::any_of(potential_conflicts.cbegin(), potential_conflicts.cend(),
  88                      [&](const UnfoldingEvent* e) { return this->has_dependent_transition_with(e); });
  89 }
  90
  91 bool UnfoldingEvent::immediately_conflicts_with(const UnfoldingEvent* other) const
  92 {
  93   // They have to be in conflict at a minimum
  94   if (not conflicts_with(other)) {
  95     return false;
  96   }
  97
  98   auto combined_events = History(EventSet{this, other}).get_all_events();
  99
 100   // See the definition of immediate conflicts in the original paper on UDPOR
 101   {
 102     combined_events.remove(this);
 103     if (not combined_events.is_valid_configuration()) {
 104       return false;
 105     }
 106     combined_events.insert(this);
 107   }
 108
 109   {
 110     combined_events.remove(other);
 111     if (not combined_events.is_valid_configuration()) {
 112       return false;
 113     }
 114     combined_events.insert(other);
 115   }
 116
 117   return true;
 118 }
 119
 120 bool UnfoldingEvent::is_dependent_with(const Transition* t) const
 121 {
 122   return associated_transition->depends(t);
 123 }
 124
 125 bool UnfoldingEvent::has_dependent_transition_with(const UnfoldingEvent* other) const
 126 {
 127   return is_dependent_with(other->associated_transition.get());
 128 }
 129
 130 } // namespace simgrid::mc::udpor