cabal_udpsocket.h

/*
   cabal_udpsocket.h
   Basic UDP socket object for cabal

   $Id: cabal_udpsocket.h,v 1.4 2004/04/10 15:28:16 jonnymind Exp $
---------------------------------------------
   Begin      : Thu, 11 Mar 2004 03:05:18 +0100
   Author     : Giancarlo Niccolai

   Last modified because:

*/

#ifndef CABAL_UDPSOCKET_H
#define CABAL_UDPSOCKET_H

#ifdef _MSC_VER
   #pragma warning ( disable : 4786 )
#endif

#include <cabal_socket.h>

namespace Cabal
{

class UDPSocket: public Socket
{
   void create( const Address *local=0, const Address *remote=0 ) throw( InitError );
   void localCreate() throw( InitError )
   {
      m_skCom = Net::createUDPSocket();
      if ( ! Net::validSocket( m_skCom ) )
         throw InitError( "Low level socket not created", Net::errorCode() );
   
      Net::setNonBlocking( m_skCom );
   }
   
   void localBind() throw( InitError )
   {
      if( ! Net::bind( m_skCom, m_local.address() ) )
         throw InitError( "Can't bind local address.", Net::errorCode() );
   }

protected:
   virtual int rawRecv( void *data, const int len )
   {
      int remlen = sizeof( SockAddrInet );   
      // Teorethically, we should not always use varAddress; recvFrom may return 0, and it
      // would not change the address in remote. But having to recalculate the remote
      // 
      return Net::recvfrom( m_skCom, data, len, 0, &(m_remote.varAddress()), &remlen );
   }


   virtual int rawSend( const void *data, const int len )
   {
      return Net::sendto( m_skCom, static_cast<const char *>(data), len, 0,
         &(m_remote.address()), sizeof( SockAddrInet ) );
   }

   
public:
   UDPSocket( const long timeout, const Address *local=0, const Address *remote=0 ) throw( InitError )
         :Socket( ST_UDP ) 
   {
      create( local, remote );
      m_timeout = timeout;
   }
   
   UDPSocket( const Address *local=0, const Address *remote=0  ) throw( InitError )
         :Socket( ST_UDP ) 
   {
      create( local, remote );
      m_timeout = -1;
   }
   
   UDPSocket( const char *ip_local, const int port_local ) throw( InitError )
         :Socket( ST_UDP, ip_local, port_local ) 
   {
      localCreate();
      localBind();
      m_timeout = -1;
   }
   
   UDPSocket( const char *ip_local, const int port_local, 
              const char *ip_remote, const int port_remote  ) throw( InitError )
         :Socket( ST_UDP, ip_local, port_local, ip_remote, port_remote ) 
   {
      localCreate();
      localBind();
      m_timeout = -1;
   }
   
   bool setBroadcast();
   
   int sendTo( const void *data, const int count, const Address &remote);      
   
   int recvFrom( void *data, const int count, Address &remote);
};

}

#endif

/* end of cabal_udpsocket.h */

---