CscSequencesProcessor.h

Go to the documentation of this file.

#ifndef CscSequencesProcessor_H_
#define CscSequencesProcessor_H_
 
#include "./CoreObjects/CscSequence.h"
#include "./SequenceProcessor/CscAbstractSequenceProcessingStrategy.h"
#include "./SequenceProcessor/CscIdleSequenceProcessingStrategy.h"
#include "./SequenceProcessor/CscSequencePositionStrategy.h"
#include "Simulator/CscEnvironmentSimulator.h"
 
namespace conscience_core::sequences_processor {
 
using namespace conscience_core::simulator;
using namespace conscience_utils::logging;
 
class CscSequencesProcessor {
public:
    CscSequencesProcessor(const string &worldEntityId, CscEnvironmentSimulator *simulator, const bool entitySimulated);
 
    ~CscSequencesProcessor();
 
    void sequenceTic();
    CscSequence *getSequence();
    bool isSequenceProcessed();
    void addSequenceInQueue(CscSequence *sequence);
    void deleteFirstSequenceFromBuffer();
    void deleteLastSequenceFromBuffer();
    int getSequenceProcessingIndex();
 
    optional<vector<const CscPoint3d *>> getCurrentPositionsOfSequence(unsigned long long **outSequenceId = nullptr);
    void setSequenceProcessingIndex(int index);
    void breakSequence();
    void resumeSequence();
    void terminateSequence();
 
    void clearSequences(size_t keepLastCount = 0);
 
private:
    std::unique_ptr<CscLogger> logger = CscLogger::getForCategory("CssSequenceProcessor");
    void setSequence(CscSequence *sequence);
    void checkAndUpdateSequenceBuffer();
 
    void selectStrategyBySequenceType();
 
    mutex strategyMutex;
 
    const string worldEntityId;
    CscEnvironmentSimulator *simulator = nullptr;
    const bool entitySimulated;
    vector<CscSequence *> sequenceBuffer;
    CscAbstractSequenceProcessingStrategy *currentSequenceProcessingStrategy = nullptr;
 
    CscSequence *currentSequence = nullptr;
 
    int currentSequenceIndex = 0;
    unsigned long long currentSequenceId = 0;
    inline void safeStrategyAction(function<void()> action);
};
}
 
#endif