UniSetManager.h

См. документацию.

/* This file is part of the UniSet project
 * Copyright (c) 2002 Free Software Foundation, Inc.
 * Copyright (c) 2002 Pavel Vainerman
 *
 * This program is free software; you can redistribute it and/or modify
 * it under the terms of the GNU General Public License as published by
 * the Free Software Foundation; either version 2 of the License, or
 * (at your option) any later version.
 *
 * 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 General Public License for more details.
 *
 * You should have received a copy of the GNU General Public License
 * along with this program; if not, write to the Free Software
 * Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA.
 */
// --------------------------------------------------------------------------
// --------------------------------------------------------------------------
#ifndef UniSetManager_H_
#define UniSetManager_H_
// --------------------------------------------------------------------------
#include <omniORB4/CORBA.h>
#include <memory>
#include "UniSetTypes.h"
#include "UniSetObject.h"
#include "UniSetManager_i.hh"
//---------------------------------------------------------------------------
class UniSetActivator;

class UniSetManager;
typedef std::list< std::shared_ptr<UniSetManager> > UniSetManagerList;
//---------------------------------------------------------------------------
class UniSetManager:
    public UniSetObject,
    public POA_UniSetManager_i
{
    public:
        UniSetManager( UniSetTypes::ObjectId id);
        UniSetManager( const std::string& name, const std::string& section );
        virtual ~UniSetManager();

        std::shared_ptr<UniSetManager> get_mptr()
        {
            return std::dynamic_pointer_cast<UniSetManager>(get_ptr());
        }

        virtual UniSetTypes::ObjectType getType() override
        {
            return UniSetTypes::ObjectType("UniSetManager");
        }

        // ------  функции объявленные в интерфейсе(IDL) ------
        virtual void broadcast( const UniSetTypes::TransportMessage& msg) override;
        virtual UniSetTypes::SimpleInfoSeq* getObjectsInfo( CORBA::Long MaxLength = 300, CORBA::Long userparam = 0  ) override ;

        // --------------------------
        virtual bool add( const std::shared_ptr<UniSetObject>& obj );
        virtual bool remove( const std::shared_ptr<UniSetObject>& obj );
        // --------------------------
        const std::shared_ptr<UniSetManager> itemM(const UniSetTypes::ObjectId id);

        const std::shared_ptr<UniSetObject> itemO( const UniSetTypes::ObjectId id );

        // Функции для аботы со списками подчиненных объектов
        inline UniSetManagerList::const_iterator beginMList()
        {
            return mlist.begin();
        }

        inline UniSetManagerList::const_iterator endMList()
        {
            return mlist.end();
        }

        inline ObjectsList::const_iterator beginOList()
        {
            return olist.begin();
        }

        inline ObjectsList::const_iterator endOList()
        {
            return olist.end();
        }

        int objectsCount();    // количество подчиненных объектов

        PortableServer::POA_ptr getPOA()
        {
            return PortableServer::POA::_duplicate(poa);
        }
        PortableServer::POAManager_ptr getPOAManager()
        {
            return  PortableServer::POAManager::_duplicate(pman);
        }

    protected:

        UniSetManager();

        virtual bool addManager( const std::shared_ptr<UniSetManager>& mngr );
        virtual bool removeManager( const std::shared_ptr<UniSetManager>& mngr );
        virtual bool addObject( const std::shared_ptr<UniSetObject>& obj );
        virtual bool removeObject( const std::shared_ptr<UniSetObject>& obj );

        enum OManagerCommand { deactiv, activ, initial, term };
        friend std::ostream& operator<<(std::ostream& os, OManagerCommand& cmd );

        // работа со списком объектов
        void objects(OManagerCommand cmd);
        // работа со списком менеджеров
        void managers(OManagerCommand cmd);

        virtual void sigterm( int signo ) override;

        void initPOA( const std::weak_ptr<UniSetManager>& rmngr );

        virtual bool activateObject() override;
        virtual bool deactivateObject() override;

        typedef UniSetManagerList::iterator MListIterator;

        int getObjectsInfo(const std::shared_ptr<UniSetManager>& mngr, UniSetTypes::SimpleInfoSeq* seq,
                           int begin, const long uplimit, CORBA::Long userparam );

        PortableServer::POA_var poa;
        PortableServer::POAManager_var pman;

    private:

        int sig;
        UniSetManagerList mlist;
        ObjectsList olist;

        UniSetTypes::uniset_rwmutex olistMutex;
        UniSetTypes::uniset_rwmutex mlistMutex;
};

#endif