cabal_udpsocket.cpp

/*
   CABAL Cached Balanced Lan
   UDPSocket class implementation

   $Id: cabal_udpsocket.cpp,v 1.4 2004/03/29 14:17:28 jonnymind Exp $
---------------------------------------------
   Begin      : Thu, 11 Mar 2004 03:32:52 +0100
   Author     : Giancarlo Niccolai

   Last modified because:

*/


#include <cabal_udpsocket.h>
#include <fcntl.h>
#include <string>
#include <cassert>

namespace Cabal {

void UDPSocket::create( const Address *local, const Address *remote  ) throw( InitError )
{
   localCreate();

   if ( local ) {
      m_local = *local;
      localBind();
   }
   
   if ( remote )
      m_remote = *remote;
}

bool UDPSocket::setBroadcast()
{
   int iOpt = 1;
   if ( setsockopt( m_skCom, SOL_SOCKET,
         SO_BROADCAST, (const char *) &iOpt, sizeof( iOpt )) == 0 )
      return true;
      
   m_osError = Net::errorCode();
   return false;
}


int UDPSocket::sendTo( const void *data, const int count, const Address &remote )
{
   if( selectFor( true ) ) //write
   {
      int len = Net::sendto( m_skCom, data, count, MSG_NOSIGNAL, &(remote.address()), sizeof(SockAddrInet)  );

      if ( len <  0 ) {
         m_osError = Net::errorCode();
      }
      else
         m_osError = 0;
      m_bTout = false;
      return len;
   }
   else {
      m_osError = 0;
      m_bTout = true;
      return 0;
   }
}

int UDPSocket::recvFrom( void *data, const int count, Address &remote )
{
   if( selectFor( false ) ) //read
   {
      int size = sizeof(SockAddrInet);
      int len = Net::recvfrom( m_skCom, data, count, MSG_NOSIGNAL, &(remote.varAddress()), &size  );

      if ( len <  0 ) {
         m_osError = Net::errorCode();
      }
      else
         m_osError = 0;
      m_bTout = false;
      return len;
   }
   else {
      m_osError = 0;
      m_bTout = true;
      return 0;
   }
}

};

/* end of cabal_udpsocket.cpp */

---