X-Git-Url: http://bilbo.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/573b5f83d54c3137fbedd6597bbef9ed3d4645fc..e80fc92c523fadeda71f4f7c2f0ca6a5a7dea7a7:/src/mc/explo/udpor/UnfoldingEvent.cpp

diff --git a/src/mc/explo/udpor/UnfoldingEvent.cpp b/src/mc/explo/udpor/UnfoldingEvent.cpp
index fd4d27309f..8651a2ac42 100644
--- a/src/mc/explo/udpor/UnfoldingEvent.cpp
+++ b/src/mc/explo/udpor/UnfoldingEvent.cpp
@@ -4,25 +4,144 @@
  * under the terms of the license (GNU LGPL) which comes with this package. */
 
 #include "src/mc/explo/udpor/UnfoldingEvent.hpp"
+#include "src/mc/explo/udpor/History.hpp"
+
+#include <xbt/asserts.h>
+#include <xbt/log.h>
+#include <xbt/string.hpp>
 
 namespace simgrid::mc::udpor {
 
-UnfoldingEvent::UnfoldingEvent(unsigned int nb_events, std::string const& trans_tag, EventSet const& immediate_causes)
-    : UnfoldingEvent(nb_events, trans_tag, immediate_causes, 0)
+UnfoldingEvent::UnfoldingEvent(std::initializer_list<const UnfoldingEvent*> init_list)
+    : UnfoldingEvent(EventSet(std::move(init_list)))
+{
+}
+
+UnfoldingEvent::UnfoldingEvent(EventSet immediate_causes, std::shared_ptr<Transition> transition)
+    : associated_transition(std::move(transition)), immediate_causes(std::move(immediate_causes))
+{
+  static uint64_t event_id = 0;
+  this->id                 = ++event_id;
+}
+
+bool UnfoldingEvent::operator==(const UnfoldingEvent& other) const
+{
+  // Intrinsic identity check
+  if (this == &other) {
+    return true;
+  }
+  // Two events are equivalent iff:
+  // 1. they have the same action
+  // 2. they have the same history
+  //
+  // NOTE: All unfolding event objects are created in reference to
+  // an `Unfolding` object which owns them. Hence, the references
+  // they contain to other events in the unfolding can
+  // be used as intrinsic identities (i.e. we don't need to
+  // recursively check if each of our causes has a `==` in
+  // the other event's causes)
+  return associated_transition->aid_ == other.associated_transition->aid_ &&
+         associated_transition->type_ == other.associated_transition->type_ &&
+         associated_transition->times_considered_ == other.associated_transition->times_considered_ &&
+         this->immediate_causes == other.immediate_causes;
+}
+
+std::string UnfoldingEvent::to_string() const
 {
-  // TODO: Implement this correctly
+  std::string dependencies_string;
+
+  dependencies_string += "[";
+  for (const auto* e : immediate_causes) {
+    dependencies_string += " ";
+    dependencies_string += e->to_string();
+    dependencies_string += " and ";
+  }
+  dependencies_string += "]";
+
+  return xbt::string_printf("Event %lu, Actor %ld: %s (%lu dependencies: %s)", this->id, associated_transition->aid_,
+                            associated_transition->to_string().c_str(), immediate_causes.size(),
+                            dependencies_string.c_str());
+}
+
+EventSet UnfoldingEvent::get_history() const
+{
+  EventSet local_config = get_local_config();
+  local_config.remove(this);
+  return local_config;
+}
+
+EventSet UnfoldingEvent::get_local_config() const
+{
+  return History(this).get_all_events();
+}
+
+bool UnfoldingEvent::related_to(const UnfoldingEvent* other) const
+{
+  return this->in_history_of(other) || other->in_history_of(this);
+}
+
+bool UnfoldingEvent::in_history_of(const UnfoldingEvent* other) const
+{
+  return History(other).contains(this);
+}
+
+bool UnfoldingEvent::conflicts_with(const UnfoldingEvent* other) const
+{
+  // Events that have a causal relation never are in conflict
+  // in an unfolding structure. Two events in conflict must
+  // not be contained in each other's histories
+  if (related_to(other)) {
+    return false;
+  }
+
+  const EventSet my_history      = get_local_config();
+  const EventSet other_history   = other->get_local_config();
+  const EventSet unique_to_me    = my_history.subtracting(other_history);
+  const EventSet unique_to_other = other_history.subtracting(my_history);
+
+  const bool conflicts_with_me    = std::any_of(unique_to_me.begin(), unique_to_me.end(),
+                                                [&](const UnfoldingEvent* e) { return e->is_dependent_with(other); });
+  const bool conflicts_with_other = std::any_of(unique_to_other.begin(), unique_to_other.end(),
+                                                [&](const UnfoldingEvent* e) { return e->is_dependent_with(this); });
+  return conflicts_with_me || conflicts_with_other;
+}
+
+bool UnfoldingEvent::conflicts_with_any(const EventSet& events) const
+{
+  return std::any_of(events.begin(), events.end(), [&](const auto e) { return e->conflicts_with(this); });
+}
+
+bool UnfoldingEvent::immediately_conflicts_with(const UnfoldingEvent* other) const
+{
+  // They have to be in conflict at a minimum
+  if (not conflicts_with(other)) {
+    return false;
+  }
+
+  auto combined_events = History(EventSet{this, other}).get_all_events();
+
+  // See the definition of immediate conflicts in the original paper on UDPOR
+  combined_events.remove(this);
+  if (not combined_events.is_valid_configuration())
+    return false;
+  combined_events.insert(this);
+
+  combined_events.remove(other);
+  if (not combined_events.is_valid_configuration())
+    return false;
+  combined_events.insert(other);
+
+  return true;
 }
 
-UnfoldingEvent::UnfoldingEvent(unsigned int nb_events, std::string const& trans_tag, EventSet const& immediate_causes,
-                               StateHandle sid)
+bool UnfoldingEvent::is_dependent_with(const Transition* t) const
 {
-  // TODO: Implement this
+  return associated_transition->depends(t);
 }
 
-bool UnfoldingEvent::operator==(const UnfoldingEvent&) const
+bool UnfoldingEvent::is_dependent_with(const UnfoldingEvent* other) const
 {
-  // TODO: Implement semantic equality
-  return false;
+  return is_dependent_with(other->associated_transition.get());
 }
 
 } // namespace simgrid::mc::udpor