BestFirstEntry.cpp

Go to the documentation of this file.

#include "BestFirstEntry.h"
#include "execution/engine/src/Engine.h"
#include <cassert>
 
using namespace BPMNOS::Execution;
 
BestFirstEntry::BestFirstEntry(Evaluator* evaluator)
  : GreedyDispatcher(evaluator)
{
}
 
void BestFirstEntry::connect(Mediator* mediator) {
  mediator->addSubscriber(this, 
    Observable::Type::EntryRequest
  );
  GreedyDispatcher::connect(mediator);
}
 
void BestFirstEntry::notice(const Observable* observable) {
  if ( observable->getObservableType() == Observable::Type::EntryRequest ) {
    assert( dynamic_cast<const DecisionRequest*>(observable) );
    auto request = static_cast<const DecisionRequest*>(observable);
    auto decision = std::make_shared<EntryDecision>(request->token, evaluator);
    decisionsWithoutEvaluation.emplace_back( request->token->weak_from_this(), request->weak_from_this(), decision );
  }
  else {
    GreedyDispatcher::notice(observable);
  }
}