* Adium is the legal property of its developers, whose names are listed in the copyright file included * with this source distribution. * This program is free software; you can redistribute it and/or modify it under the terms of the GNU * General Public License as published by the Free Software Foundation; either version 2 of the License, * or (at your option) any later version. * This program is distributed in the hope that it will be useful, but WITHOUT ANY WARRANTY; without even * the implied warranty of MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU General * Public License for more details. * You should have received a copy of the GNU General Public License along with this program; if not, * write to the Free Software Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA. #import "adiumPurpleEventloop.h" #include <dispatch/dispatch.h> // This one is missing from the 10.6 headers... #define NSEC_PER_MSEC (NSEC_PER_SEC / 1000) //#define PURPLE_SOCKET_DEBUG static guint sourceId = 0; //The next source key; continuously incrementing * glib, unfortunately, identifies all sources and timers via unsigned 32 bit tags. We would like to map them to dispatch_source_t objects. * So: we make a CFDictionary with all null callbacks (hash on the value of the integer, cast to a void*, and don't retain/release anything). * That gives us a guint->dispatch_source_t map, but it's a little gross, so three inline wrapper functions are provided to make things nice: * sourceForTag, setSourceForTag, and removeSourceForTag. The names should be self-explanatory. No retains or releases are done by them. static inline CFMutableDictionaryRef sourceInfoDict() { static CFMutableDictionaryRef _sourceInfoDict; static dispatch_once_t sourceInfoDictToken; dispatch_once(&sourceInfoDictToken, ^{ static const CFDictionaryKeyCallBacks keyCallbacks = {0, NULL, NULL, NULL, NULL, NULL}; static const CFDictionaryValueCallBacks valueCallbacks = {0, NULL, NULL, NULL, NULL}; _sourceInfoDict = CFDictionaryCreateMutable(kCFAllocatorDefault, 0, &keyCallbacks, &valueCallbacks); static inline dispatch_source_t sourceForTag(guint tag) { return (dispatch_source_t)CFDictionaryGetValue(sourceInfoDict(), (void *)tag); static inline void setSourceForTag(dispatch_source_t source, guint tag) { CFDictionarySetValue(sourceInfoDict(), (void *)tag, source); static inline void removeSourceForTag(guint tag) { CFDictionaryRemoveValue(sourceInfoDict(), (void *)tag); gboolean adium_source_remove(guint tag) { dispatch_source_t src = sourceForTag(tag); AILogWithSignature(@"Source info for %i not found", tag); dispatch_source_cancel(src); BOOL success = (dispatch_source_testcancel(src) != 0); //Like g_source_remove, return TRUE if successful, FALSE if not gboolean adium_timeout_remove(guint tag) { return adium_source_remove(tag); /* Extra function to generalize adium_timeout_add and adium_timeout_add_seconds, * making the permitted leeway explicit. guint addTimer(uint64_t interval, uint64_t leeway, GSourceFunc function, gpointer data) src = dispatch_source_create(DISPATCH_SOURCE_TYPE_TIMER, 0, 0, dispatch_get_main_queue()); dispatch_source_set_timer(src, dispatch_time(DISPATCH_TIME_NOW, interval), interval, leeway); setSourceForTag(src, tag); dispatch_source_set_event_handler(src, ^{ NSAutoreleasePool *pool = [[NSAutoreleasePool alloc] init]; if (!function || !function(data)) { adium_timeout_remove(tag); AILogWithSignature(@"Timer with tag %i was already canceled!", tag); // Add a timer in miliseconds guint adium_timeout_add(guint interval, GSourceFunc function, gpointer data) return addTimer(((uint64_t)interval) * NSEC_PER_MSEC, NSEC_PER_USEC, function, data); // Add a timer in seconds (allowing more leeway, therefore allowing the OS to group events and save power) guint adium_timeout_add_seconds(guint interval, GSourceFunc function, gpointer data) return addTimer(((uint64_t)interval) * NSEC_PER_SEC, NSEC_PER_SEC, function, data); guint adium_input_add(gint fd, PurpleInputCondition condition, PurpleInputFunction func, gpointer user_data) NSLog(@"INVALID: fd was %i; returning tag %i",fd,sourceId+1); dispatch_source_type_t type; if (condition == PURPLE_INPUT_READ) { type = DISPATCH_SOURCE_TYPE_READ; type = DISPATCH_SOURCE_TYPE_WRITE; src = dispatch_source_create(type, fd, 0, dispatch_get_main_queue()); dispatch_source_set_event_handler(src, ^{ NSAutoreleasePool *pool = [[NSAutoreleasePool alloc] init]; if (func) func(user_data, fd, condition); setSourceForTag(src, tag); int adium_input_get_error(int fd, int *error) ret = getsockopt(fd, SOL_SOCKET, SO_ERROR, error, &len); * Taken from Fire's FaimP2PConnection.m: * The job of this function is to detect if the connection failed or not * There has to be a better way to do this * Any socket that fails to connect will select for reading and writing * and all reads and writes will fail * Any listening socket will select for reading, and any read will fail * So, select for writing, if you can write, and the write fails, not connected select(fd+1, NULL, &thisfd, NULL, &timeout); if(FD_ISSET(fd, &thisfd)){ char buffer[4] = {0, 0, 0, 0}; length = write(fd, buffer, length); AILog(@"adium_input_get_error(%i): Socket is NOT valid", fd); static PurpleEventLoopUiOps adiumEventLoopUiOps = { adium_timeout_add_seconds, /* _purple_reserved2 */ NULL, /* _purple_reserved3 */ NULL, /* _purple_reserved4 */ NULL PurpleEventLoopUiOps *adium_purple_eventloop_get_ui_ops(void) return &adiumEventLoopUiOps;
