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 "UniSetTypes.h"
#include "UniSetObject.h"
#include "UniSetManager_i.hh"
//---------------------------------------------------------------------------
class UniSetActivator;

class UniSetManager;
typedef std::list<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();

        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 ) override ;

        // --------------------------
        void initPOA(UniSetManager* rmngr);

        virtual bool addObject(UniSetObject *obj);
        virtual bool removeObject(UniSetObject *obj);

        virtual bool addManager( UniSetManager *mngr );
        virtual bool removeManager( UniSetManager *mngr );


        const UniSetManager* itemM(const UniSetTypes::ObjectId id);


        const 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();

        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;

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

        typedef UniSetManagerList::iterator MListIterator;

        int getObjectsInfo( UniSetManager* mngr, UniSetTypes::SimpleInfoSeq* seq, 
                            int begin, const long uplimit );

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

    private:

        friend class UniSetActivator;

        int sig;
        UniSetManagerList mlist;
        ObjectsList olist;

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

#endif