---

svcdesocket.hpp

Go to the documentation of this file.

//
// Fichero            : SvcDeSocket.hpp
// Autor              : 
// Fecha creacion     : 
// 
// Descripcion        : 
// 
// Notas
//   -  

#ifndef __SvcDeSocket_H__
#define __SvcDeSocket_H__

#include "jic/log/trazas.hpp"
#include "jic/socket/acceptor.hpp"
#include "jic/task/producers/fndesocketdin.hpp" 
#include "jic/task/CMessageBlock.hpp"
#include "jic/task/CChainTask.hpp"
#include "jic/socket/sockets.hpp"


namespace SOCKETS
{

  EXCEPCION(ExcSalidaNoConectada);

  //------------------------------------------------------------------------------
  //------------------------------------------------------------------------------
  template<class Msg>
  class SvcDeSocket : public SOCKETS::Servicio
  {
  public:
    SvcDeSocket();

    // Es llamado por cada Msg recibido
    int open(void *);

    // Es llamado por cada Msg recibido
    virtual int handle_input(ACE_HANDLE idConexion);
    
    void set_pNext(TASK::CChainTask<Msg> * next);

  private:
    TASK::CChainTask<Msg> * _objAct;


    // Conexiones activas
    TASK::PRODUCERS::FnDeSocketDin<Msg> _fnDeSocketDin;
    typedef std::map<ACE_HANDLE, SOCKETS::Socket > MapaConexiones;
    MapaConexiones _mapaConexiones;
  };

  //------------------------------------------------------------------------------
  //------------------------------------------------------------------------------
  template<class Msg>
  class LectorDeSocket 
    : public SOCKETS::Acceptor<SvcDeSocket<Msg> >
  {
  public:
    LectorDeSocket(int puertoEscucha) 
      : SOCKETS::Acceptor<SvcDeSocket<Msg> > (puertoEscucha, 
        (_svc = new SvcDeSocket<Msg>))
    {
      O_TRAZA("SERVICIOS::LectorDeSocket::LectorDeSocket(puertoEscucha=" << puertoEscucha << ")");
    }
    
    virtual ~LectorDeSocket() {
      O_TRAZA("SERVICIOS::LectorDeSocket::~LectorSondaInelcom()");
      delete _svc;
    }

    void set_pNext(TASK::CChainTask<Msg> * next)
    {
      _svc->set_pNext(next);
    };

  private:
    SvcDeSocket<Msg> * _svc;
    
  };
  
  

#ifdef  ACE_TEMPLATES_REQUIRE_SOURCE
#include "svcdesocket.cpp"
#endif

} // namespace SERVICES

#endif

---