NeuronFileState.h

#pragma once

#include "NPLMessageQueue.h"
#include "NPLCommon.h"

namespace NPL
{
    using namespace std;
    class CNPLRuntimeState;

    class CNeuronFileState
    {
    public:
        CNeuronFileState(const std::string& filename);

        bool IsProcessing() const;
        void SetProcessing(bool val);

        bool PushMessage(NPLMessage_ptr& msg);

        bool PopMessage(NPLMessage_ptr& msg);

        bool GetMessage(NPLMessage_ptr& msg);

        bool IsEmpty();

        void ClearMessage();

        /* check if there is clear state and unset it. 
        * return true if there is a clear state */
        bool PopClearState();

        void Tick(int nFrameMoveId);

        int GetTick(int nFrameMoveId);

        int32 GetMaxQueueSize() const;
        void SetMaxQueueSize(int32 val);

        const std::string& GetFilename() const { return m_filename; }
        
        bool IsPreemptive();
        int32 GetPreemptiveInstructionCount() const;
        void SetPreemptiveInstructionCount(int32 val);

    protected:
        /* clear all messages and shrink message queue (releasing memory).*/
        void ClearMessageImp();
        friend class CNPLRuntimeState;
    protected:
        int32 m_nActivationThisTick;
        int32 m_nFrameMoveId;
        int32 m_nTotalActivations;
        int32 m_nPreemptiveInstructionCount;
        DWORD m_nActionState;
        bool m_isProcessing;
        int32 m_nMaxQueueSize;
        std::deque<NPLMessage_ptr> m_queue;
        std::string m_filename;
    };
}