UniExchange.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 UniExchange_H_
#define UniExchange_H_
// -----------------------------------------------------------------------------
#include <list>
#include <memory>
#include "UniXML.h"
#include "IOController.h"
#include "SMInterface.h"
#include "SharedMemory.h"
#include "PassiveTimer.h"
// --------------------------------------------------------------------------
namespace uniset
{
    // -----------------------------------------------------------------------------
    // -----------------------------------------------------------------------------
    class UniExchange:
        public IOController
    {
        public:
            UniExchange( uniset::ObjectId id, uniset::ObjectId shmID,
                         const std::shared_ptr<SharedMemory>& ic = nullptr, const std::string& prefix = "unet" );
            virtual ~UniExchange();
 
            void execute();
 
            static std::shared_ptr<UniExchange> init_exchange( int argc, const char* const* argv,
                    uniset::ObjectId shmID, const std::shared_ptr<SharedMemory>& ic = nullptr,
                    const std::string& prefix = "unet" );

            static void help_print( int argc, const char** argv );
 
            virtual IOController_i::ShortMapSeq* getSensors( const uniset::ObjectId consumer_id ) override;
 
        protected:
 
            virtual void sysCommand( const uniset::SystemMessage* sm ) override;
            virtual void askSensors( UniversalIO::UIOCommand cmd );
            virtual bool deactivateObject() override;
 
            xmlNode* cnode = { 0 };
            std::string s_field = { "" };
            std::string s_fvalue = { "" };
            std::shared_ptr<SMInterface> shm;
 
            struct SInfo
            {
                // т.к. содержится rwmutex с запрещённым конструктором копирования
                // приходится здесь тоже объявлять разрешенными только операции "перемещения"
                SInfo( const SInfo& r ) = delete;
                SInfo& operator=(const SInfo& r) = delete;
                SInfo( SInfo&& r ) = default;
                SInfo& operator=(SInfo&& r) = default;
 
                SInfo():
                    val(0),
                    id(uniset::DefaultObjectId),
                    type(UniversalIO::UnknownIOType)
                {}
 
                IOController::IOStateList::iterator ioit;
                long val;
                long id;
                UniversalIO::IOType type;
                mutable uniset::uniset_rwmutex val_lock;
            };
 
            typedef std::vector<SInfo> SList;
 
            struct NetNodeInfo
            {
                // т.к. содержится SList в котором rwmutex с запрещённым конструктором копирования
                // приходится здесь тоже объявлять разрешенными только операции "перемещения"
                NetNodeInfo( const NetNodeInfo& r ) = delete;
                NetNodeInfo& operator=(const NetNodeInfo& r) = delete;
                NetNodeInfo( NetNodeInfo&& r ) = default;
                NetNodeInfo& operator=(NetNodeInfo&& r) = default;
 
                NetNodeInfo();
 
                CORBA::Object_var oref;
                IOController_i_var shm;
                uniset::ObjectId id;
                uniset::ObjectId node;
                uniset::ObjectId sidConnection; 
                IOController::IOStateList::iterator conn_it;
                SList smap;
 
                void update(IOController_i::ShortMapSeq_var& map, const std::shared_ptr<SMInterface>& shm );
            };
 
            typedef std::list<NetNodeInfo> NetNodeList;
            NetNodeList nlst;
 
            void readConfiguration();
            bool readItem( const std::shared_ptr<UniXML>& xml, UniXML::iterator& it, xmlNode* sec );
            bool initItem( UniXML::iterator& it );
            void updateLocalData();
            void initIterators();
 
            timeout_t polltime = { 200 };
            PassiveTimer ptUpdate;
            bool init_ok = { false };
 
            SList mymap;
            size_t maxIndex = { 0 };
            timeout_t smReadyTimeout = { 60000 }; // msec
 
            std::atomic_bool cancelled = { false };
 
        private:
    };
    // --------------------------------------------------------------------------
} // end of namespace uniset
// -----------------------------------------------------------------------------
#endif // UniExchange_H_