blob: 006f04c8e51b546c25761d92d1c3ac9341095181 (
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
|
// **********************************************************************
//
// Copyright (c) 2003-2017 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
-(void) iceDispatch:(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;
[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];
}
-(void) 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];
}
-(void)dealloc
{
[servant release];
[super dealloc];
}
@end
|
