/*
 * InterThreadMessaging -- InterThreadMessaging.m
 * Created by toby on Tue Jun 19 2001.
 */

#if (defined(TARGET_OS_IPHONE) && TARGET_OS_IPHONE) || (defined(MAC_OS_X_VERSION_MIN_REQUIRED) && MAC_OS_X_VERSION_MIN_REQUIRED >= 1060)
#define ALWAYS_HAS_SYSTEM_SUPPORT 1
#else
#define ALWAYS_HAS_SYSTEM_SUPPORT 0
#endif

#import "InterThreadMessaging.h"

#import "MVUtilities.h"

#if !ALWAYS_HAS_SYSTEM_SUPPORT
@interface NSObject (ThreadPerformAdditions)
- (void) performSelector:(SEL) selector onThread:(NSThread *) thread withObject:(id) object waitUntilDone:(BOOL) wait;
@end
#endif

MVInline BOOL useSystemThreadPerformSelector() {
#if ALWAYS_HAS_SYSTEM_SUPPORT
	return YES;
#else
	static BOOL useSystemVersion = NO;
	static BOOL checkedSystem = NO;

	if( ! checkedSystem ) {
		useSystemVersion = [NSObject instancesRespondToSelector:@selector(performSelector:onThread:withObject:waitUntilDone:)];
		checkedSystem = YES;
	}

	return useSystemVersion;
#endif
}

#if !ALWAYS_HAS_SYSTEM_SUPPORT

#import <pthread.h>

typedef struct InterThreadMessage {
	SEL selector;
	id receiver;
	id arg;
} InterThreadMessage;

static NSMapTable *pThreadMessagePorts = NULL;
static pthread_mutex_t pGate;

@interface InterThreadManager : NSObject
+ (void) threadDied:(NSNotification *)notification;
+ (void) handlePortMessage:(NSPortMessage *)msg;
@end

static void createMessagePortForThread(NSThread *thread, NSRunLoop *runLoop) {
	pthread_mutex_lock(&pGate);

	NSPort *port = NSMapGet(pThreadMessagePorts, thread);
	if( ! port ) {
		id <NSMachPortDelegate> delegate = (id)[InterThreadManager class];

		port = [[NSPort alloc] init];
		[port setDelegate:delegate];
		[port scheduleInRunLoop:runLoop forMode:NSDefaultRunLoopMode];

		NSMapInsertKnownAbsent(pThreadMessagePorts, thread, port);
		[port release];
	}

	pthread_mutex_unlock(&pGate);
}

static NSPort *messagePortForThread(NSThread *thread) {
	pthread_mutex_lock(&pGate);
	NSPort *port = NSMapGet(pThreadMessagePorts, thread);
	pthread_mutex_unlock(&pGate);

	if( ! port ) [NSException raise:NSInvalidArgumentException format:@"Thread %@ is not prepared to receive inter-thread messages. You must invoke +prepareForInterThreadMessages first.", thread];

	return port;
}

static void removeMessagePortForThread(NSThread *thread) {
	pthread_mutex_lock(&pGate);

	NSPort *port = (NSPort *) NSMapGet(pThreadMessagePorts, thread);
	if (port) {
		[port invalidate];
		NSMapRemove(pThreadMessagePorts, thread);
	}

	pthread_mutex_unlock(&pGate);
}

#endif

@implementation NSThread (InterThreadMessaging)
+ (void) prepareForInterThreadMessages {
#if !ALWAYS_HAS_SYSTEM_SUPPORT
	if(useSystemThreadPerformSelector())
		return;
	[InterThreadManager class]; // Force the class initialization.
	createMessagePortForThread([NSThread currentThread], [NSRunLoop currentRunLoop]);
#endif
}
@end

#if !ALWAYS_HAS_SYSTEM_SUPPORT

@implementation InterThreadManager
+ (void) initialize {
	if(useSystemThreadPerformSelector())
		return;
	if( ! pThreadMessagePorts ) {
		pthread_mutex_init(&pGate, NULL);
		pThreadMessagePorts = NSCreateMapTable(NSNonRetainedObjectMapKeyCallBacks, NSObjectMapValueCallBacks, 0);
		[[NSNotificationCenter defaultCenter] addObserver:[self class] selector:@selector(threadDied:) name:NSThreadWillExitNotification object:nil];
	}
}

+ (void) threadDied:(NSNotification *)notification {
	removeMessagePortForThread([notification object]);
}

+ (void) handlePortMessage:(NSPortMessage *)portMessage {
	NSArray *components = [portMessage components];
	NSData *data = [components objectAtIndex:0];
	InterThreadMessage *msg = *((InterThreadMessage **) [data bytes]);

	[msg->receiver performSelector:msg->selector withObject:msg->arg];

	[msg->receiver release];
	[msg->arg release];

	free(msg);
}
@end

#endif

MVInline void performSelector(SEL selector, id receiver, id object, NSThread *thread, BOOL wait) {
	if( ! thread || [thread isEqual:[NSThread currentThread]] ) {
		[receiver performSelector:selector withObject:object];
		return;
	}

	if(useSystemThreadPerformSelector()) {
		[receiver performSelector:selector onThread:thread withObject:object waitUntilDone:wait];
		return;
	}

#if !ALWAYS_HAS_SYSTEM_SUPPORT
	InterThreadMessage *msg = (InterThreadMessage *)malloc(sizeof(struct InterThreadMessage));
	bzero(msg, sizeof(struct InterThreadMessage));

	msg->selector = selector;
	msg->receiver = [receiver retain];
	msg->arg = [object retain];

	NSPort *port = messagePortForThread(thread);
	NSData *data = [[NSData alloc] initWithBytes:&msg length:sizeof(void *)];
	NSMutableArray *components = [[NSMutableArray alloc] initWithObjects:&data count:1];
	NSPortMessage *portMessage = [[NSPortMessage alloc] initWithSendPort:port receivePort:nil components:components];

	[portMessage sendBeforeDate:[NSDate distantFuture]];

	[portMessage release];
	[components release];
	[data release];
#endif
}

@implementation NSObject (InterThreadMessaging)
- (void) performSelector:(SEL)selector inThread:(NSThread *)thread {
	performSelector(selector, self, nil, thread, YES);
}

- (void) performSelector:(SEL)selector inThread:(NSThread *)thread waitUntilDone:(BOOL)wait {
	performSelector(selector, self, nil, thread, wait);
}

- (void) performSelector:(SEL)selector withObject:(id)object inThread:(NSThread *)thread {
	performSelector(selector, self, object, thread, YES);
}

- (void) performSelector:(SEL)selector withObject:(id)object inThread:(NSThread *)thread waitUntilDone:(BOOL)wait {
	performSelector(selector, self, object, thread, wait);
}
@end