redraw forced for size changes (layout for measuring is simpler than word-wrapping...

[wxWidgets.git] / src / mac / gsocket.c

diff --git a/src/mac/gsocket.c b/src/mac/gsocket.c
index ed895445f299e67b7e11378f8063caf8ea58e048..9e3ba3079a4c3e75ef5dc34ed064c596d7ef37a8 100644 (file)
--- a/src/mac/gsocket.c
+++ b/src/mac/gsocket.c
@@ -15,11 +15,12 @@
 
 #ifndef __GSOCKET_STANDALONE__
 #include "wx/setup.h"
 
 #ifndef __GSOCKET_STANDALONE__
 #include "wx/setup.h"

+#include "wx/platform.h"

 #endif
 
 #if wxUSE_SOCKETS || defined(__GSOCKET_STANDALONE__)
 
 #endif
 
 #if wxUSE_SOCKETS || defined(__GSOCKET_STANDALONE__)
 

-#ifdef __UNIX__
+#ifdef __DARWIN__

   #include <CoreServices/CoreServices.h>
 
   #ifndef FALSE
   #include <CoreServices/CoreServices.h>
 
   #ifndef FALSE


@@ -29,12 +30,13 @@
     #define TRUE 1
   #endif
 #else
     #define TRUE 1
   #endif
 #else

+  #include <MacHeaders.c>

   #define OTUNIXERRORS 1
   #include <OpenTransport.h>
   #include <OpenTransportProviders.h>
   #include <OpenTptInternet.h>
 #endif
   #define OTUNIXERRORS 1
   #include <OpenTransport.h>
   #include <OpenTransportProviders.h>
   #include <OpenTptInternet.h>
 #endif

-#if TARGET_CARBON
+#if TARGET_CARBON && !defined(OTAssert)

   #define OTAssert( str , cond ) /* does not exists in Carbon */
 #endif
 
   #define OTAssert( str , cond ) /* does not exists in Carbon */
 #endif
 


@@ -80,11 +82,12 @@ void wxCYield() ;
 #define qDebug2 1
 extern pascal void OTDebugStr(const char* str);
 #endif
 #define qDebug2 1
 extern pascal void OTDebugStr(const char* str);
 #endif

-#ifndef __UNIX__
+#ifndef __DARWIN__

   #include <OTDebug.h>
 #endif
 InetSvcRef gInetSvcRef = 0 ;
   #include <OTDebug.h>
 #endif
 InetSvcRef gInetSvcRef = 0 ;

-
+int gOTInited = 0 ;
+OTNotifyUPP gOTNotifierUPP = NULL ;

 
 OSStatus DoNegotiateIPReuseAddrOption(EndpointRef ep, Boolean enableReuseIPMode);
 
 
 OSStatus DoNegotiateIPReuseAddrOption(EndpointRef ep, Boolean enableReuseIPMode);
 


@@ -121,7 +124,7 @@ OSStatus DoNegotiateIPReuseAddrOption(EndpointRef ep, Boolean enableReuseIPMode)
        ret.opt.maxlen = kOTFourByteOptionSize;
 
        opt->level      = INET_IP;                                      // dealing with an IP Level function
        ret.opt.maxlen = kOTFourByteOptionSize;
 
        opt->level      = INET_IP;                                      // dealing with an IP Level function

-#ifdef __UNIX__
+#ifdef __DARWIN__

        opt->name       = kIP_REUSEADDR;
 #else
        opt->name       = IP_REUSEADDR;
        opt->name       = kIP_REUSEADDR;
 #else
        opt->name       = IP_REUSEADDR;


@@ -183,7 +186,7 @@ static void SetDefaultEndpointModes(EndpointRef ep , void *data )
        junk = OTSetBlocking(ep);
        OTAssert("SetDefaultEndpointModes: Could not set blocking", junk == noErr);
 */
        junk = OTSetBlocking(ep);
        OTAssert("SetDefaultEndpointModes: Could not set blocking", junk == noErr);
 */

-       junk = OTInstallNotifier(ep, OTInetEventHandler, data);
+       junk = OTInstallNotifier(ep, gOTNotifierUPP, data);

        OTAssert("SetDefaultEndpointModes: Could not install notifier", junk == noErr);
 /*
        junk = OTUseSyncIdleEvents(ep, true);
        OTAssert("SetDefaultEndpointModes: Could not install notifier", junk == noErr);
 /*
        junk = OTUseSyncIdleEvents(ep, true);


@@ -193,41 +196,76 @@ static void SetDefaultEndpointModes(EndpointRef ep , void *data )
 
 /* Global initialisers */
 
 
 /* Global initialisers */
 

+void GSocket_SetGUIFunctions(struct GSocketGUIFunctionsTable *table)
+{
+    // do nothing, wxMac doesn't have wxBase-GUI separation yet
+}
+

 int GSocket_Init()
 {
 int GSocket_Init()
 {

-       OSStatus err ;
+    return TRUE;
+}
+
+int GSocket_Verify_Inited() ;
+int GSocket_Verify_Inited()
+{
+    OSStatus err ;

 #if TARGET_CARBON
 #if TARGET_CARBON

-       InitOpenTransportInContext( kInitOTForApplicationMask , NULL ) ;
+    // Marc Newsam: added the clientcontext variable
+    //              however, documentation is unclear how this works
+    OTClientContextPtr clientcontext;
+
+    if ( gInetSvcRef )
+      return TRUE ;
+
+    InitOpenTransportInContext(kInitOTForApplicationMask, &clientcontext);
+    gOTInited = 1 ;
+    gInetSvcRef = OTOpenInternetServicesInContext(kDefaultInternetServicesPath,
+                                               NULL, &err, clientcontext);

 #else  
 #else  

-       InitOpenTransport() ;
+    if ( gInetSvcRef )
+      return TRUE ;
+ 
+    InitOpenTransport() ;
+    gOTInited = 1 ;
+    gInetSvcRef = OTOpenInternetServices(kDefaultInternetServicesPath, NULL, &err);

 #endif
 #endif

-       gInetSvcRef = OTOpenInternetServices(kDefaultInternetServicesPath, NULL, &err);
-       if ( gInetSvcRef == NULL ||  err != kOTNoError )
-       {
-               OTAssert("Could not open Inet Services", err == noErr);
-               return FALSE ;
-       }
-  return TRUE;
+    if ( gInetSvcRef == NULL ||  err != kOTNoError )
+    {
+       OTAssert("Could not open Inet Services", err == noErr);
+       return FALSE ;
+    }
+    gOTNotifierUPP = NewOTNotifyUPP( OTInetEventHandler ) ;
+    return TRUE ;

 }
 
 void GSocket_Cleanup()
 {
 }
 
 void GSocket_Cleanup()
 {

-  if ( gInetSvcRef != NULL )
-       OTCloseProvider( gInetSvcRef );
-#if TARGET_CARBON
-  CloseOpenTransportInContext( NULL ) ;
-#else
-  CloseOpenTransport() ;
-#endif
+    if ( gOTInited != 0 )
+    {
+      if ( gInetSvcRef != NULL )
+       OTCloseProvider( gInetSvcRef );
+    #if TARGET_CARBON
+      CloseOpenTransportInContext( NULL ) ;
+    #else
+      CloseOpenTransport() ;
+    #endif
+        if ( gOTNotifierUPP )
+            DisposeOTNotifyUPP( gOTNotifierUPP ) ;
+    }

 }
 
 /* Constructors / Destructors for GSocket */
 
 GSocket *GSocket_new()
 {
 }
 
 /* Constructors / Destructors for GSocket */
 
 GSocket *GSocket_new()
 {

+     

   int i;
   GSocket *socket;
 
   int i;
   GSocket *socket;
 

+ if ( GSocket_Verify_Inited() == FALSE )
+    return NULL ;
+

   socket = (GSocket *)malloc(sizeof(GSocket));
 
   if (socket == NULL)
   socket = (GSocket *)malloc(sizeof(GSocket));
 
   if (socket == NULL)


@@ -245,8 +283,8 @@ GSocket *GSocket_new()
   socket->m_server              = FALSE;
   socket->m_stream              = TRUE;
   socket->m_non_blocking        = FALSE;
   socket->m_server              = FALSE;
   socket->m_stream              = TRUE;
   socket->m_non_blocking        = FALSE;

-  socket->m_timeout             = 10*60*1000;
-                                /* 10 minutes * 60 sec * 1000 millisec */
+  socket->m_timeout             = 1*1000;
+                                /* 10 sec * 1000 millisec */

   socket->m_takesEvents                        = TRUE ;
   socket->m_mac_events                 = wxMacGetNotifierTable() ;
   return socket;
   socket->m_takesEvents                        = TRUE ;
   socket->m_mac_events                 = wxMacGetNotifierTable() ;
   return socket;


@@ -444,9 +482,6 @@ GAddress *GSocket_GetPeer(GSocket *socket)
  */
 GSocketError GSocket_SetServer(GSocket *sck)
 {
  */
 GSocketError GSocket_SetServer(GSocket *sck)
 {

-  int type;
-  int arg = 1;
-

   assert(sck != NULL);
 
   /* must not be in use */
   assert(sck != NULL);
 
   /* must not be in use */


@@ -516,9 +551,6 @@ GSocketError GSocket_SetServer(GSocket *sck)
 GSocket *GSocket_WaitConnection(GSocket *socket)
 {
   GSocket *connection = NULL ;
 GSocket *GSocket_WaitConnection(GSocket *socket)
 {
   GSocket *connection = NULL ;

-  GSocketError err;
-
-  int arg = 1;

 
   assert(socket != NULL);
 
 
   assert(socket != NULL);
 


@@ -611,8 +643,6 @@ GSocket *GSocket_WaitConnection(GSocket *socket)
  */
 GSocketError GSocket_SetNonOriented(GSocket *sck)
 {
  */
 GSocketError GSocket_SetNonOriented(GSocket *sck)
 {

-  int arg = 1;
-

   assert(sck != NULL);
 
   if (sck->m_endpoint != kOTInvalidEndpointRef )
   assert(sck != NULL);
 
   if (sck->m_endpoint != kOTInvalidEndpointRef )


@@ -697,12 +727,9 @@ GSocketError GSocket_SetNonOriented(GSocket *sck)
  */
 GSocketError GSocket_Connect(GSocket *sck, GSocketStream stream)
 {
  */
 GSocketError GSocket_Connect(GSocket *sck, GSocketStream stream)
 {

-  int ret;
-  int arg = 1;

   InetAddress addr ;
   TEndpointInfo        info;
   InetAddress addr ;
   TEndpointInfo        info;

-  OTFlags flags = 0;
-  OSStatus             err = kOTNoError;
+   OSStatus            err = kOTNoError;

   TCall peer ;
 
   assert(sck != NULL);
   TCall peer ;
 
   assert(sck != NULL);


@@ -903,7 +930,6 @@ int GSocket_Write(GSocket *socket, const char *buffer, int size)
  */
 GSocketEventFlags GSocket_Select(GSocket *socket, GSocketEventFlags flags)
 {
  */
 GSocketEventFlags GSocket_Select(GSocket *socket, GSocketEventFlags flags)
 {

-  OTResult     state ;

   assert(socket != NULL);
   wxMacProcessNotifierEvents() ;
   /*
   assert(socket != NULL);
   wxMacProcessNotifierEvents() ;
   /*


@@ -952,7 +978,9 @@ void GSocket_SetTimeout(GSocket *socket, unsigned long millisec)
 {
   assert(socket != NULL);
 
 {
   assert(socket != NULL);
 

-  socket->m_timeout = millisec;
+//  this is usually set too high and we have not yet been able to detect a closed
+//  stream, thus we leave the 10 sec timeout
+//  socket->m_timeout = millisec;

 }
 
 /* GSocket_GetError:
 }
 
 /* GSocket_GetError:


@@ -1048,6 +1076,8 @@ int _GSocket_Recv_Stream(GSocket *socket, char *buffer, int size)
        OTByteCount sz = 0 ;
 
        OTCountDataBytes( socket->m_endpoint , &sz ) ;
        OTByteCount sz = 0 ;
 
        OTCountDataBytes( socket->m_endpoint , &sz ) ;

+       if ( size > (int)sz )
+         size = sz ;

        res = OTRcv( socket->m_endpoint , buffer , size , &flags ) ;
        if ( res < 0 )
        {
        res = OTRcv( socket->m_endpoint , buffer , size , &flags ) ;
        if ( res < 0 )
        {


@@ -1243,6 +1273,8 @@ 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() == FALSE )
+    return GSOCK_IOERR ;

   memset(addr, 0 , sizeof(struct InetAddress));
   OTInitInetAddress( addr , address->m_port , address->m_host ) ;
   return GSOCK_NOERROR;
   memset(addr, 0 , sizeof(struct InetAddress));
   OTInitInetAddress( addr , address->m_port , address->m_host ) ;
   return GSOCK_NOERROR;


@@ -1267,6 +1299,9 @@ GSocketError GAddress_INET_SetHostName(GAddress *address, const char *hostname)
   InetHostInfo hinfo ;
   OSStatus ret ;
 
   InetHostInfo hinfo ;
   OSStatus ret ;
 

+ if ( GSocket_Verify_Inited() == FALSE )
+    return GSOCK_IOERR ;
+

   assert(address != NULL);
 
   CHECK_ADDRESS(address, INET, GSOCK_INVADDR);
   assert(address != NULL);
 
   CHECK_ADDRESS(address, INET, GSOCK_INVADDR);


@@ -1289,8 +1324,6 @@ GSocketError GAddress_INET_SetAnyAddress(GAddress *address)
 GSocketError GAddress_INET_SetHostAddress(GAddress *address,
                                           unsigned long hostaddr)
 {
 GSocketError GAddress_INET_SetHostAddress(GAddress *address,
                                           unsigned long hostaddr)
 {

-  struct in_addr *addr;
-

   assert(address != NULL);
 
   CHECK_ADDRESS(address, INET, GSOCK_INVADDR);
   assert(address != NULL);
 
   CHECK_ADDRESS(address, INET, GSOCK_INVADDR);


@@ -1316,8 +1349,7 @@ service_entry gServices[] =
 GSocketError GAddress_INET_SetPortName(GAddress *address, const char *port,
                                        const char *protocol)
 {
 GSocketError GAddress_INET_SetPortName(GAddress *address, const char *port,
                                        const char *protocol)
 {

-  InetAddress *addr;
-  int i ;
+  size_t i ;

 
   assert(address != NULL);
   CHECK_ADDRESS(address, INET, GSOCK_INVADDR);
 
   assert(address != NULL);
   CHECK_ADDRESS(address, INET, GSOCK_INVADDR);


@@ -1351,8 +1383,6 @@ GSocketError GAddress_INET_SetPortName(GAddress *address, const char *port,
 
 GSocketError GAddress_INET_SetPort(GAddress *address, unsigned short port)
 {
 
 GSocketError GAddress_INET_SetPort(GAddress *address, unsigned short port)
 {

-  InetAddress *addr;
-

   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 ;


@@ -1363,6 +1393,8 @@ GSocketError GAddress_INET_SetPort(GAddress *address, unsigned short port)
 GSocketError GAddress_INET_GetHostName(GAddress *address, char *hostname, size_t sbuf)
 {
   InetDomainName name ;
 GSocketError GAddress_INET_GetHostName(GAddress *address, char *hostname, size_t sbuf)
 {
   InetDomainName name ;

+ if ( GSocket_Verify_Inited() == FALSE )
+    return GSOCK_IOERR ;

   
   assert(address != NULL); 
   CHECK_ADDRESS(address, INET, GSOCK_INVADDR);
   
   assert(address != NULL); 
   CHECK_ADDRESS(address, INET, GSOCK_INVADDR);


@@ -1440,7 +1472,7 @@ GSocketError _GSocket_Input_Timeout(GSocket *socket)
     {
        OTResult state ;
                OTByteCount sz = 0 ;
     {
        OTResult state ;
                OTByteCount sz = 0 ;

-               state = OTGetEndpointState(socket->m_endpoint);
+                 state = OTGetEndpointState(socket->m_endpoint);

   
                OTCountDataBytes( socket->m_endpoint , &sz ) ;
                if ( state == T_INCON || sz > 0 )
   
                OTCountDataBytes( socket->m_endpoint , &sz ) ;
                if ( state == T_INCON || sz > 0 )


@@ -1610,10 +1642,12 @@ void _GSocket_Internal_Proc(unsigned long e , void* d )
 /* Hack added for Mac OS X */
 GSocketError GAddress_UNIX_GetPath(GAddress *addr, char *path, size_t buf)
 {
 /* Hack added for Mac OS X */
 GSocketError GAddress_UNIX_GetPath(GAddress *addr, char *path, size_t buf)
 {

+    return GSOCK_INVADDR;

 }
 
 GSocketError GAddress_UNIX_SetPath(GAddress *addr, const char *path)
 {
 }
 
 GSocketError GAddress_UNIX_SetPath(GAddress *addr, const char *path)
 {

+    return GSOCK_INVADDR;

 }
 
 #endif  /* wxUSE_SOCKETS || defined(__GSOCKET_STANDALONE__) */
 }
 
 #endif  /* wxUSE_SOCKETS || defined(__GSOCKET_STANDALONE__) */