cabal_os_wsa.cpp

/*
   CABAL PROTOCOL
   CAched BAlanced LAN

   OS specific cabal extensions (WIN*OWS WSA)

   $Id: cabal_os_wsa.cpp,v 1.5 2004/03/26 22:45:11 jonnymind Exp $
---------------------------------------------
   Begin      :
   Author     : Giancarlo Niccolai

   Last modified because:

*/


#include <cabal_os.h>

namespace Cabal
{

bool Net_WSA::init() throw(InitError)
{
   WORD wVersion;
   WSADATA wsaData;


   wVersion = MAKEWORD( 2, 0 );
   if ( WSAStartup( wVersion, &wsaData ) == 0 ) {
      return true;
   }

   throw InitError( "Cannot initialize Windows Socket API", GetLastError() );
}

bool Net_WSA::exit() throw(DataIncompleteError)
{
   if ( WSACleanup() == 0 ) {
      return true;
   }
   throw DataIncompleteError( "Cannot shut down Windows Socket API", GetLastError() );
}
     
bool Net_WSA::getHostList(
   const std::string &name,
   std::string &real_name,
   char *real_ip,
   NetAddr *other_addrs, int na_count )
{
   int i;
   struct hostent *result;

   if (isalpha(name.c_str()[0])) 
   {   /* host address is a name */
     result = gethostbyname(name.c_str());
   }
   else  
   { 
     unsigned int addr = inet_addr(name.c_str());
     result = gethostbyaddr((char *)&addr, 4, AF_INET);
   }

   if ( result )
   {
      char **ret_ips = result->h_addr_list;

      i = 0;
      while ( *ret_ips && i < na_count )
      {
         memcpy( other_addrs+i, *ret_ips, sizeof( NetAddr ) );
         // WSA bug: hosts are returned in host order bytes.
         *(other_addrs + i) = hostToNetAddr( *(other_addrs + i) );
         ret_ips++;
         i++;
      }

      SockAddrInet addr;
      Net::initSockAddr( addr,  *other_addrs, 0 );
      addrToString( addr , real_ip );
      
      if( i < na_count ) 
         other_addrs[i] = CABAL_INVALID_ADDR;
         
      real_name = result->h_name;
      return true;
   }

   return false;
}


bool Net_WSA::addrToString( const SockAddrInet &addr, char* buf )
{
   // TODO: Lock here
   char *ret =  inet_ntoa( addr.sin_addr );
   if ( ret == 0 )
      return false;
   strncpy( buf, ret, CABAL_MAX_IP_SIZE );
   buf[CABAL_MAX_IP_SIZE-1] = '\0';
   return true;
}


std::string Net_WSA::errorDescription( const int osCode )
{
   char buf[256];
   DWORD dwRet;
   
   if ( osCode < 0 ) return "";
   
   dwRet = FormatMessage( 
      FORMAT_MESSAGE_FROM_SYSTEM,
      0,
      osCode,
      MAKELANGID(LANG_NEUTRAL, SUBLANG_DEFAULT),
      buf,
      256,
      0);
   
   if ( dwRet != 0 ) return std::string(buf);
   
   return "Unknown Error";
}

MSECS Net_WSA::timeOfDay()
{
   SYSTEMTIME sysTime;

   GetSystemTime( &sysTime );

   return (static_cast<MSECS>(sysTime.wHour) * 3600000L) + 
            sysTime.wMinute * 60000L + 
            sysTime.wSecond * 1000 + 
            sysTime.wMilliseconds;
}


}

/* End of cabal_os_wsa.cpp */

---