---

svcdesocketbruto.hpp

Go to the documentation of this file.

//
// Fichero            : SvcDeSocketBruto.h
// Autor              : Javier Gomez Sanchez
// Fecha creacion     : 
// 
// Descripcion        : 
// 
// Notas
//   -  

#ifndef __SvcDeSocketBruto_H__
#define __SvcDeSocketBruto_H__



#include "jic/socket/acceptor.hpp"
#include "jic/task/producers/fndesocketbruto.hpp"
#include "jic/socket/capturatrafico.hpp"
#include "jic/task/CMessageBlock.hpp"
#include "jic/task/CChainTask.hpp"
#include "jic/socket/sockets.hpp"


namespace SOCKETS
{

  EXCEPCION(ExcSalidaNoConectada);

  //------------------------------------------------------------------------------
  //------------------------------------------------------------------------------
  class SvcDeSocketBruto : public SOCKETS::Servicio
  {
  public:
    SvcDeSocketBruto();

    // 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<SOCKETS::CapturaTrafico> * next);

  private:
    TASK::CChainTask<SOCKETS::CapturaTrafico> * _objAct;

    // Conexiones activas
    TASK::PRODUCERS::FnDeSocketBruto _fnDeSocketB;
    typedef std::map<ACE_HANDLE, SOCKETS::Socket > MapaConexiones;
    MapaConexiones _mapaConexiones;
  };

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

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

  private:
    SvcDeSocketBruto * _svc;
  };


} // namespace SOCKETS

#endif

---