blob: 1248e976125f334a5bd5316171cf1067c20155c7 (
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
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
|
// **********************************************************************
//
// 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.h>
#import <invoke/BlobjectI.h>
@implementation BlobjectI
-(BOOL) ice_invoke:(NSData*)inEncaps outEncaps:(NSMutableData**)outEncaps current:(ICECurrent*)current
{
id<ICECommunicator> communicator = [current.adapter getCommunicator];
id<ICEInputStream> inS = [ICEUtil createInputStream:communicator data:inEncaps];
id<ICEOutputStream> outS = [ICEUtil createOutputStream:communicator];
[outS startEncapsulation];
if([current.operation isEqualToString:@"opOneway"])
{
return YES;
}
else if([current.operation isEqualToString:@"opString"])
{
[inS startEncapsulation];
NSString* s = [inS readString];
[inS endEncapsulation];
[outS writeString:s];
[outS writeString:s];
[outS endEncapsulation];
*outEncaps = [outS finished];
return YES;
}
else if([current.operation isEqualToString:@"opException"])
{
if([current.ctx objectForKey:@"raise"] != nil)
{
@throw [TestInvokeMyException myException];
}
TestInvokeMyException* ex = [TestInvokeMyException myException];
[outS writeException:ex];
[outS endEncapsulation];
*outEncaps = [outS finished];
return NO;
}
else if([current.operation isEqualToString:@"shutdown"])
{
[outS endEncapsulation];
*outEncaps = [outS finished];
[communicator shutdown];
return YES;
}
else if([current.operation isEqualToString:@"ice_isA"])
{
[inS startEncapsulation];
NSString* s = [inS readString];
[inS endEncapsulation];
if([s isEqualToString:[TestInvokeMyClass ice_staticId]])
{
[outS writeBool:YES];
}
else
{
[outS writeBool:NO];
}
[outS endEncapsulation];
*outEncaps = [outS finished];
return YES;
}
else
{
@throw [ICEOperationNotExistException operationNotExistException:__FILE__
line:__LINE__
id:current.id_
facet:current.facet
operation:current.operation];
}
}
@end
|
