]> git.saurik.com Git - wxWidgets.git/blobdiff - src/mac/carbon/gsocket.cpp
projects / wxWidgets.git / blobdiff
? search:
summary | shortlog | log | commit | commitdiff | tree
raw | inline | side by side
check that the version of __sync_sub_and_fetch that returns a value is supported...
[wxWidgets.git] / src / mac / carbon / gsocket.cpp
diff --git a/src/mac/carbon/gsocket.cpp b/src/mac/carbon/gsocket.cpp
index 91fb0149d53d9179c0c4184c37d54c0c1c67961b..1b14f7d3a0d74a2ef033e234d23994f124c56416 100644 (file)
--- a/src/mac/carbon/gsocket.cpp
+++ b/src/mac/carbon/gsocket.cpp
@@ -1,6 +1,6 @@
 /* -------------------------------------------------------------------------
  * Project:     GSocket (Generic Socket) for WX
 /* -------------------------------------------------------------------------
  * Project:     GSocket (Generic Socket) for WX
- * Name:        gsocket.cpp
+ * Name:        src/mac/carbon/gsocket.cpp
  * Copyright:   (c) Guilhem Lavaux
  * Licence:     wxWindows Licence
  * Authors:     Guilhem Lavaux,
  * Copyright:   (c) Guilhem Lavaux
  * Licence:     wxWindows Licence
  * Authors:     Guilhem Lavaux,
@@ -16,24 +16,22 @@
  */
 
 #ifndef __GSOCKET_STANDALONE__
  */
 
 #ifndef __GSOCKET_STANDALONE__
-#include "wx/setup.h"
 #include "wx/platform.h"
 #endif
 
 #if wxUSE_SOCKETS || defined(__GSOCKET_STANDALONE__)
 
 #ifdef __DARWIN__
 #include "wx/platform.h"
 #endif
 
 #if wxUSE_SOCKETS || defined(__GSOCKET_STANDALONE__)
 
 #ifdef __DARWIN__
-  #include <CoreServices/CoreServices.h>
-
+    #include <CoreServices/CoreServices.h>
 #else
 #else
-  #include <MacHeaders.c>
-  #define OTUNIXERRORS 1
-  #include <OpenTransport.h>
-  #include <OpenTransportProviders.h>
-  #include <OpenTptInternet.h>
+    #include <MacHeaders.c>
+    #define OTUNIXERRORS 1
+    #include <OpenTransport.h>
+    #include <OpenTransportProviders.h>
+    #include <OpenTptInternet.h>
 #endif
 #if TARGET_CARBON && !defined(OTAssert)
 #endif
 #if TARGET_CARBON && !defined(OTAssert)
-  #define OTAssert( str , cond ) /* does not exists in Carbon */
+    #define OTAssert( str , cond ) /* does not exists in Carbon */
 #endif
 
 #include <assert.h>
 #endif
 
 #include <assert.h>
@@ -61,22 +59,22 @@
 #endif
 #ifndef __GSOCKET_STANDALONE__
 
 #endif
 #ifndef __GSOCKET_STANDALONE__
 
-#include "wx/mac/macnotfy.h"
-#include "wx/mac/gsockmac.h"
-#include "wx/gsocket.h"
+    #include "wx/mac/macnotfy.h"
+    #include "wx/mac/gsockmac.h"
+    #include "wx/gsocket.h"
 
 #else
 
 
 #else
 
-#include "gsockmac.h"
-#include "gsocket.h"
+    #include "gsockmac.h"
+    #include "gsocket.h"
 
 #endif /* __GSOCKET_STANDALONE__ */
 
 #ifndef ntohl
 
 #endif /* __GSOCKET_STANDALONE__ */
 
 #ifndef ntohl
-#define        ntohl(x)        (x)
-#define        ntohs(x)        (x)
-#define        htonl(x)        (x)
-#define        htons(x)        (x)
+    #define  ntohl(x) (x)
+    #define  ntohs(x) (x)
+    #define  htonl(x) (x)
+    #define  htons(x) (x)
 #endif
 
 void wxCYield() ;
 #endif
 
 void wxCYield() ;
@@ -95,104 +93,104 @@ OTNotifyUPP gOTNotifierUPP = NULL ;
 OSStatus DoNegotiateIPReuseAddrOption(EndpointRef ep, Boolean enableReuseIPMode);
 
 /* Input: ep - endpointref on which to negotiate the option
 OSStatus DoNegotiateIPReuseAddrOption(EndpointRef ep, Boolean enableReuseIPMode);
 
 /* Input: ep - endpointref on which to negotiate the option
-                       enableReuseIPMode - desired option setting - true/false
+               enableReuseIPMode - desired option setting - true/false
    Return: kOTNoError indicates that the option was successfully negotiated
    Return: kOTNoError indicates that the option was successfully negotiated
-                       OSStatus is an error if < 0, otherwise, the status field is
-                       returned and is > 0.
-       
-       IMPORTANT NOTE: The endpoint is assumed to be in synchronous more, otherwise
-                       this code will not function as desired
+           OSStatus is an error if < 0, otherwise, the status field is
+           returned and is > 0.
+
+   IMPORTANT NOTE: The endpoint is assumed to be in synchronous more, otherwise
+                   this code will not function as desired
 */
 
 
 OSStatus DoNegotiateIPReuseAddrOption(EndpointRef ep, Boolean enableReuseIPMode)
 
 {
 */
 
 
 OSStatus DoNegotiateIPReuseAddrOption(EndpointRef ep, Boolean enableReuseIPMode)
 
 {
-       UInt8           buf[kOTFourByteOptionSize];     // define buffer for fourByte Option size
-       TOption*        opt;                                            // option ptr to make items easier to access
-       TOptMgmt        req;
-       TOptMgmt        ret;
-       OSStatus        err;
-       
-       if (!OTIsSynchronous(ep))
-       {
-               return (-1);
-       }
-       opt = (TOption*)buf;                                    // set option ptr to buffer
-       req.opt.buf     = buf;
-       req.opt.len     = sizeof(buf);
-       req.flags       = T_NEGOTIATE;                          // negotiate for option
-
-       ret.opt.buf = buf;
-       ret.opt.maxlen = kOTFourByteOptionSize;
-
-       opt->level      = INET_IP;                                      // dealing with an IP Level function
+    UInt8        buf[kOTFourByteOptionSize]; // define buffer for fourByte Option size
+    TOption*     opt;                        // option ptr to make items easier to access
+    TOptMgmt     req;
+    TOptMgmt     ret;
+    OSStatus     err;
+
+    if (!OTIsSynchronous(ep))
+    {
+        return (-1);
+    }
+    opt = (TOption*)buf; // set option ptr to buffer
+    req.opt.buf = buf;
+    req.opt.len = sizeof(buf);
+    req.flags   = T_NEGOTIATE;    // negotiate for option
+
+    ret.opt.buf = buf;
+    ret.opt.maxlen = kOTFourByteOptionSize;
+
+    opt->level  = INET_IP;        // dealing with an IP Level function
 #ifdef __DARWIN__
 #ifdef __DARWIN__
-       opt->name       = kIP_REUSEADDR;
+    opt->name   = kIP_REUSEADDR;
 #else
 #else
-       opt->name       = IP_REUSEADDR;
+    opt->name   = IP_REUSEADDR;
 #endif
 #endif
-       opt->len        = kOTFourByteOptionSize;
-       opt->status = 0;
-       *(UInt32*)opt->value = enableReuseIPMode;               // set the desired option level, true or false
-
-       err = OTOptionManagement(ep, &req, &ret);
-       
-               // if no error then return the option status value
-       if (err == kOTNoError)
-       {
-               if (opt->status != T_SUCCESS)
-                       err = opt->status;
-               else
-                       err = kOTNoError;
-       }
-                               
-       return err;
+    opt->len    = kOTFourByteOptionSize;
+    opt->status = 0;
+    *(UInt32*)opt->value = enableReuseIPMode;   // set the desired option level, true or false
+
+    err = OTOptionManagement(ep, &req, &ret);
+
+    // if no error then return the option status value
+    if (err == kOTNoError)
+    {
+        if (opt->status != T_SUCCESS)
+            err = opt->status;
+        else
+            err = kOTNoError;
+    }
+
+    return err;
 }
 
 
 pascal void OTInetEventHandler(void*s, OTEventCode event, OTResult, void *cookie) ;
 pascal void OTInetEventHandler(void*s, OTEventCode event, OTResult result, void *cookie)
 {
 }
 
 
 pascal void OTInetEventHandler(void*s, OTEventCode event, OTResult, void *cookie) ;
 pascal void OTInetEventHandler(void*s, OTEventCode event, OTResult result, void *cookie)
 {
-       int wakeUp = true ;
-       GSocket* sock = (GSocket*) s ;
-       
-       if ( event == kOTSyncIdleEvent )
-       {
-               return ;
-       }
-
-       if ( s )
-       {
-               wxMacAddEvent( sock->m_mac_events , _GSocket_Internal_Proc , event , s , wakeUp ) ;
-       }
-
-       return;
+    int wakeUp = true ;
+    GSocket* sock = (GSocket*) s ;
+
+    if ( event == kOTSyncIdleEvent )
+    {
+        return ;
+    }
+
+    if ( s )
+    {
+        wxMacAddEvent( sock->m_mac_events , _GSocket_Internal_Proc , event , s , wakeUp ) ;
+    }
+
+    return;
 }
 
 static void SetDefaultEndpointModes(EndpointRef ep , void *data )
 }
 
 static void SetDefaultEndpointModes(EndpointRef ep , void *data )
