PGenericSocketManager_impl.h

Go to the documentation of this file.

/***************************************
        Auteur : Pierre Aubert
        Mail : pierre.aubert@lapp.in2p3.fr
        Licence : CeCILL-C
****************************************/
 
#ifndef __PGENERIC_SOCKET_MANAGER_H_IMPL__
#define __PGENERIC_SOCKET_MANAGER_H_IMPL__
 
#include "PGenericSocketManager.h"


template<typename _TSocketKey, typename _TBackend, typename _TMockBackend>
PGenericSocketManager<_TSocketKey, _TBackend, _TMockBackend>::PGenericSocketManager(PSocketMode::PSocketMode mode){
        initialisationPGenericSocketManager(mode);
}

template<typename _TSocketKey, typename _TBackend, typename _TMockBackend>
PGenericSocketManager<_TSocketKey, _TBackend, _TMockBackend>::~PGenericSocketManager(){
        clear();
}


template<typename _TSocketKey, typename _TBackend, typename _TMockBackend>
void PGenericSocketManager<_TSocketKey, _TBackend, _TMockBackend>::setMode(PSocketMode::PSocketMode mode){
        p_mode = mode;
        for(typename std::map<_TSocketKey, PGenericSocket<_TBackend, _TMockBackend>* >::iterator it(p_mapSocket.begin()); it != p_mapSocket.end(); ++it){
                it->second->setMode(mode);
        }
}


template<typename _TSocketKey, typename _TBackend, typename _TMockBackend>
PSocketMode::PSocketMode PGenericSocketManager<_TSocketKey, _TBackend, _TMockBackend>::getMode() const{
        return p_mode;
}


template<typename _TSocketKey, typename _TBackend, typename _TMockBackend>
bool PGenericSocketManager<_TSocketKey, _TBackend, _TMockBackend>::addClientSocket(const _TSocketKey & name, const std::string & host, size_t port, const typename _TBackend::Param & param, const std::string & mockPrefix, const typename _TMockBackend::Param & mockParam)
{
        PGenericSocket<_TBackend, _TMockBackend>* socket = new PGenericSocket<_TBackend, _TMockBackend>(p_mode);
        bool b(socket != NULL);
        if(b){
                b &= socket->createClientSocket(host, port, param, mockPrefix, mockParam);
                if(b){
                        p_mapSocket[name] = socket;
                }
        }
        return b;
}


template<typename _TSocketKey, typename _TBackend, typename _TMockBackend>
bool PGenericSocketManager<_TSocketKey, _TBackend, _TMockBackend>::addServerSocket(const _TSocketKey & name, const std::string & host, size_t port, const typename _TBackend::Param & param, const std::string & mockPrefix, const typename _TMockBackend::Param & mockParam)
{
        PGenericSocket<_TBackend, _TMockBackend>* socket = new PGenericSocket<_TBackend, _TMockBackend>(p_mode);
        bool b(socket != NULL);
        if(b){
                b &= socket->createServerSocket(host, port, param, mockPrefix, mockParam);
                if(b){
                        p_mapSocket[name] = socket;
                }
        }
        return b;
}


template<typename _TSocketKey, typename _TBackend, typename _TMockBackend>
void PGenericSocketManager<_TSocketKey, _TBackend, _TMockBackend>::removeSocket(const _TSocketKey & name){
        typename std::map<_TSocketKey, PGenericSocket<_TBackend, _TMockBackend>* >::iterator it(p_mapSocket.find(name));
        if(it != p_mapSocket.end()){
                delete it->second;
                p_mapSocket.erase(it);
        }
}

template<typename _TSocketKey, typename _TBackend, typename _TMockBackend>
void PGenericSocketManager<_TSocketKey, _TBackend, _TMockBackend>::clear(){
        for(typename std::map<_TSocketKey, PGenericSocket<_TBackend, _TMockBackend>* >::iterator it(p_mapSocket.begin()); it != p_mapSocket.end(); ++it){
                it->second->close();
                delete it->second;
        }
        p_mapSocket.clear();
}


template<typename _TSocketKey, typename _TBackend, typename _TMockBackend>
bool PGenericSocketManager<_TSocketKey, _TBackend, _TMockBackend>::sendMsg(const _TSocketKey & name, typename _TBackend::Message & msg, PSendFlag::PSendFlag flag){
        PGenericSocket<_TBackend, _TMockBackend> * socket = getSocket(name);
        if(socket != NULL){
                return socket->sendMsg(msg, flag);
        }else{
                return false;
        }
}


template<typename _TSocketKey, typename _TBackend, typename _TMockBackend>
bool PGenericSocketManager<_TSocketKey, _TBackend, _TMockBackend>::recvMsg(const _TSocketKey & name, typename _TBackend::Message & msg, PRecvFlag::PRecvFlag flag){
        PGenericSocket<_TBackend, _TMockBackend> * socket = getSocket(name);
        if(socket != NULL){
                return socket->recvMsg(msg, flag);
        }else{
                return false;
        }
}


template<typename _TSocketKey, typename _TBackend, typename _TMockBackend>
PGenericSocket<_TBackend, _TMockBackend>* PGenericSocketManager<_TSocketKey, _TBackend, _TMockBackend>::getSocket(const _TSocketKey & name)
{
        typename std::map<_TSocketKey, PGenericSocket<_TBackend, _TMockBackend>* >::iterator it(p_mapSocket.find(name));
        if(it != p_mapSocket.end()){
                return it->second;
        }else{
                return NULL;
        }
}


template<typename _TSocketKey, typename _TBackend, typename _TMockBackend>
bool PGenericSocketManager<_TSocketKey, _TBackend, _TMockBackend>::isSocketExist(const _TSocketKey & name) const{
        typename std::map<_TSocketKey, PGenericSocket<_TBackend, _TMockBackend>* >::const_iterator it(p_mapSocket.find(name));
        return it != p_mapSocket.end();
}


template<typename _TSocketKey, typename _TBackend, typename _TMockBackend>
bool PGenericSocketManager<_TSocketKey, _TBackend, _TMockBackend>::isConnected(const _TSocketKey & name) const{
        typename std::map<_TSocketKey, PGenericSocket<_TBackend, _TMockBackend>* >::const_iterator it(p_mapSocket.find(name));
        if(it != p_mapSocket.end()){
                return it->second->isConnected();
        }
        return false;
}
 


template<typename _TSocketKey, typename _TBackend, typename _TMockBackend>
void PGenericSocketManager<_TSocketKey, _TBackend, _TMockBackend>::initialisationPGenericSocketManager(PSocketMode::PSocketMode mode){
        p_mode = mode;
}
 
 
 
 
 
#endif