include/UniExchange.h

// -----------------------------------------------------------------------------
#ifndef UniExchange_H_
#define UniExchange_H_
// -----------------------------------------------------------------------------
#include <list>
#include "UniXML.h"
#include "IOController.h"
#include "SMInterface.h"
#include "SharedMemory.h"
#include "PassiveTimer.h"
// -----------------------------------------------------------------------------
// -----------------------------------------------------------------------------
class UniExchange:
    public IOController
{
    public:
        UniExchange( UniSetTypes::ObjectId id, UniSetTypes::ObjectId shmID, 
                        SharedMemory* ic=0, const std::string prefix="unet" );
        virtual ~UniExchange();

        void execute();

        static UniExchange* init_exchange( int argc, const char* const* argv,
                                    UniSetTypes::ObjectId shmID, SharedMemory* ic=0,
                                    const std::string prefix="unet" );

        static void help_print( int argc, const char** argv );

        virtual IOController_i::ShortMapSeq* getSensors();

    protected:

        virtual void processingMessage( UniSetTypes::VoidMessage* msg );
        virtual void sysCommand( UniSetTypes::SystemMessage* sm );
        virtual void askSensors( UniversalIO::UIOCommand cmd );
        virtual void sensorInfo( UniSetTypes::SensorMessage* sm );
        virtual void timerInfo( UniSetTypes::TimerMessage* tm );
        virtual void sigterm( int signo );

        xmlNode* cnode;
        std::string s_field;
        std::string s_fvalue;
        SMInterface* shm;
        
        struct SInfo
        {
            SInfo():
                val(0),
                id(UniSetTypes::DefaultObjectId),
                type(UniversalIO::UnknownIOType)
            {}

            IOController::DIOStateList::iterator dit;
            IOController::AIOStateList::iterator ait;
            long val;
            long id;
            UniversalIO::IOTypes type;
            UniSetTypes::uniset_spin_mutex val_lock;
        };
        
        typedef std::vector<SInfo> SList;
        
        struct NetNodeInfo
        {
            NetNodeInfo();
        
            CORBA::Object_var oref;
            IOController_i_var shm;
            UniSetTypes::ObjectId id;
            UniSetTypes::ObjectId node;
            UniSetTypes::ObjectId sidConnection; 
            IOController::DIOStateList::iterator conn_dit;
            SList smap;
            
            void update(IOController_i::ShortMapSeq_var& map, SMInterface* shm );
        };
        
        typedef std::list<NetNodeInfo> NetNodeList;
        NetNodeList nlst;

        void readConfiguration();
        bool readItem( UniXML& xml, UniXML_iterator& it, xmlNode* sec );
        bool initItem( UniXML_iterator& it );
        void updateLocalData();
        void initIterators();
        
        int polltime;
        PassiveTimer ptUpdate;
        bool init_ok;
        
        SList mymap;
        size_t maxIndex;
        int smReadyTimeout;
        
    private:
};
// -----------------------------------------------------------------------------
#endif // UniExchange_H_