Added support for Win32 broadcast and recience over lan. Changes sent in

by Michael Gronager.

src/Demos/osgcluster/receiver.cpp

@@ -1,13 +1,17 @@
 #include <stdio.h>
-#include <unistd.h>
 #include <fcntl.h>
 #include <sys/types.h>
+#if defined (WIN32)
+#include <winsock.h>
+#else
+#include <unistd.h>
 #include <sys/uio.h>
 #include <sys/socket.h>
 #include <netinet/in.h>
 #include <netdb.h>
 #include <arpa/inet.h>
 #include <sys/time.h>
+#endif
 #include <string.h>
 
 
@@ -22,34 +26,54 @@ Receiver::Receiver( void )
 
 Receiver::~Receiver( void )
 {
+#if defined (WIN32)
+    closesocket( _so);
+#else
     close( _so );
+#endif
 }
 
 bool Receiver::init( void )
 {
+#ifdef WIN32
+    WORD version = MAKEWORD(1,1);
+    WSADATA wsaData;
+    // First, we start up Winsock
+    WSAStartup(version, &wsaData);
+#endif
+
     if( _port == 0 )
     {
-	fprintf( stderr, "Receiver::init() - port not defined\n" );
-	return false;
+    fprintf( stderr, "Receiver::init() - port not defined\n" );
+    return false;
     }
 
     if( (_so = socket( AF_INET, SOCK_DGRAM, 0 )) < 0 )
     {
-        perror( "socket" );
-	return false;
+        perror( "Socket" );
+    return false;
     }
+#if defined (WIN32)
+//    const BOOL on = TRUE;
+//    setsockopt( _so, SOL_SOCKET, SO_REUSEADDR, (const char*) &on, sizeof(int));
+#else
     int on = 1;
     setsockopt( _so, SOL_SOCKET, SO_REUSEADDR, &on, sizeof(on));
+#endif
 
-    struct sockaddr_in saddr;
+//    struct sockaddr_in saddr;
     saddr.sin_family = AF_INET;
     saddr.sin_port   = htons( _port );
+#if defined (WIN32)
+    saddr.sin_addr.s_addr =  htonl(INADDR_ANY);
+#else
     saddr.sin_addr.s_addr =  0;
+#endif
 
     if( bind( _so, (struct sockaddr *)&saddr, sizeof( saddr )) < 0 )
     {
         perror( "bind" );
-	return false;
+        return false;
     }
 
     _initialized = true;
@@ -70,7 +94,7 @@ void Receiver::setBuffer( void *buffer, const unsigned int size )
 
 void Receiver::sync( void )
 {
-    _initialized || init();
+    if(!_initialized) init();
 
     if( _buffer == 0L )
     {
@@ -93,13 +117,29 @@ void Receiver::sync( void )
     tv.tv_sec = 0;
     tv.tv_usec = 0;
 
+#if defined (WIN32)
+//    saddr.sin_port   = htons( _port );
+    recvfrom( _so, (char *)_buffer, _buffer_size, 0, (sockaddr*)&saddr, &size );
+//    recvfrom(sock_Receive, szMessage, 256, 0, (sockaddr*)&addr_Cli, &clilen)
+    int err = WSAGetLastError ();
+    int *dum = (int*) _buffer;
+
+    while( select( _so+1, &fdset, 0L, 0L, &tv ) )
+    {
+        if( FD_ISSET( _so, &fdset ) )
+        {
+            recvfrom( _so, (char *)_buffer, _buffer_size, 0, (sockaddr*)&saddr, &size );
+        }
+    }
+#else
     recvfrom( _so, (caddr_t)_buffer, _buffer_size, 0, 0, &size );
     while( select( _so+1, &fdset, 0L, 0L, &tv ) )
     {
         if( FD_ISSET( _so, &fdset ) )
-	{
+        {
             recvfrom( _so, (caddr_t)_buffer, _buffer_size, 0, 0, &size );
-	}
+        }
     }
+#endif
 }