---

sockets.hpp

Go to the documentation of this file.

//
// Fichero            : sockets.H
// Autor              : 
// Fecha creacion     : 15 / 11 / 2000
// 
// Descripcion        : Reactor singleton, Servicio
//
// Notas
//   - 

#ifndef __SOCKETS_H__
#define __SOCKETS_H__

#include "jic/log/trazas.hpp"
#include "jic/exc/excepcion.hpp"

#include <ace/Singleton.h>
#include <ace/Svc_Handler.h>
#include <ace/SOCK_Stream.h>
#include <ace/Reactor.h>

//@@j
#include <ace/OS.h>


/* #include "orb/globalorb.h" */

namespace SOCKETS
{
  EXCEPCION(ExcSocket);
  EXCEPCION_DE(ExcSocket, ExcBucleEventos);

  typedef ACE_Singleton<ACE_Reactor, ACE_Null_Mutex> Reactor;
  typedef ACE_SOCK_Stream Socket;
  typedef ACE_Svc_Handler<ACE_SOCK_STREAM, ACE_NULL_SYNCH> Servicio;

  class BucleEventos
  {
  public:
    static void svc()
    {
//@@j
ACE_Time_Value tiempo(0,50);

      O_TRAZA("Atendiendo Eventos...");
      while(1) ::SOCKETS::Reactor::instance()->handle_events(&tiempo);
    }
    
/*
    static void start(bool enOtroThread = false)
    {
      if (enOtroThread)
      {
        if (-1 == ACE_Thread::spawn( (ACE_THR_FUNC)::SOCKETS::BucleEventos::svc, 0))
        {
          THROW(ExcBucleEventos, 
                "Imposible lanzar un thread para el bucle de eventos");
        }
      }
      else
      {
        svc();
      }
    }
*/
    static void start()
    {
        svc();
    }
  };
  
/* @@@ De momento no hay soporte a funcionalida de ORB: Cesar 07/01/2003
  
  class Orb
  {
  public:
    static void svc()
    {
      O_TRAZA("Lanzando Orb...");
      GORB->run(); 
    }
    
    static void start(bool enOtroThread = false)
    {
      if (enOtroThread)
      {
        if (-1 == ACE_Thread::spawn( (ACE_THR_FUNC)::SOCKETS::Orb::svc, 0))
        {
          THROW(ExcBucleEventos, 
                "Imposible lanzar un thread para el bucle de eventos");
        }
      }
      else
      {
        svc();
      }
    }
  };
  
*/

} /* SOCKETS */

#endif

---