#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(std::initializer_list<const UnfoldingEvent*> 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
{
- // Must be run by the same actor
- if (associated_transition->aid_ != other.associated_transition->aid_)
- return false;
-
- // If run by the same actor, must be the same _step_ of that actor's
- // execution
-
- // TODO: Add in information to determine which step in the sequence this actor was executed
-
- // All unfolding event objects are created in reference to
- // an Unfolding object which owns them. Hence, the references
+ // 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 this->immediate_causes == other.immediate_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
+{
+ 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(),
+ static_cast<long unsigned>(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) or other->in_history_of(this);
+ return this->in_history_of(other) || other->in_history_of(this);
}
bool UnfoldingEvent::in_history_of(const UnfoldingEvent* other) const
return false;
}
- const EventSet my_history = get_history();
- const EventSet other_history = other->get_history();
+ 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->has_dependent_transition_with(other);
- });
- const bool conflicts_with_other =
- std::any_of(unique_to_other.begin(), unique_to_other.end(),
- [&](const UnfoldingEvent* e) { return e->has_dependent_transition_with(this); });
- return conflicts_with_me or conflicts_with_other;
+ 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(const Configuration& config) const
+bool UnfoldingEvent::conflicts_with_any(const EventSet& events) const
{
- // A configuration is itself already conflict-free. Thus, it is
- // simply a matter of testing whether or not the transition associated
- // with the event is dependent with any already in `config` that are
- // OUTSIDE this event's history (in an unfolding, events only conflict
- // if they are not related)
- const EventSet potential_conflicts = config.get_events().subtracting(get_history());
- return std::any_of(potential_conflicts.cbegin(), potential_conflicts.cend(),
- [&](const UnfoldingEvent* e) { return this->has_dependent_transition_with(e); });
+ 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
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(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);
- }
+ combined_events.remove(other);
+ if (not combined_events.is_valid_configuration())
+ return false;
+ combined_events.insert(other);
return true;
}
return associated_transition->depends(t);
}
-bool UnfoldingEvent::has_dependent_transition_with(const UnfoldingEvent* other) const
+bool UnfoldingEvent::is_dependent_with(const UnfoldingEvent* other) const
{
return is_dependent_with(other->associated_transition.get());
}
