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 <vector>
#include <atomic>
#include "UniSetTypes.h"
#include "UInterface.h"
#include "Element.h"
#include "Schema.h"
#include "USingleProcess.h"
// --------------------------------------------------------------------------
namespace uniset
{
    // --------------------------------------------------------------------------
    class LProcessor:
        private USingleProcess
    {
        public:
            explicit LProcessor( const std::string& name, xmlNode* cnode );
            virtual ~LProcessor();
 
            void open( const std::string& lfile );
 
            bool isOpen() const;
 
            timeout_t getSleepTime() const noexcept;
 
            std::shared_ptr<SchemaXML> getSchema();
 
            virtual void execute( const std::string& lfile = "" );
 
            virtual void terminate();
 
        protected:
 
            virtual void build( const std::string& lfile );
 
            virtual void step();
 
            virtual void getInputs();
            virtual void processing();
            virtual void setOuts();
 
            struct EXTInfo
            {
                uniset::ObjectId sid = { uniset::DefaultObjectId };
                long value = { 0 };
                std::shared_ptr<Element> el = { nullptr };
                int numInput = { -1 };
            };
 
            struct EXTOutInfo
            {
                uniset::ObjectId sid = { uniset::DefaultObjectId };
                std::shared_ptr<Element> el = { nullptr };
            };
 
            typedef std::vector<EXTInfo> EXTList;
            typedef std::vector<EXTOutInfo> OUTList;
 
            EXTList extInputs;
            OUTList extOuts;
 
            std::shared_ptr<SchemaXML> sch;
 
            UInterface ui;
            timeout_t sleepTime = { 200 };
            timeout_t smReadyTimeout = { 120000 } ;     
 
            std::string logname = { "" };
            std::atomic_bool canceled = {false};
            std::string fSchema = {""};
 
        private:
    };
    // --------------------------------------------------------------------------
} // end of namespace uniset
// ---------------------------------------------------------------------------
#endif