blob: 05b4abf25ae9fa28f562d80622457d8981bfe1fd (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
|
// **********************************************************************
//
// Copyright (c) 2003-2016 ZeroC, Inc. All rights reserved.
//
// This copy of Ice is licensed to you under the terms described in the
// ICE_LICENSE file included in this distribution.
//
// **********************************************************************
#import <objc/Ice/DispatchInterceptor.h>
#import <Request.h>
#import <Foundation/NSThread.h>
#import <Foundation/NSInvocation.h>
@implementation ICEDispatchInterceptor
-(BOOL) dispatch__:(ICECurrent*)current is:(id<ICEInputStream>)is os:(id<ICEOutputStream>)os
{
ICERequest* request = [ICERequest request:current is:is os:os];
id<ICEDispatchInterceptor> dispatchInterceptor = (id<ICEDispatchInterceptor>)self;
return [dispatchInterceptor dispatch:request];
}
@end
@implementation ICEMainThreadDispatch
-(id)init:(ICEObject*)s
{
servant = [s retain];
return self;
}
+(id)mainThreadDispatch:(ICEObject*)s
{
return [[[self alloc] init:s] autorelease];
}
-(BOOL) dispatch:(id<ICERequest>)request
{
SEL selector = @selector(ice_dispatch:);
NSMethodSignature* sig = [[servant class] instanceMethodSignatureForSelector:selector];
NSInvocation* inv = [NSInvocation invocationWithMethodSignature:sig];
[inv setTarget:servant];
[inv setSelector:selector];
[inv setArgument:&request atIndex:2];
[inv performSelectorOnMainThread:@selector(invokeWithTarget:) withObject:servant waitUntilDone:YES];
BOOL status;
[inv getReturnValue:&status];
return status;
}
-(void)dealloc
{
[servant release];
[super dealloc];
}
@end
|
