UniSetManager.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 UniSetManager_H_
#define UniSetManager_H_
// --------------------------------------------------------------------------
#include <omniORB4/CORBA.h>
#include <memory>
#include "UniSetTypes.h"
#include "UniSetObject.h"
#include "UniSetManager_i.hh"
//---------------------------------------------------------------------------
namespace uniset
{
    //---------------------------------------------------------------------------
    class UniSetActivator;
 
    class UniSetManager;
    typedef std::list< std::shared_ptr<UniSetManager> > UniSetManagerList;
    //---------------------------------------------------------------------------
    class UniSetManager:
        public UniSetObject,
        public POA_UniSetManager_i
    {
        public:
            UniSetManager( uniset::ObjectId id);
            UniSetManager( const std::string& name, const std::string& section );
            virtual ~UniSetManager();
 
            virtual uniset::ObjectType getType() override
            {
                return uniset::ObjectType("UniSetManager");
            }
 
            // ------  функции объявленые в интерфейсе(IDL) ------
            virtual void broadcast( const uniset::TransportMessage& msg) override;
            virtual uniset::SimpleInfoSeq* getObjectsInfo( CORBA::Long MaxLength = 300, const char* userparam = 0  ) override ;
 
            // --------------------------
            virtual bool add( const std::shared_ptr<UniSetObject>& obj );
            virtual bool remove( const std::shared_ptr<UniSetObject>& obj );
            // --------------------------
            size_t objectsCount() const;    // количество подчинённых объектов
            // ---------------
 
            PortableServer::POA_ptr getPOA();
            PortableServer::POAManager_ptr getPOAManager();
            std::shared_ptr<UniSetManager> get_mptr();
 
        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 };
            friend std::ostream& operator<<( std::ostream& os, OManagerCommand& cmd );
 
            // работа со списком объектов
            void objects(OManagerCommand cmd);
            // работа со списком менеджеров
            void managers(OManagerCommand cmd);
 
            void initPOA( const std::weak_ptr<UniSetManager>& rmngr );
 
            virtual bool activateObject() override;
            virtual bool deactivateObject() override;
 
            const std::shared_ptr<UniSetObject> findObject( const std::string& name ) const;
            const std::shared_ptr<UniSetManager> findManager( const std::string& name ) const;
 
            // рекурсивный поиск по всем объектам
            const std::shared_ptr<UniSetObject> deepFindObject( const std::string& name ) const;
 
            // рекурсивное наполнение списка объектов
            void getAllObjectsList(std::vector<std::shared_ptr<UniSetObject> >& vec, size_t lim = 1000 );
 
            typedef UniSetManagerList::iterator MListIterator;
 
            int getObjectsInfo(const std::shared_ptr<UniSetManager>& mngr, uniset::SimpleInfoSeq* seq,
                               int begin, const long uplimit, const char* userparam );
 
            PortableServer::POA_var poa;
            PortableServer::POAManager_var pman;
 
            // Функции для работы со списками подчинённых объектов
            // ---------------
            typedef std::function<void(const std::shared_ptr<UniSetObject>&)> OFunction;
            void apply_for_objects( OFunction f );
 
            typedef std::function<void(const std::shared_ptr<UniSetManager>&)> MFunction;
            void apply_for_managers( MFunction f );
 
        private:
 
            UniSetManagerList mlist;
            ObjectsList olist;
 
            mutable uniset::uniset_rwmutex olistMutex;
            mutable uniset::uniset_rwmutex mlistMutex;
    };
    // -------------------------------------------------------------------------
} // end of uniset namespace
#endif