LProcessor.h

/*
 * Copyright (c) 2015 Pavel Vainerman.
 *
 * This program is free software: you can redistribute it and/or modify
 * it under the terms of the GNU Lesser General Public License as
 * published by the Free Software Foundation, version 2.1.
 *
 * This program is distributed in the hope that it will be useful, but
 * WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
 * Lesser General Lesser Public License for more details.
 *
 * You should have received a copy of the GNU Lesser General Public License
 * along with this program. If not, see <http://www.gnu.org/licenses/>.
 */
// --------------------------------------------------------------------------
#ifndef LProcessor_H_
#define LProcessor_H_
// --------------------------------------------------------------------------
// --------------------------------------------------------------------------
#include <list>
#include <atomic>
#include "UniSetTypes.h"
#include "UInterface.h"
#include "Element.h"
#include "Schema.h"
// --------------------------------------------------------------------------
namespace uniset
{
// --------------------------------------------------------------------------
class LProcessor
{
    public:
        explicit LProcessor( const std::string& name = "" );
        virtual ~LProcessor();

        void open( const std::string& lfile );

        inline bool isOpen() const
        {
            return !fSchema.empty();
        }

        virtual void execute( const std::string& lfile = "" );

        virtual void terminate()
        {
            canceled = true;
        }

        inline std::shared_ptr<SchemaXML> getSchema()
        {
            return sch;
        }

        inline int getSleepTime() const
        {
            return sleepTime;
        }

    protected:

        virtual void build( const string& lfile );

        virtual void step();

        virtual void getInputs();
        virtual void processing();
        virtual void setOuts();

        struct EXTInfo
        {
            uniset::ObjectId sid;
            UniversalIO::IOType iotype;
            bool state;
            std::shared_ptr<Element> el;
            int numInput = { -1};
        };

        struct EXTOutInfo
        {
            uniset::ObjectId sid;
            UniversalIO::IOType iotype;
            std::shared_ptr<Element> el;
        };

        typedef std::list<EXTInfo> EXTList;
        typedef std::list<EXTOutInfo> OUTList;

        EXTList extInputs;
        OUTList extOuts;

        std::shared_ptr<SchemaXML> sch;

        UInterface ui;
        timeout_t sleepTime = { 200 };
        timeout_t smReadyTimeout = { 30000 } ;     
        std::string logname = { "" };

        std::atomic_bool canceled = {false};

        std::string fSchema = {""};

    private:
};
// --------------------------------------------------------------------------
} // end of namespace uniset
// ---------------------------------------------------------------------------
#endif