/* -------------------------------------------------------------------------
- * Project: GSocket (Generic Socket) for WX
- * Name: gsockosx.c
- * Purpose: GSocket: Mac OS X mach-o part
- * CVSID: $Id$
+ * Project: GSocket (Generic Socket) for WX
+ * Name: gsockosx.c
+ * Copyright: (c) Brian Victor
+ * Licence: wxWindows Licence
+ * Purpose: GSocket: Mac OS X mach-o part
+ * CVSID: $Id$
* Mac code by Brian Victor, February 2002. Email comments to bhv1@psu.edu
* ------------------------------------------------------------------------- */
CFRunLoopSourceRef source;
};
+// Sockets must use the event loop on the main thread
+// We will store the main loop's reference when Initialize is called
+static CFRunLoopRef s_mainRunLoop = NULL;
+
void Mac_Socket_Callback(CFSocketRef s, CFSocketCallBackType callbackType,
CFDataRef address, const void* data, void* info)
{
bool GSocketGUIFunctionsTableConcrete::OnInit(void)
{
+ // No need to store the main loop again
+ if (s_mainRunLoop != NULL)
+ return true;
+
+ // Get the loop for the main thread so our events will actually fire.
+ // The common socket.cpp code will assert if initialize is called from a
+ // secondary thread, otherwise Mac would have the same problems as MSW
+ s_mainRunLoop = CFRunLoopGetCurrent();
+ CFRetain(s_mainRunLoop);
+
return true;
}
void GSocketGUIFunctionsTableConcrete::OnExit(void)
{
+ // Release the reference count, and set the reference back to NULL
+ CFRelease(s_mainRunLoop);
+ s_mainRunLoop = NULL;
}
bool GSocketGUIFunctionsTableConcrete::Init_Socket(GSocket *socket)
struct MacGSocketData* data = _GSocket_Get_Mac_Socket(socket);
if (!data) return;
- CFRunLoopAddSource(CFRunLoopGetCurrent(), data->source, kCFRunLoopCommonModes);
+ CFRunLoopAddSource(s_mainRunLoop, data->source, kCFRunLoopCommonModes);
}
void GSocketGUIFunctionsTableConcrete::Disable_Events(GSocket *socket)
if (!data) return;
/* CFSocketInvalidate does CFRunLoopRemoveSource anyway */
- CFRunLoopRemoveSource(CFRunLoopGetCurrent(), data->source, kCFRunLoopCommonModes);
+ CFRunLoopRemoveSource(s_mainRunLoop, data->source, kCFRunLoopCommonModes);
CFSocketInvalidate(data->socket);
}