blob: 37b8f6f655fb03c24afe7340279737e6285deb39 (
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
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
|
// **********************************************************************
//
// Copyright (c) 2003-2015 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 <location/TestI.h>
@implementation ServerManagerI
-(id) init:(ServerLocatorRegistry*)registry initData:(ICEInitializationData*)initData
{
self = [super init];
if(!self)
{
return nil;
}
registry_ = registry;
initData_ = initData;
[initData_.properties setProperty:@"TestAdapter.Endpoints" value:@"default"];
[initData_.properties setProperty:@"TestAdapter.AdapterId" value:@"TestAdapter"];
[initData_.properties setProperty:@"TestAdapter.ReplicaGroupId" value:@"ReplicatedAdapter"];
[initData_.properties setProperty:@"TestAdapter2.Endpoints" value:@"default"];
[initData_.properties setProperty:@"TestAdapter2.AdapterId" value:@"TestAdapter2"];
[initData_.properties setProperty:@"Ice.PrintAdapterReady" value:@"0"];
return self;
}
#if defined(__clang__) && !__has_feature(objc_arc)
-(void) dealloc
{
[communicators_ release];
[super dealloc];
}
#endif
-(void) startServer:(ICECurrent*)current
{
for(id<ICECommunicator> c in communicators_)
{
[c waitForShutdown];
[c destroy];
}
ICE_RELEASE(communicators_);
communicators_ = [[NSMutableArray alloc] init];
//
// Simulate a server: create a [[communicator alloc] init] and object
// adapter. The object adapter is started on a system allocated
// port. The configuration used here contains the Ice.Locator
// configuration variable. The [[object alloc] init] adapter will register
// its endpoints with the locator and create references containing
// the adapter id instead of the endpoints.
//
id<ICECommunicator> serverCommunicator = [ICEUtil createCommunicator:initData_];
[communicators_ addObject:serverCommunicator];
id<ICEObjectAdapter> adapter = [serverCommunicator createObjectAdapter:@"TestAdapter"];
id<ICEObjectAdapter> adapter2 = [serverCommunicator createObjectAdapter:@"TestAdapter2"];
id<ICEObjectPrx> locator = [serverCommunicator stringToProxy:@"locator:default -p 12010"];
[adapter setLocator:[ICELocatorPrx uncheckedCast:locator]];
[adapter2 setLocator:[ICELocatorPrx uncheckedCast:locator]];
ICEObject* object = ICE_AUTORELEASE([[TestLocationI alloc] init:adapter adapter2:adapter2 registry:registry_]);
[registry_ addObject:[adapter add:object identity:[serverCommunicator stringToIdentity:@"test"]]];
[registry_ addObject:[adapter add:object identity:[serverCommunicator stringToIdentity:@"test2"]]];
[adapter add:object identity:[serverCommunicator stringToIdentity:@"test3"]];
[adapter activate];
[adapter2 activate];
}
-(void) shutdown:(ICECurrent*)current
{
for(id<ICECommunicator> c in communicators_)
{
[c destroy];
}
[communicators_ removeAllObjects];
[[current.adapter getCommunicator] shutdown];
}
-(void) terminate
{
for(id<ICECommunicator> c in communicators_)
{
[c destroy];
}
[communicators_ removeAllObjects];
}
@end
@implementation TestLocationI
-(id) init:(id<ICEObjectAdapter>)adapter
adapter2:(id<ICEObjectAdapter>)adapter2
registry:(ServerLocatorRegistry*)registry
{
self = [super init];
if(!self)
{
return nil;
}
adapter1_ = ICE_RETAIN(adapter);
adapter2_ = ICE_RETAIN(adapter2);
registry_ = registry;
[registry_ addObject:[adapter1_ add:[HelloI hello] identity:[[adapter1_ getCommunicator] stringToIdentity:@"hello"]]];
return self;
}
#if defined(__clang__) && !__has_feature(objc_arc)
-(void) dealloc
{
[adapter1_ release];
[adapter2_ release];
[super dealloc];
}
#endif
-(void) shutdown:(ICECurrent*)current
{
[[adapter1_ getCommunicator] shutdown];
}
-(id<TestLocationHelloPrx>) getHello:(ICECurrent*)current
{
return [TestLocationHelloPrx uncheckedCast:[adapter1_ createIndirectProxy:[[adapter1_ getCommunicator]
stringToIdentity:@"hello"]]];
}
-(id<TestLocationHelloPrx>) getReplicatedHello:(ICECurrent*)current
{
return [TestLocationHelloPrx uncheckedCast:[adapter1_ createProxy:[[adapter1_ getCommunicator] stringToIdentity:@"hello"]]];
}
-(void) migrateHello:(ICECurrent*)current
{
ICEIdentity* ident = [[adapter1_ getCommunicator] stringToIdentity:@"hello"];
@try
{
[registry_ addObject:[adapter2_ add:[adapter1_ remove:ident] identity:ident]];
}
@catch(ICENotRegisteredException*)
{
[registry_ addObject:[adapter1_ add:[adapter2_ remove:ident] identity:ident]];
}
}
@end
@implementation HelloI
-(void) sayHello:(ICECurrent*)current
{
}
@end
|
