SMInterface.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 SMInterface_H_
#define SMInterface_H_
//--------------------------------------------------------------------------
#include <string>
#include <memory>
#include "UniSetTypes.h"
#include "Mutex.h"
#include "IONotifyController.h"
#include "UInterface.h"
// --------------------------------------------------------------------------
namespace uniset
{
// --------------------------------------------------------------------------
class SMInterface
{
    public:

        SMInterface( uniset::ObjectId _shmID, const std::shared_ptr<UInterface>& ui,
                     uniset::ObjectId myid, const std::shared_ptr<IONotifyController> ic = nullptr );
        ~SMInterface();

        void setValue ( uniset::ObjectId, long value );
        void setUndefinedState( const IOController_i::SensorInfo& si, bool undefined, uniset::ObjectId supplier );

        long getValue ( uniset::ObjectId id );

        void askSensor( uniset::ObjectId id, UniversalIO::UIOCommand cmd,
                        uniset::ObjectId backid = uniset::DefaultObjectId );

        IOController_i::SensorInfoSeq* getSensorsMap();
        IONotifyController_i::ThresholdsListSeq* getThresholdsList();

        void localSetValue( IOController::IOStateList::iterator& it,
                            uniset::ObjectId sid,
                            CORBA::Long newvalue, uniset::ObjectId sup_id );

        long localGetValue( IOController::IOStateList::iterator& it,
                            uniset::ObjectId sid );

        void localSetUndefinedState( IOController::IOStateList::iterator& it,
                                     bool undefined, uniset::ObjectId sid );

        // специальные функции
        IOController::IOStateList::iterator ioEnd();
        void initIterator( IOController::IOStateList::iterator& it );

        bool exist();
        bool waitSMready( int msec, int pause = 5000 );
        bool waitSMworking( uniset::ObjectId, int msec, int pause = 3000 );

        inline bool isLocalwork()
        {
            return (ic == NULL);
        }
        inline uniset::ObjectId ID()
        {
            return myid;
        }
        inline const std::shared_ptr<IONotifyController> SM()
        {
            return ic;
        }
        inline uniset::ObjectId getSMID()
        {
            return shmID;
        }

    protected:
        const std::shared_ptr<IONotifyController> ic;
        const std::shared_ptr<UInterface> ui;
        CORBA::Object_var oref;
        uniset::ObjectId shmID;
        uniset::ObjectId myid;
        uniset::uniset_rwmutex shmMutex;
};
// --------------------------------------------------------------------------
} // end of namespace uniset
//--------------------------------------------------------------------------
#endif