EventLoop.h

Go to the documentation of this file.

/*
 * EventLoop.h
 *
 *  Created on: 29 May 2017
 *      Author: Nicola Mori
 */

#ifndef EVENTLOOP_H_
#define EVENTLOOP_H_

#include "algorithm/AlgoSequence.h"
#include "algorithm/Algorithm.h"
#include "analysis/EventLoopProxy.h"
#include "data/DataProviderManager.h"
#include "data/DataStoreManager.h"
#include "data/EventDataCacheManager.h"
#include "persistence/PersistenceServiceManager.h"

namespace EA {

class EventLoopProxy;

class EventLoop : public Configurable {
public:
  EventLoop(unsigned int firstEvent = 0, unsigned int nEvents = 0);

  bool SetDataProviderManager(observer_ptr<DataProviderManager> dpManager);

  bool SetDataStoreManager(observer_ptr<DataStoreManager> dsManager);

  bool SetEventDataCacheManager(observer_ptr<EventDataCacheManager> ecManager);

  bool SetPersistenceServiceManager(observer_ptr<PersistenceServiceManager> psManager);

  bool AddAlgorithm(std::unique_ptr<Algorithm> algo);

  bool SetAlgorithms(std::unique_ptr<AlgoSequence> &&algorithms);

  AlgoSequence &GetAlgorithms() { return *_algorithms; }

  bool CacheEventObject(const std::string &objName, const std::string &storeName);

  bool CleanEventCache(const std::string &objName, const std::string &storeName);

  bool Initialize(unsigned int passNumber, unsigned int iterNumber);

  bool Run();

  unsigned int GetFirstEvent();

  unsigned int GetNEvents();

  unsigned int GetNProcessed();

  bool Finalize();

  enum class IterateRequest { YES, NO, ERROR };

  IterateRequest Iterate();

private:
  friend class EventLoopProxy;
  EventLoopProxy _loopProxy;

  observer_ptr<DataProviderManager> _dpManager;
  observer_ptr<DataStoreManager> _dsManager;
  observer_ptr<EventDataCacheManager> _ecManager;
  observer_ptr<PersistenceServiceManager> _psManager;
  std::unique_ptr<AlgoSequence> _algorithms;
  using CachedObjs = std::list<std::pair<std::string, std::string>>;
  CachedObjs _cachedObjs;
  CachedObjs _cachesToBeCleaned;

  unsigned int _passNumber;
  unsigned int _currIter;
  unsigned int _currentEvent;
  unsigned int _firstEvent;
  unsigned int _nEvents;
  unsigned int _nProcessed;
  int _printModulo;
  bool _checkDataAvailability;
  std::vector<std::string> _disabledProviders;
};

} // namespace EA

#endif /* EVENTLOOP_H_ */