-       // This routine sets the supplied endpoint into the default
-       // mode used in this application.  The specifics are:
-       // blocking, synchronous, and using synch idle events with
-       // the standard YieldingNotifier.
+    // This routine sets the supplied endpoint into the default
+    // mode used in this application.  The specifics are:
+    // blocking, synchronous, and using synch idle events with
+    // the standard YieldingNotifier.
 {
 {
-       OSStatus junk = kOTNoError ;
-       OTAssert ("SetDefaultEndpointModes:invalid ref", ep != kOTInvalidEndpointRef ) ;
-       junk = OTSetAsynchronous(ep);
-       OTAssert("SetDefaultEndpointModes: Could not set asynchronous", junk == noErr);
+    OSStatus junk = kOTNoError ;
+    OTAssert ("SetDefaultEndpointModes:invalid ref", ep != kOTInvalidEndpointRef ) ;
+    junk = OTSetAsynchronous(ep);
+    OTAssert("SetDefaultEndpointModes: Could not set asynchronous", junk == noErr);
 /*
 /*
-       junk = OTSetBlocking(ep);
-       OTAssert("SetDefaultEndpointModes: Could not set blocking", junk == noErr);
-       junk = OTSetSynchronous(ep);
-       OTAssert("SetDefaultEndpointModes: Could not set synchronous", junk == noErr);
-       junk = OTSetBlocking(ep);
-       OTAssert("SetDefaultEndpointModes: Could not set blocking", junk == noErr);
+    junk = OTSetBlocking(ep);
+    OTAssert("SetDefaultEndpointModes: Could not set blocking", junk == noErr);
+    junk = OTSetSynchronous(ep);
+    OTAssert("SetDefaultEndpointModes: Could not set synchronous", junk == noErr);
+    junk = OTSetBlocking(ep);
+    OTAssert("SetDefaultEndpointModes: Could not set blocking", junk == noErr);
 */
 */
-       junk = OTInstallNotifier(ep, gOTNotifierUPP, data);
-       OTAssert("SetDefaultEndpointModes: Could not install notifier", junk == noErr);
+    junk = OTInstallNotifier(ep, gOTNotifierUPP, data);
+    OTAssert("SetDefaultEndpointModes: Could not install notifier", junk == noErr);
 /*
 /*
-       junk = OTUseSyncIdleEvents(ep, true);
-       OTAssert("SetDefaultEndpointModes: Could not use sync idle events", junk == noErr);
+    junk = OTUseSyncIdleEvents(ep, true);
+    OTAssert("SetDefaultEndpointModes: Could not use sync idle events", junk == noErr);
 */
 }
 
 */
 }
 
@@ -223,19 +221,19 @@ bool GSocket_Verify_Inited()
     InitOpenTransportInContext(kInitOTForApplicationMask, &clientcontext);
     gOTInited = 1 ;
     gInetSvcRef = OTOpenInternetServicesInContext(kDefaultInternetServicesPath,
     InitOpenTransportInContext(kInitOTForApplicationMask, &clientcontext);
     gOTInited = 1 ;
     gInetSvcRef = OTOpenInternetServicesInContext(kDefaultInternetServicesPath,
-                                               NULL, &err, clientcontext);
-#else  
+                                                  NULL, &err, clientcontext);
+#else
     if ( gInetSvcRef )
       return true ;
     if ( gInetSvcRef )
       return true ;
- 
+
     InitOpenTransport() ;
     gOTInited = 1 ;
     gInetSvcRef = OTOpenInternetServices(kDefaultInternetServicesPath, NULL, &err);
 #endif
     if ( gInetSvcRef == NULL ||  err != kOTNoError )
     {
     InitOpenTransport() ;
     gOTInited = 1 ;
     gInetSvcRef = OTOpenInternetServices(kDefaultInternetServicesPath, NULL, &err);
 #endif
     if ( gInetSvcRef == NULL ||  err != kOTNoError )
     {
-       OTAssert("Could not open Inet Services", err == noErr);
-       return false ;
+        OTAssert("Could not open Inet Services", err == noErr);
+        return false ;
     }
     gOTNotifierUPP = NewOTNotifyUPP( OTInetEventHandler ) ;
     return true ;
     }
     gOTNotifierUPP = NewOTNotifyUPP( OTInetEventHandler ) ;
     return true ;
