root/lang/objective-cplusplus/i3/trunk/tmp/distant.m @ 36642

// -*- coding: utf-8-dos -*-

#import <Foundation/Foundation.h>
//#import <Appkit/Appkit.h>

#define NUM_THREADS 2

@interface SubTask : NSObject {
@private
    NSNumber* taskNumber;
    SubTask* proxies[NUM_THREADS];
}
- (NSArray*)createConnectionData;
- (oneway void)addNewThread:(NSArray*)data;
- (void)startThread:(NSNumber*)data;
- (oneway void)hello;
@end

SubTask* proxies[NUM_THREADS];

@interface MainTask : NSObject {
}
- (void)addNewThread:(NSArray*)data;
- (void)start;
@end

@implementation MainTask
- (void)start {
    NSAutoreleasePool* pool = [[NSAutoreleasePool alloc] init];
    NS_DURING
    {
        //[NSApplication sharedApplication];


        int task_num = 0;
        for (task_num = 0; task_num < NUM_THREADS; task_num++) {
            proxies[task_num] = nil;
        }        

        for (task_num = 0; task_num < NUM_THREADS; task_num++) {
            NSNumber* taskNumber = [[NSNumber numberWithInt:task_num] retain];
            SubTask* task = [[[SubTask alloc] init] retain];
            [NSThread detachNewThreadSelector:@selector(startThread:)
                      toTarget:task
                      withObject:taskNumber];
        }

        [[NSRunLoop currentRunLoop] runUntilDate:[NSDate dateWithTimeIntervalSinceNow:5]];
    }
    NS_HANDLER
    {
        NSLog(@"Exception name=[%s] reason=[%s]\n",
              [[localException name] UTF8String],
              [[localException reason] UTF8String]);
    }
    NS_ENDHANDLER;
    [pool release];
}


- (void)addNewThread:(NSArray*)data {
    NSNumber* taskNumber = [data objectAtIndex:0];
    NSPort* port1 = [data objectAtIndex:1];
    NSPort* port2 = [data objectAtIndex:2];

    int task_num = [taskNumber intValue];
    NSConnection* connection = [NSConnection connectionWithReceivePort:port2
                                                           sendPort:port1];
    [connection retain];

    proxies[task_num] = [(SubTask*)[[connection rootProxy] retain] retain];

    int i = 0;
    for (i = 0; i < NUM_THREADS; i++) {
        if (i == task_num) {
            continue;
        }
        if (proxies[i] == nil) {
            continue;
        }

        NSArray* newData = [proxies[task_num] createConnectionData];

        NS_DURING
        {
            [proxies[i] addNewThread:newData];
        }
        NS_HANDLER
        {
            NSLog(@"Exception name=[%s] reason=[%s]\n",
                  [[localException name] UTF8String],
                  [[localException reason] UTF8String]);
        }
        NS_ENDHANDLER;

    }
}
@end

MainTask* mainTask = nil;

@implementation SubTask

- (oneway void)hello {
    NSLog(@"hello");
}

- (oneway void)addNewThread:(NSArray*)data {
    NSNumber* subTaskNumber = [data objectAtIndex:0];
    int sub_task_num = [subTaskNumber intValue];
    NSLog(@"a");
    NSPort* port1 = [data objectAtIndex:1];
    NSLog(@"b");
    NSPort* port2 = [data objectAtIndex:2];
    NSLog(@"c");
    NSConnection* connection = [NSConnection connectionWithReceivePort:port2
                                                              sendPort:port1];
    [connection retain];
    NSLog(@"d");

    proxies[sub_task_num] = [(SubTask*)[[connection rootProxy] retain] retain];
    NSLog(@"e");

    int i = 0;
    for (i = 0; i < NUM_THREADS; i++) {
        if (proxies[i] == nil) {
            NSLog(@"f");
            continue;
        }
        NSLog(@"g");
        [proxies[i] hello];
    }
    NSLog(@"h");
}

- (NSArray*)createConnectionData {
    [[taskNumber retain] retain];

    NSPort* port1 = [NSPort port];
    NSPort* port2 = [NSPort port];
    [[port1 retain] retain];
    [[port2 retain] retain];

    if (port1 == nil || port2 == nil) {
        NSLog(@"XXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXX");
    }

    NSConnection *serverConnection =
        [[NSConnection alloc] initWithReceivePort:port1
                                         sendPort:port2];
    [[serverConnection retain] retain];
    [serverConnection setRootObject:self];

    NSArray* data = [NSArray arrayWithObjects:taskNumber, port1, port2, nil];
    [[data retain] retain];
    return data;
}

- (void)startThread:(NSNumber*)taskNumber_ {
    NSAutoreleasePool* pool = [[NSAutoreleasePool alloc] init];

    NS_DURING
    {
        int i = 0;
        for (i = 0; i < NUM_THREADS; i++) {
            proxies[i] = nil;
        }

        taskNumber = taskNumber_;

        NSArray* data = [self createConnectionData];
        [[data retain] retain];
        
        @synchronized (mainTask) {
            [mainTask performSelectorOnMainThread:@selector(addNewThread:)
                      withObject:data
                      waitUntilDone:NO];
        }

        [[NSRunLoop currentRunLoop] run];
    }  
    NS_HANDLER
    {
        NSLog(@"Exception name=[%s] reason=[%s]\n",
              [[localException name] UTF8String],
              [[localException reason] UTF8String]);
    }
    NS_ENDHANDLER;
       

    [pool release];
}
@end

int main() {
    fputs("main()\n", stderr);

    NSAutoreleasePool* pool = [[NSAutoreleasePool alloc] init];
    NS_DURING
    {
        mainTask = [[MainTask alloc] init];
        [mainTask start];
        [mainTask release];
    }
    NS_HANDLER
    {
        NSLog(@"Exception name=[%s] reason=[%s]\n",
              [[localException name] UTF8String],
              [[localException reason] UTF8String]);
    }
    NS_ENDHANDLER;
    [pool release];
     
    fputs("main() return\n", stderr);
    return 0;
}