PGenericSocketManager.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__
#define __PGENERIC_SOCKET_MANAGER_H__
 
#include <map>
#include "PGenericSocket.h"
#include "PEmptyBackend.h"
#include "PMockBackend.h"

template<typename _TSocketKey, typename _TBackend, typename _TMockBackend>
class PGenericSocketManager{
        public:
                typedef _TBackend Backend;
                typedef _TMockBackend Mock;
                PGenericSocketManager(PSocketMode::PSocketMode mode = PSocketMode::NO_MOCK);
                virtual ~PGenericSocketManager();
                
                void setMode(PSocketMode::PSocketMode mode);
                PSocketMode::PSocketMode getMode() const;
                bool addClientSocket(const _TSocketKey & name, const PSocketParam & socketParam, const typename _TBackend::Param & param, const std::string & mockPrefix, const typename _TMockBackend::Param & mockParam);
                bool addServerSocket(const _TSocketKey & name, const PSocketParam & socketParam, const typename _TBackend::Param & param, const std::string & mockPrefix, const typename _TMockBackend::Param & mockParam);
                
                void removeSocket(const _TSocketKey & name);
                void clear();
                

                template<typename U>
                PSendStatus::PSendStatus sendData(const _TSocketKey & name, const U & data, PSendFlag::PSendFlag flag = PSendFlag::BLOCK){
                        PGenericSocket<_TBackend, _TMockBackend> * socket = getSocket(name);
                        if(socket != NULL){
                                return socket->sendData(data, flag);
                        }else{
                                return PSendStatus::BROKEN_SOCKET;
                        }
                }
                
                PSendStatus::PSendStatus sendMsg(const _TSocketKey & name, typename _TBackend::Message & msg, PSendFlag::PSendFlag flag = PSendFlag::BLOCK);
                

                template<typename U>
                PRecvStatus::PRecvStatus recvData(const _TSocketKey & name, U & data, PRecvFlag::PRecvFlag flag = PRecvFlag::BLOCK){
                        PGenericSocket<_TBackend, _TMockBackend> * socket = getSocket(name);
                        if(socket != NULL){
                                return socket->recvData(data, flag);
                        }else{
                                return PRecvStatus::BROKEN_SOCKET;
                        }
                }
                
                PRecvStatus::PRecvStatus recvMsg(const _TSocketKey & name, typename _TBackend::Message & msg, PRecvFlag::PRecvFlag flag = PRecvFlag::BLOCK);
                
                PGenericSocket<_TBackend, _TMockBackend>* getSocket(const _TSocketKey & name);
                bool isSocketExist(const _TSocketKey & name) const;
                bool isConnected(const _TSocketKey & name) const;
                
        private:
                void initialisationPGenericSocketManager(PSocketMode::PSocketMode mode);
                
                PSocketMode::PSocketMode p_mode;
                
                std::map<_TSocketKey, PGenericSocket<_TBackend, _TMockBackend> *> p_mapSocket;
                _TBackend p_backend;
                _TMockBackend p_mockBackend;
                
};
 
#include "PGenericSocketManager_impl.h"
 
 
#endif