@@ -245,8 +243,8 @@ void GSocket_Cleanup()
 {
     if ( gOTInited != 0 )
     {
 {
     if ( gOTInited != 0 )
     {
-      if ( gInetSvcRef != NULL )
-       OTCloseProvider( gInetSvcRef );
+        if ( gInetSvcRef != NULL )
+            OTCloseProvider( gInetSvcRef );
     #if TARGET_CARBON
       CloseOpenTransportInContext( NULL ) ;
     #else
     #if TARGET_CARBON
       CloseOpenTransportInContext( NULL ) ;
     #else
@@ -279,25 +277,25 @@ GSocket::GSocket()
   m_non_blocking        = false;
   m_timeout             = 1*1000;
                                 /* 10 sec * 1000 millisec */
   m_non_blocking        = false;
   m_timeout             = 1*1000;
                                 /* 10 sec * 1000 millisec */
-  m_takesEvents                        = true ;
-  m_mac_events                 = wxMacGetNotifierTable() ;
+  m_takesEvents         = true ;
+  m_mac_events          = wxMacGetNotifierTable() ;
 }
 
 GSocket::~GSocket()
 {
 }
 
 GSocket::~GSocket()
 {
-  assert(this);
+    assert(this);
 
 
-  /* Check that the socket is really shutdowned */
-  if (m_endpoint != kOTInvalidEndpointRef)
-    Shutdown();
+    /* Check that the socket is really shutdowned */
+    if (m_endpoint != kOTInvalidEndpointRef)
+        Shutdown();
 
 
 
 
-  /* Destroy private addresses */
-  if (m_local)
-    GAddress_destroy(m_local);
+    /* Destroy private addresses */
+    if (m_local)
+        GAddress_destroy(m_local);
 
 
-  if (m_peer)
-    GAddress_destroy(m_peer);
+    if (m_peer)
+        GAddress_destroy(m_peer);
 }
 
 /* GSocket_Shutdown:
 }
 
 /* GSocket_Shutdown:
@@ -306,32 +304,32 @@ GSocket::~GSocket()
  */
 void GSocket::Shutdown()
 {
  */
 void GSocket::Shutdown()
 {
-  OSStatus err ;
-  int evt;
+    OSStatus err ;
+    int evt;
 
 
-  assert(this);
+    assert(this);
 
 
-  /* If socket has been created, shutdown it */
-  if (m_endpoint != kOTInvalidEndpointRef )
-  {
-    err = OTSndOrderlyDisconnect( m_endpoint ) ;
-       if ( err != kOTNoError )
-       {
-               
-       }
-    err = OTRcvOrderlyDisconnect( m_endpoint ) ;
-       err = OTUnbind( m_endpoint ) ;
-       err = OTCloseProvider( m_endpoint ) ;
-       m_endpoint = kOTInvalidEndpointRef ;
-  }
+    /* If socket has been created, shutdown it */
+    if (m_endpoint != kOTInvalidEndpointRef )
+    {
+        err = OTSndOrderlyDisconnect( m_endpoint ) ;
+        if ( err != kOTNoError )
+        {
+        }
+
+        err = OTRcvOrderlyDisconnect( m_endpoint ) ;
+        err = OTUnbind( m_endpoint ) ;
+        err = OTCloseProvider( m_endpoint ) ;
+        m_endpoint = kOTInvalidEndpointRef ;
+    }
 
 
-  /* Disable GUI callbacks */
-  for (evt = 0; evt < GSOCK_MAX_EVENT; evt++)
-    m_cbacks[evt] = NULL;
+    /* Disable GUI callbacks */
+    for (evt = 0; evt < GSOCK_MAX_EVENT; evt++)
+        m_cbacks[evt] = NULL;
 
 
-  m_detected = 0;
-  Disable_Events();
-  wxMacRemoveAllNotifiersForData( wxMacGetNotifierTable() , this ) ;
+    m_detected = 0;
+    Disable_Events();
+    wxMacRemoveAllNotifiersForData( wxMacGetNotifierTable() , this ) ;
 }
 
 
 }
 
 
@@ -353,109 +351,109 @@ void GSocket::Shutdown()
  */
 GSocketError GSocket::SetLocal(GAddress *address)
 {
  */
 GSocketError GSocket::SetLocal(GAddress *address)
 {
-  assert(this);
+    assert(this);
 
 
-  /* the socket must be initialized, or it must be a server */
-  if ((m_endpoint != kOTInvalidEndpointRef && !m_server))
-  {
-    m_error = GSOCK_INVSOCK;
-    return GSOCK_INVSOCK;
-  }
+    /* the socket must be initialized, or it must be a server */
+    if ((m_endpoint != kOTInvalidEndpointRef && !m_server))
+    {
+        m_error = GSOCK_INVSOCK;
+        return GSOCK_INVSOCK;
+    }
 
 
-  /* check address */
-  if (address == NULL || address->m_family == GSOCK_NOFAMILY)
-  {
-    m_error = GSOCK_INVADDR;
-    return GSOCK_INVADDR;
-  }
+    /* check address */
+    if (address == NULL || address->m_family == GSOCK_NOFAMILY)
+    {
+        m_error = GSOCK_INVADDR;
+        return GSOCK_INVADDR;
+    }
 
 
-  if (m_local)
-    GAddress_destroy(m_local);
+    if (m_local)
+        GAddress_destroy(m_local);
 
 
-  m_local = GAddress_copy(address);
+    m_local = GAddress_copy(address);
 
 
-  return GSOCK_NOERROR;
+    return GSOCK_NOERROR;
 }
 
 GSocketError GSocket::SetPeer(GAddress *address)
 {
 }
 
 GSocketError GSocket::SetPeer(GAddress *address)
 {
-  assert(this);
+    assert(this);
 
 
-  /* check address */
-  if (address == NULL || address->m_family == GSOCK_NOFAMILY)
-  {
-    m_error = GSOCK_INVADDR;
-    return GSOCK_INVADDR;
-  }
+    /* check address */
+    if (address == NULL || address->m_family == GSOCK_NOFAMILY)
+    {
+        m_error = GSOCK_INVADDR;
+        return GSOCK_INVADDR;
+    }
 
 
-  if (m_peer)
-    GAddress_destroy(m_peer);
+    if (m_peer)
+        GAddress_destroy(m_peer);
 
 
-  m_peer = GAddress_copy(address);
+    m_peer = GAddress_copy(address);
 
 
-  return GSOCK_NOERROR;
+    return GSOCK_NOERROR;
 }
 
 GAddress *GSocket::GetLocal()
 {
 }
 
 GAddress *GSocket::GetLocal()
 {
-  GAddress *address = NULL ;
-  GSocketError err;
-  InetAddress loc ;
+    GAddress *address = NULL ;
+    GSocketError err;
+    InetAddress loc ;
 
 
-  assert(this);
+    assert(this);
 
 
-  /* try to get it from the m_local var first */
-  if (m_local)
-    return GAddress_copy(m_local);
+    /* try to get it from the m_local var first */
+    if (m_local)
+        return GAddress_copy(m_local);
+
+    /* else, if the socket is initialized, try getsockname */
+    if (m_endpoint == kOTInvalidEndpointRef)
+    {
+        m_error = GSOCK_INVSOCK;
+        return NULL;
+    }
 
 
-  /* else, if the socket is initialized, try getsockname */
-  if (m_endpoint == kOTInvalidEndpointRef)
-  {
-    m_error = GSOCK_INVSOCK;
-    return NULL;
-  }
 
 
-       
 /* we do not support multihoming with this code at the moment
 /* we do not support multihoming with this code at the moment
-   OTGetProtAddress will have to be used then - but we don't have a handy 
+   OTGetProtAddress will have to be used then - but we don't have a handy
    method to use right now
 */
    method to use right now
 */
-  {
-    InetInterfaceInfo  info;
-    OTInetGetInterfaceInfo(&info, kDefaultInetInterface);
-    loc.fHost = info.fAddress ;
-    loc.fPort = 0 ;
-       loc.fAddressType = AF_INET ;
-  }
+    {
+        InetInterfaceInfo info;
+        OTInetGetInterfaceInfo(&info, kDefaultInetInterface);
+        loc.fHost = info.fAddress ;
+        loc.fPort = 0 ;
+        loc.fAddressType = AF_INET ;
+    }
 
 
-  /* got a valid address from getsockname, create a GAddress object */
-  address = GAddress_new();
-  if (address == NULL)
-  {
-    m_error = GSOCK_MEMERR;
-    return NULL;
-  }
+    /* got a valid address from getsockname, create a GAddress object */
+    address = GAddress_new();
+    if (address == NULL)
+    {
+        m_error = GSOCK_MEMERR;
+        return NULL;
+    }
 
 
-  err = _GAddress_translate_from(address, &loc);
-  if (err != GSOCK_NOERROR)
-  {
-    GAddress_destroy(address);
-    m_error = err;
-    return NULL;
-  }
+    err = _GAddress_translate_from(address, &loc);
+    if (err != GSOCK_NOERROR)
+    {
+        GAddress_destroy(address);
+        m_error = err;
+        return NULL;
+    }
 
 
-  return address;
+    return address;
 }
 
 GAddress *GSocket::GetPeer()
 {
 }
 
 GAddress *GSocket::GetPeer()
 {
-  assert(this);
+    assert(this);
 
 
-  /* try to get it from the m_peer var */
-  if (m_peer)
-    return GAddress_copy(m_peer);
+    /* try to get it from the m_peer var */
+    if (m_peer)
+        return GAddress_copy(m_peer);
 
 
-  return NULL;
+    return NULL;
 }
 
 /* Server specific parts */
 }
 
 /* Server specific parts */
@@ -464,11 +462,11 @@ GAddress *GSocket::GetPeer()
  *  Sets up this socket as a server. The local address must have been
  *  set with GSocket_SetLocal() before GSocket_SetServer() is called.
  *  Returns GSOCK_NOERROR on success, one of the following otherwise:
  *  Sets up this socket as a server. The local address must have been
  *  set with GSocket_SetLocal() before GSocket_SetServer() is called.
  *  Returns GSOCK_NOERROR on success, one of the following otherwise:
- * 
+ *
  *  Error codes:
  *    GSOCK_INVSOCK - the socket is in use.
  *    GSOCK_INVADDR - the local address has not been set.
  *  Error codes:
  *    GSOCK_INVSOCK - the socket is in use.
  *    GSOCK_INVADDR - the local address has not been set.
- *    GSOCK_IOERR   - low-level error. 
+ *    GSOCK_IOERR   - low-level error.
  */
 GSocketError GSocket::SetServer()
 {
  */
 GSocketError GSocket::SetServer()
 {
@@ -514,7 +512,7 @@ GSocketError GSocket::SetServer()
   if ((bind(m_endpoint, m_local->m_addr, m_local->m_len) != 0) ||
       (getsockname(m_endpoint,
                    m_local->m_addr,
   if ((bind(m_endpoint, m_local->m_addr, m_local->m_len) != 0) ||
       (getsockname(m_endpoint,
                    m_local->m_addr,
-                   (SOCKLEN_T *) &m_local->m_len) != 0) ||
+                   (WX_SOCKLEN_T *) &m_local->m_len) != 0) ||
       (listen(m_endpoint, 5) != 0))
   {
     close(m_endpoint);
       (listen(m_endpoint, 5) != 0))
   {
     close(m_endpoint);
@@ -536,7 +534,7 @@ GSocketError GSocket::SetServer()
  *    GSOCK_TIMEDOUT   - timeout, no incoming connections.
  *    GSOCK_WOULDBLOCK - the call would block and the socket is nonblocking.
  *    GSOCK_MEMERR     - couldn't allocate memory.
  *    GSOCK_TIMEDOUT   - timeout, no incoming connections.
  *    GSOCK_WOULDBLOCK - the call would block and the socket is nonblocking.
  *    GSOCK_MEMERR     - couldn't allocate memory.
- *    GSOCK_IOERR      - low-level error. 
+ *    GSOCK_IOERR      - low-level error.
  */
 GSocket *GSocket::WaitConnection()
 {
  */
 GSocket *GSocket::WaitConnection()
 {
@@ -573,7 +571,7 @@ GSocket *GSocket::WaitConnection()
 
 // TODO
 #if 0
 
 // TODO
 #if 0
-  connection->m_endpoint = accept(m_endpoint, &from, (SOCKLEN_T *) &fromlen);
+  connection->m_endpoint = accept(m_endpoint, &from, (WX_SOCKLEN_T *) &fromlen);
 #endif
 
   if (connection->m_endpoint == kOTInvalidEndpointRef )
 #endif
 
   if (connection->m_endpoint == kOTInvalidEndpointRef )
@@ -653,7 +651,7 @@ GSocketError GSocket::SetNonOriented()
   m_oriented = false;
 
   /* Create the socket */
   m_oriented = false;
 
   /* Create the socket */
-  
+
 // TODO
 #if 0
   m_endpoint = socket(m_local->m_realfamily, SOCK_DGRAM, 0);
 // TODO
 #if 0
   m_endpoint = socket(m_local->m_realfamily, SOCK_DGRAM, 0);
@@ -679,7 +677,7 @@ GSocketError GSocket::SetNonOriented()
   if ((bind(m_endpoint, m_local->m_addr, m_local->m_len) != 0) ||
       (getsockname(m_endpoint,
                    m_local->m_addr,
   if ((bind(m_endpoint, m_local->m_addr, m_local->m_len) != 0) ||
       (getsockname(m_endpoint,
                    m_local->m_addr,
-                   (SOCKLEN_T *) &m_local->m_len) != 0))
+                   (WX_SOCKLEN_T *) &m_local->m_len) != 0))
   {
     close(m_endpoint);
     m_endpoint    = -1;
   {
     close(m_endpoint);
     m_endpoint    = -1;
@@ -696,7 +694,7 @@ GSocketError GSocket::SetNonOriented()
  *  For stream (connection oriented) sockets, GSocket_Connect() tries
  *  to establish a client connection to a server using the peer address
  *  as established with GSocket_SetPeer(). Returns GSOCK_NOERROR if the
  *  For stream (connection oriented) sockets, GSocket_Connect() tries
  *  to establish a client connection to a server using the peer address
  *  as established with GSocket_SetPeer(). Returns GSOCK_NOERROR if the
- *  connection has been succesfully established, or one of the error
+ *  connection has been successfully established, or one of the error
  *  codes listed below. Note that for nonblocking sockets, a return
  *  value of GSOCK_WOULDBLOCK doesn't mean a failure. The connection
  *  request can be completed later; you should use GSocket_Select()
  *  codes listed below. Note that for nonblocking sockets, a return
  *  value of GSOCK_WOULDBLOCK doesn't mean a failure. The connection
  *  request can be completed later; you should use GSocket_Select()
@@ -713,13 +711,13 @@ GSocketError GSocket::SetNonOriented()
  *    GSOCK_TIMEDOUT   - timeout, the connection failed.
  *    GSOCK_WOULDBLOCK - connection in progress (nonblocking sockets only)
  *    GSOCK_MEMERR     - couldn't allocate memory.
  *    GSOCK_TIMEDOUT   - timeout, the connection failed.
  *    GSOCK_WOULDBLOCK - connection in progress (nonblocking sockets only)
  *    GSOCK_MEMERR     - couldn't allocate memory.
- *    GSOCK_IOERR      - low-level error. 
+ *    GSOCK_IOERR      - low-level error.
  */
 GSocketError GSocket::Connect(GSocketStream stream)
 {
   InetAddress addr ;
  */
 GSocketError GSocket::Connect(GSocketStream stream)
 {
   InetAddress addr ;
-  TEndpointInfo        info;
-   OSStatus            err = kOTNoError;
+  TEndpointInfo   info;
+   OSStatus       err = kOTNoError;
   TCall peer ;
 
   assert(this);
   TCall peer ;
 
   assert(this);
@@ -746,22 +744,22 @@ GSocketError GSocket::Connect(GSocketStream stream)
 
   /* Create the socket */
 #if TARGET_CARBON
 
   /* Create the socket */
 #if TARGET_CARBON
-  m_endpoint = 
-       OTOpenEndpointInContext( OTCreateConfiguration( kTCPName) , 0 , &info , &err , NULL ) ;
+  m_endpoint =
+      OTOpenEndpointInContext( OTCreateConfiguration( kTCPName) , 0 , &info , &err , NULL ) ;
 #else
 #else
-  m_endpoint = 
-       OTOpenEndpoint( OTCreateConfiguration( kTCPName) , 0 , &info , &err ) ;
+  m_endpoint =
+      OTOpenEndpoint( OTCreateConfiguration( kTCPName) , 0 , &info , &err ) ;
 #endif
   if ( m_endpoint == kOTInvalidEndpointRef || err != kOTNoError )
   {
 #endif
   if ( m_endpoint == kOTInvalidEndpointRef || err != kOTNoError )
   {
-               m_endpoint = kOTInvalidEndpointRef ;
-       m_error = GSOCK_IOERR;
-       return GSOCK_IOERR;
+    m_endpoint = kOTInvalidEndpointRef ;
+    m_error = GSOCK_IOERR;
+    return GSOCK_IOERR;
   }
   err = OTBind( m_endpoint , nil , nil ) ;
   if ( err != kOTNoError )
   {
   }
   err = OTBind( m_endpoint , nil , nil ) ;
   if ( err != kOTNoError )
   {
-       return GSOCK_IOERR;
+    return GSOCK_IOERR;
   }
   SetDefaultEndpointModes( m_endpoint , this ) ;
 // TODO
   }
   SetDefaultEndpointModes( m_endpoint , this ) ;
 // TODO
@@ -781,13 +779,13 @@ GSocketError GSocket::Connect(GSocketStream stream)
      * is in blocking mode, we select() for the specified timeout
      * checking for writability to see if the connection request
      * completes.
      * is in blocking mode, we select() for the specified timeout
      * checking for writability to see if the connection request
      * completes.
-     */ 
-       
+     */
+
     if ((err == kOTNoDataErr ) && (!m_non_blocking))
     {
       if (Output_Timeout() == GSOCK_TIMEDOUT)
       {
     if ((err == kOTNoDataErr ) && (!m_non_blocking))
     {
       if (Output_Timeout() == GSOCK_TIMEDOUT)
       {
-       OTSndOrderlyDisconnect( m_endpoint ) ;
+        OTSndOrderlyDisconnect( m_endpoint ) ;
         m_endpoint = kOTInvalidEndpointRef ;
         /* m_error is set in _GSocket_Output_Timeout */
         return GSOCK_TIMEDOUT;
         m_endpoint = kOTInvalidEndpointRef ;
         /* m_error is set in _GSocket_Output_Timeout */
         return GSOCK_TIMEDOUT;
@@ -796,7 +794,7 @@ GSocketError GSocket::Connect(GSocketStream stream)
       {
 /*
         int error;
       {
 /*
         int error;
-        SOCKLEN_T len = sizeof(error);
+        WX_SOCKLEN_T len = sizeof(error);
 
         getsockopt(m_endpoint, SOL_SOCKET, SO_ERROR, (void*) &error, &len);
 
 
         getsockopt(m_endpoint, SOL_SOCKET, SO_ERROR, (void*) &error, &len);
 
@@ -858,7 +856,7 @@ int GSocket::Read(char *buffer, int size)
     ret = Recv_Stream(buffer, size);
   else
     ret = Recv_Dgram(buffer, size);
     ret = Recv_Stream(buffer, size);
   else
     ret = Recv_Dgram(buffer, size);
-    
+
   if (ret == -1)
   {
     if (errno == EWOULDBLOCK)
   if (ret == -1)
   {
     if (errno == EWOULDBLOCK)
@@ -866,12 +864,12 @@ int GSocket::Read(char *buffer, int size)
     else
       m_error = GSOCK_IOERR;
   }
     else
       m_error = GSOCK_IOERR;
   }
-  
+
   return ret;
 }
 
 int GSocket::Write(const char *buffer, int size)
   return ret;
 }
 
 int GSocket::Write(const char *buffer, int size)
-{                        
+{
   int ret;
 
   assert(this);
   int ret;
 
   assert(this);
@@ -891,7 +889,7 @@ int GSocket::Write(const char *buffer, int size)
     ret = Send_Stream(buffer, size);
   else
     ret = Send_Dgram(buffer, size);
     ret = Send_Stream(buffer, size);
   else
     ret = Send_Dgram(buffer, size);
-    
+
   if (ret == -1)
   {
     if (errno == EWOULDBLOCK)
   if (ret == -1)
   {
     if (errno == EWOULDBLOCK)
@@ -907,7 +905,7 @@ int GSocket::Write(const char *buffer, int size)
     m_detected &= ~GSOCK_OUTPUT_FLAG;
     return -1;
   }
     m_detected &= ~GSOCK_OUTPUT_FLAG;
     return -1;
   }
-  
+
   return ret;
 }
 
   return ret;
 }
 
@@ -924,24 +922,24 @@ GSocketEventFlags GSocket::Select(GSocketEventFlags flags)
   wxMacProcessNotifierEvents() ;
   /*
   state = OTGetEndpointState(m_endpoint);
   wxMacProcessNotifierEvents() ;
   /*
   state = OTGetEndpointState(m_endpoint);
-  
+
   if ( ( flags & GSOCK_INPUT_FLAG ) && ! ( m_detected & GSOCK_INPUT_FLAG ) )
   {
   if ( ( flags & GSOCK_INPUT_FLAG ) && ! ( m_detected & GSOCK_INPUT_FLAG ) )
   {
-       size_t sz = 0 ;
-       OTCountDataBytes( m_endpoint , &sz ) ;
-       if ( state == T_INCON || sz > 0 )
-       {
-        m_detected |= GSOCK_INPUT_FLAG ;
-               (m_cbacks[GSOCK_INPUT])(this, GSOCK_INPUT, m_data[GSOCK_INPUT]);
-       }
+    size_t sz = 0 ;
+    OTCountDataBytes( m_endpoint , &sz ) ;
+    if ( state == T_INCON || sz > 0 )
+    {
+      m_detected |= GSOCK_INPUT_FLAG ;
+      (m_cbacks[GSOCK_INPUT])(this, GSOCK_INPUT, m_data[GSOCK_INPUT]);
+    }
   }
   if ( ( flags & GSOCK_INPUT_FLAG ) && ! ( m_detected & GSOCK_OUTPUT_FLAG ) )
   {
   }
   if ( ( flags & GSOCK_INPUT_FLAG ) && ! ( m_detected & GSOCK_OUTPUT_FLAG ) )
   {
-       if ( state == T_DATAXFER || state == T_INREL )
-       {
-        m_detected |=GSOCK_OUTPUT_FLAG ;
-               (m_cbacks[GSOCK_OUTPUT])(this, GSOCK_OUTPUT, m_data[GSOCK_OUTPUT]);
-       }
+    if ( state == T_DATAXFER || state == T_INREL )
+    {
+      m_detected |=GSOCK_OUTPUT_FLAG ;
+      (m_cbacks[GSOCK_OUTPUT])(this, GSOCK_OUTPUT, m_data[GSOCK_OUTPUT]);
+    }
   }
   */
   return ( flags & m_detected ) ;
   }
   */
   return ( flags & m_detected ) ;
@@ -974,7 +972,7 @@ void GSocket::SetTimeout(unsigned long millisec)
 }
 
 /* GSocket_GetError:
 }
 
 /* GSocket_GetError:
- *  Returns the last error occured for this socket. Note that successful
+ *  Returns the last error which occurred for this socket. Note that successful
  *  operations do not clear this back to GSOCK_NOERROR, so use it only
  *  after an error.
  */
  *  operations do not clear this back to GSOCK_NOERROR, so use it only
  *  after an error.
  */
@@ -992,14 +990,14 @@ GSocketError WXDLLIMPEXP_NET GSocket::GetError()
  *   operation, there is still data available, the callback function will
  *   be called again.
  * GSOCK_OUTPUT:
  *   operation, there is still data available, the callback function will
  *   be called again.
  * GSOCK_OUTPUT:
- *   The socket is available for writing. That is, the next write call 
+ *   The socket is available for writing. That is, the next write call
  *   won't block. This event is generated only once, when the connection is
  *   first established, and then only if a call failed with GSOCK_WOULDBLOCK,
  *   when the output buffer empties again. This means that the app should
  *   assume that it can write since the first OUTPUT event, and no more
  *   OUTPUT events will be generated unless an error occurs.
  * GSOCK_CONNECTION:
  *   won't block. This event is generated only once, when the connection is
  *   first established, and then only if a call failed with GSOCK_WOULDBLOCK,
  *   when the output buffer empties again. This means that the app should
  *   assume that it can write since the first OUTPUT event, and no more
  *   OUTPUT events will be generated unless an error occurs.
  * GSOCK_CONNECTION:
- *   Connection succesfully established, for client sockets, or incoming
+ *   Connection successfully established, for client sockets, or incoming
  *   client connection, for server sockets. Wait for this event (also watch
  *   out for GSOCK_LOST) after you issue a nonblocking GSocket_Connect() call.
  * GSOCK_LOST:
  *   client connection, for server sockets. Wait for this event (also watch
  *   out for GSOCK_LOST) after you issue a nonblocking GSocket_Connect() call.
  * GSOCK_LOST:
@@ -1061,31 +1059,31 @@ void GSocket::UnsetCallback(GSocketEventFlags flags)
 
 int GSocket::Recv_Stream(char *buffer, int size)
 {
 
 int GSocket::Recv_Stream(char *buffer, int size)
 {
-       OTFlags flags ;
-       OTResult res ;
-       OTByteCount sz = 0 ;
-
-       OTCountDataBytes( m_endpoint , &sz ) ;
-       if ( size > (int)sz )
-         size = sz ;
-       res = OTRcv( m_endpoint , buffer , size , &flags ) ;
-       if ( res < 0 )
-       {
-               return -1 ;
-       }
-       
-       // we simulate another read event if there are still bytes
-       if ( m_takesEvents )
-       {
-               OTByteCount sz = 0 ;
-               OTCountDataBytes( m_endpoint , &sz ) ;
-               if ( sz > 0 )
-               {
-               m_detected |= GSOCK_INPUT_FLAG ;
-                       (m_cbacks[GSOCK_INPUT])(this, GSOCK_INPUT, m_data[GSOCK_INPUT]);
-               }
-       }
-       return res ;
+    OTFlags flags ;
+    OTResult res ;
+    OTByteCount sz = 0 ;
+
+    OTCountDataBytes( m_endpoint , &sz ) ;
+    if ( size > (int)sz )
+        size = sz ;
+    res = OTRcv( m_endpoint , buffer , size , &flags ) ;
+    if ( res < 0 )
+    {
+        return -1 ;
+    }
+
+    // we simulate another read event if there are still bytes
+    if ( m_takesEvents )
+    {
+        OTByteCount sz = 0 ;
+        OTCountDataBytes( m_endpoint , &sz ) ;
+        if ( sz > 0 )
+        {
+            m_detected |= GSOCK_INPUT_FLAG ;
+            (m_cbacks[GSOCK_INPUT])(this, GSOCK_INPUT, m_data[GSOCK_INPUT]);
+        }
+    }
+    return res ;
 }
 
 int GSocket::Recv_Dgram(char *buffer, int size)
 }
 
 int GSocket::Recv_Dgram(char *buffer, int size)
@@ -1094,12 +1092,12 @@ int GSocket::Recv_Dgram(char *buffer, int size)
   int ret = -1;
 #if 0
   struct sockaddr from;
   int ret = -1;
 #if 0
   struct sockaddr from;
-  SOCKLEN_T fromlen = sizeof(from);
+  WX_SOCKLEN_T fromlen = sizeof(from);
   GSocketError err;
 
   fromlen = sizeof(from);
 
   GSocketError err;
 
   fromlen = sizeof(from);
 
-  ret = recvfrom(m_endpoint, buffer, size, 0, &from, (SOCKLEN_T *) &fromlen);
+  ret = recvfrom(m_endpoint, buffer, size, 0, &from, (WX_SOCKLEN_T *) &fromlen);
 
   if (ret == -1)
     return -1;
 
   if (ret == -1)
     return -1;
@@ -1128,11 +1126,11 @@ int GSocket::Recv_Dgram(char *buffer, int size)
 
 int GSocket::Send_Stream(const char *buffer, int size)
 {
 
 int GSocket::Send_Stream(const char *buffer, int size)
 {
-       OTFlags flags = 0 ;
-       OTResult res ;
+    OTFlags flags = 0 ;
+    OTResult res ;
 
 
-       res = OTSnd( m_endpoint , (void*) buffer , size , flags ) ;
-       return res ;
+    res = OTSnd( m_endpoint , (void*) buffer , size , flags ) ;
+    return res ;
 }
 
 int GSocket::Send_Dgram(const char *buffer, int size)
 }
 
 int GSocket::Send_Dgram(const char *buffer, int size)
@@ -1273,7 +1271,7 @@ GSocketError _GAddress_translate_from(GAddress *address,
 GSocketError _GAddress_translate_to(GAddress *address,
                                     InetAddress *addr)
 {
 GSocketError _GAddress_translate_to(GAddress *address,
                                     InetAddress *addr)
 {
- if ( !GSocket_Verify_Inited() )
+  if ( !GSocket_Verify_Inited() )
     return GSOCK_IOERR ;
   memset(addr, 0 , sizeof(struct InetAddress));
   OTInitInetAddress( addr , address->m_port , address->m_host ) ;
     return GSOCK_IOERR ;
   memset(addr, 0 , sizeof(struct InetAddress));
   OTInitInetAddress( addr , address->m_port , address->m_host ) ;
@@ -1290,7 +1288,7 @@ GSocketError _GAddress_Init_INET(GAddress *address)
 {
   address->m_family = GSOCK_INET;
   address->m_host = kOTAnyInetAddress ;
 {
   address->m_family = GSOCK_INET;
   address->m_host = kOTAnyInetAddress ;
-  
+
   return GSOCK_NOERROR;
 }
 
   return GSOCK_NOERROR;
 }
 
@@ -1308,14 +1306,19 @@ GSocketError GAddress_INET_SetHostName(GAddress *address, const char *hostname)
   ret = OTInetStringToAddress( gInetSvcRef , (char*) hostname , &hinfo ) ;
   if ( ret != kOTNoError )
   {
   ret = OTInetStringToAddress( gInetSvcRef , (char*) hostname , &hinfo ) ;
   if ( ret != kOTNoError )
   {
-       address->m_host = INADDR_NONE ;
+    address->m_host = INADDR_NONE ;
     address->m_error = GSOCK_NOHOST;
     return GSOCK_NOHOST;
     address->m_error = GSOCK_NOHOST;
     return GSOCK_NOHOST;
-  }  
+  }
   address->m_host = hinfo.addrs[0] ;
   return GSOCK_NOERROR;
 }
 
   address->m_host = hinfo.addrs[0] ;
   return GSOCK_NOERROR;
 }
 
+GSocketError GAddress_INET_SetBroadcastAddress(GAddress *address)
+{
+  return GAddress_INET_SetHostAddress(address, INADDR_BROADCAST);
+}
+
 GSocketError GAddress_INET_SetAnyAddress(GAddress *address)
 {
   return GAddress_INET_SetHostAddress(address, INADDR_ANY);
 GSocketError GAddress_INET_SetAnyAddress(GAddress *address)
 {
   return GAddress_INET_SetHostAddress(address, INADDR_ANY);
@@ -1333,17 +1336,17 @@ GSocketError GAddress_INET_SetHostAddress(GAddress *address,
   return GSOCK_NOERROR;
 }
 
   return GSOCK_NOERROR;
 }
 
-struct service_entry 
+struct service_entry
 {
 {
-       const char * name ;
-       unsigned short port ;
-       const char * protocol ; 
+    const char * name ;
+    unsigned short port ;
+    const char * protocol ;
 } ;
 typedef struct service_entry service_entry ;
 
 service_entry gServices[] =
 {
 } ;
 typedef struct service_entry service_entry ;
 
 service_entry gServices[] =
 {
-       { "http" , 80 , "tcp" } 
+    { "http" , 80 , "tcp" }
 } ;
 
 GSocketError GAddress_INET_SetPortName(GAddress *address, const char *port,
 } ;
 
 GSocketError GAddress_INET_SetPortName(GAddress *address, const char *port,
@@ -1361,14 +1364,14 @@ GSocketError GAddress_INET_SetPortName(GAddress *address, const char *port,
   }
   for ( i = 0 ; i < sizeof( gServices) / sizeof( service_entry ) ; ++i )
   {
   }
   for ( i = 0 ; i < sizeof( gServices) / sizeof( service_entry ) ; ++i )
   {
-       if ( strcmp( port , gServices[i].name ) == 0 )
-       {
-               if ( protocol == NULL || strcmp( protocol , gServices[i].protocol ) )
-               {
-                       address->m_port = gServices[i].port ;
-               return GSOCK_NOERROR;
-               }
-       }
+    if ( strcmp( port , gServices[i].name ) == 0 )
+    {
+      if ( protocol == NULL || strcmp( protocol , gServices[i].protocol ) )
+      {
+        address->m_port = gServices[i].port ;
+        return GSOCK_NOERROR;
+      }
+    }
   }
 
   if (isdigit(port[0]))
   }
 
   if (isdigit(port[0]))
@@ -1386,17 +1389,17 @@ GSocketError GAddress_INET_SetPort(GAddress *address, unsigned short port)
   assert(address != NULL);
   CHECK_ADDRESS(address, INET, GSOCK_INVADDR);
   address->m_port = port ;
   assert(address != NULL);
   CHECK_ADDRESS(address, INET, GSOCK_INVADDR);
   address->m_port = port ;
- 
+
   return GSOCK_NOERROR;
 }
 
 GSocketError GAddress_INET_GetHostName(GAddress *address, char *hostname, size_t sbuf)
 {
   InetDomainName name ;
   return GSOCK_NOERROR;
 }
 
 GSocketError GAddress_INET_GetHostName(GAddress *address, char *hostname, size_t sbuf)
 {
   InetDomainName name ;
- if ( !GSocket_Verify_Inited() )
+  if ( !GSocket_Verify_Inited() )
     return GSOCK_IOERR ;
     return GSOCK_IOERR ;
-  
-  assert(address != NULL); 
+
+  assert(address != NULL);
   CHECK_ADDRESS(address, INET, GSOCK_INVADDR);
 
   OTInetAddressToName( gInetSvcRef , address->m_host , name ) ;
   CHECK_ADDRESS(address, INET, GSOCK_INVADDR);
 
   OTInetAddressToName( gInetSvcRef , address->m_host , name ) ;
@@ -1406,52 +1409,52 @@ GSocketError GAddress_INET_GetHostName(GAddress *address, char *hostname, size_t
 
 unsigned long GAddress_INET_GetHostAddress(GAddress *address)
 {
 
 unsigned long GAddress_INET_GetHostAddress(GAddress *address)
 {
-  assert(address != NULL); 
-  CHECK_ADDRESS(address, INET, 0); 
+  assert(address != NULL);
+  CHECK_ADDRESS(address, INET, 0);
 
   return ntohl(address->m_host);
 }
 
 unsigned short GAddress_INET_GetPort(GAddress *address)
 {
 
   return ntohl(address->m_host);
 }
 
 unsigned short GAddress_INET_GetPort(GAddress *address)
 {
-  assert(address != NULL); 
-  CHECK_ADDRESS(address, INET, 0); 
+  assert(address != NULL);
+  CHECK_ADDRESS(address, INET, 0);
 
   return address->m_port;
 }
 
 void GSocket::Enable_Events()
 {
 
   return address->m_port;
 }
 
 void GSocket::Enable_Events()
 {
-  if ( m_takesEvents )
-       return ;
-  
-  {
-         OTResult      state ;
-         m_takesEvents                 = true ;
-         state = OTGetEndpointState(m_endpoint);
-         
-         {
-               OTByteCount sz = 0 ;
-               OTCountDataBytes( m_endpoint , &sz ) ;
-               if ( state == T_INCON || sz > 0 )
-               {
-               m_detected |= GSOCK_INPUT_FLAG ;
-                       (m_cbacks[GSOCK_INPUT])(this, GSOCK_INPUT, m_data[GSOCK_INPUT]);
-               }
-         }
-         {
-               if ( state == T_DATAXFER || state == T_INREL )
-               {
-               m_detected |=GSOCK_OUTPUT_FLAG ;
-                       (m_cbacks[GSOCK_OUTPUT])(this, GSOCK_OUTPUT, m_data[GSOCK_OUTPUT]);
-               }
-         }
-  }
+    if ( m_takesEvents )
+        return ;
+
+    {
+        OTResult  state ;
+        m_takesEvents = true ;
+        state = OTGetEndpointState(m_endpoint);
+
+        {
+            OTByteCount sz = 0 ;
+            OTCountDataBytes( m_endpoint , &sz ) ;
+            if ( state == T_INCON || sz > 0 )
+            {
+                m_detected |= GSOCK_INPUT_FLAG ;
+                (m_cbacks[GSOCK_INPUT])(this, GSOCK_INPUT, m_data[GSOCK_INPUT]);
+            }
+        }
+        {
+            if ( state == T_DATAXFER || state == T_INREL )
+            {
+                m_detected |=GSOCK_OUTPUT_FLAG ;
+                (m_cbacks[GSOCK_OUTPUT])(this, GSOCK_OUTPUT, m_data[GSOCK_OUTPUT]);
+            }
+        }
+    }
 }
 
 void GSocket::Disable_Events()
 {
 }
 
 void GSocket::Disable_Events()
 {
-  m_takesEvents                        = false ;
+    m_takesEvents = false ;
 }
 
 /* _GSocket_Input_Timeout:
 }
 
 /* _GSocket_Input_Timeout:
@@ -1467,20 +1470,20 @@ GSocketError GSocket::Input_Timeout()
     Microseconds(&start);
     now = start ;
     m_takesEvents = false ;
     Microseconds(&start);
     now = start ;
     m_takesEvents = false ;
-    
+
     while( (now.hi * 4294967296.0 + now.lo) - (start.hi * 4294967296.0 + start.lo) < m_timeout * 1000.0 )
     {
     while( (now.hi * 4294967296.0 + now.lo) - (start.hi * 4294967296.0 + start.lo) < m_timeout * 1000.0 )
     {
-       OTResult state ;
-               OTByteCount sz = 0 ;
-                 state = OTGetEndpointState(m_endpoint);
-  
-               OTCountDataBytes( m_endpoint , &sz ) ;
-               if ( state == T_INCON || sz > 0 )
-               {
-               m_takesEvents = formerTakesEvents ;
-                       return GSOCK_NOERROR;
-       }
-       Microseconds(&now); 
+        OTResult state ;
+        OTByteCount sz = 0 ;
+        state = OTGetEndpointState(m_endpoint);
+
+        OTCountDataBytes( m_endpoint , &sz ) ;
+        if ( state == T_INCON || sz > 0 )
+        {
+            m_takesEvents = formerTakesEvents ;
+            return GSOCK_NOERROR;
+        }
+        Microseconds(&now);
     }
     m_takesEvents = formerTakesEvents ;
     m_error = GSOCK_TIMEDOUT;
     }
     m_takesEvents = formerTakesEvents ;
     m_error = GSOCK_TIMEDOUT;
@@ -1502,18 +1505,18 @@ GSocketError GSocket::Output_Timeout()
     Microseconds(&start);
     now = start ;
     m_takesEvents = false ;
     Microseconds(&start);
     now = start ;
     m_takesEvents = false ;
-    
+
     while( (now.hi * 4294967296.0 + now.lo) - (start.hi * 4294967296.0 + start.lo) < m_timeout * 1000.0 )
     {
     while( (now.hi * 4294967296.0 + now.lo) - (start.hi * 4294967296.0 + start.lo) < m_timeout * 1000.0 )
     {
-       OTResult state ;
-               state = OTGetEndpointState(m_endpoint);
-  
-               if ( state == T_DATAXFER || state == T_INREL )
-               {
-               m_takesEvents = formerTakesEvents ;
-                       return GSOCK_NOERROR;
-       }
-       Microseconds(&now); 
+        OTResult state ;
+        state = OTGetEndpointState(m_endpoint);
+
+        if ( state == T_DATAXFER || state == T_INREL )
+        {
+            m_takesEvents = formerTakesEvents ;
+            return GSOCK_NOERROR;
+        }
+        Microseconds(&now);
     }
     m_takesEvents = formerTakesEvents ;
     m_error = GSOCK_TIMEDOUT;
     }
     m_takesEvents = formerTakesEvents ;
     m_error = GSOCK_TIMEDOUT;
@@ -1527,14 +1530,14 @@ GSocketError GSocket::Output_Timeout()
  *   operation, there is still data available, the callback function will
  *   be called again.
  * GSOCK_OUTPUT:
  *   operation, there is still data available, the callback function will
  *   be called again.
  * GSOCK_OUTPUT:
- *   The socket is available for writing. That is, the next write call 
+ *   The socket is available for writing. That is, the next write call
  *   won't block. This event is generated only once, when the connection is
  *   first established, and then only if a call failed with GSOCK_WOULDBLOCK,
  *   when the output buffer empties again. This means that the app should
  *   assume that it can write since the first OUTPUT event, and no more
  *   OUTPUT events will be generated unless an error occurs.
  * GSOCK_CONNECTION:
  *   won't block. This event is generated only once, when the connection is
  *   first established, and then only if a call failed with GSOCK_WOULDBLOCK,
  *   when the output buffer empties again. This means that the app should
  *   assume that it can write since the first OUTPUT event, and no more
  *   OUTPUT events will be generated unless an error occurs.
  * GSOCK_CONNECTION:
- *   Connection succesfully established, for client sockets, or incoming
+ *   Connection successfully established, for client sockets, or incoming
  *   client connection, for server sockets. Wait for this event (also watch
  *   out for GSOCK_LOST) after you issue a nonblocking GSocket_Connect() call.
  * GSOCK_LOST:
  *   client connection, for server sockets. Wait for this event (also watch
  *   out for GSOCK_LOST) after you issue a nonblocking GSocket_Connect() call.
  * GSOCK_LOST:
@@ -1544,18 +1547,19 @@ GSocketError GSocket::Output_Timeout()
 
 void _GSocket_Internal_Proc(unsigned long e , void* d )
 {
 
 void _GSocket_Internal_Proc(unsigned long e , void* d )
 {
-               
-  GSocket * socket = (GSocket*) d ;
-  OTEventCode ev = (OTEventCode) e ;
-  GSocketEvent event;
-  GSocketEvent event2;
-  GSocketCallback cback;
-  char *data;
-  GSocketCallback cback2;
-  char *data2;
-
-       if ( !socket )
-               return ;
+    GSocket *socket = (GSocket*) d ;
+
+    if ( !socket )
+        return ;
+
+    OTEventCode ev = (OTEventCode) e ;
+    GSocketEvent event;
+    GSocketEvent event2;
+    GSocketCallback cback;
+    char *data;
+    GSocketCallback cback2;
+    char *data2;
+
     event = GSOCK_MAX_EVENT ;
     event2 = GSOCK_MAX_EVENT ;
     cback = NULL;
     event = GSOCK_MAX_EVENT ;
     event2 = GSOCK_MAX_EVENT ;
     cback = NULL;
@@ -1567,41 +1571,41 @@ void _GSocket_Internal_Proc(unsigned long e , void* d )
      * destroyed) and for safety, check that the m_endpoint field
      * is what we expect it to be.
      */
      * destroyed) and for safety, check that the m_endpoint field
      * is what we expect it to be.
      */
-    if ((socket != NULL) && (socket->m_takesEvents))
+    if ( /* (socket != NULL) && */ (socket->m_takesEvents))
     {
     {
-       switch (ev)
-       {
-               case T_LISTEN :
-                       event = GSOCK_CONNECTION ;
-                       break ;
-               case T_CONNECT :
-                       event = GSOCK_CONNECTION ;
-                       event2 = GSOCK_OUTPUT ;
-                       {
-                                       TCall retCall;
-                                       
-                                       retCall.addr.buf        = NULL;
-                                       retCall.addr.maxlen     = 0;
-                                       retCall.opt.buf         = NULL;
-                                       retCall.opt.maxlen      = 0;
-                                       retCall.udata.buf       = NULL;
-                                       retCall.udata.maxlen= 0;
-                                       OTRcvConnect( socket->m_endpoint , &retCall ) ;
-                               }
-                       break ;
-               case T_DISCONNECT :
-                       event = GSOCK_LOST ;
-                       break ;
-               case T_GODATA :
-               case T_GOEXDATA :
-                       event = GSOCK_OUTPUT ;
-                       break ;
-               case T_DATA :
-                       event = GSOCK_INPUT ;
-                       break ;
-               case T_EXDATA :
-                       event = GSOCK_INPUT ;
-                       break ;
+        switch (ev)
+        {
+            case T_LISTEN :
+                event = GSOCK_CONNECTION ;
+                break ;
+            case T_CONNECT :
+                event = GSOCK_CONNECTION ;
+                event2 = GSOCK_OUTPUT ;
+                {
+                    TCall retCall;
+
+                    retCall.addr.buf     = NULL;
+                    retCall.addr.maxlen  = 0;
+                    retCall.opt.buf      = NULL;
+                    retCall.opt.maxlen   = 0;
+                    retCall.udata.buf    = NULL;
+                    retCall.udata.maxlen = 0;
+                    OTRcvConnect( socket->m_endpoint , &retCall ) ;
+                }
+                break ;
+            case T_DISCONNECT :
+                event = GSOCK_LOST ;
+                break ;
+            case T_GODATA :
+            case T_GOEXDATA :
+                event = GSOCK_OUTPUT ;
+                break ;
+            case T_DATA :
+                event = GSOCK_INPUT ;
+                break ;
+            case T_EXDATA :
+                event = GSOCK_INPUT ;
+                break ;
       }
       if (event != GSOCK_MAX_EVENT)
       {
       }
       if (event != GSOCK_MAX_EVENT)
       {
wxWidgets (Impactor)