blob: 2cd28c2cc592407757b27a158111ac2eb88b1413 (
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
|
// **********************************************************************
//
// Copyright (c) 2003-2012 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.
//
// **********************************************************************
package test.IceSSL.configuration;
import test.IceSSL.configuration.Test.ServerPrx;
import test.IceSSL.configuration.Test.ServerPrxHelper;
import test.IceSSL.configuration.Test._ServerFactoryDisp;
class ServerFactoryI extends _ServerFactoryDisp
{
private static void
test(boolean b)
{
if(!b)
{
throw new RuntimeException();
}
}
public ServerPrx
createServer(java.util.Map<String, String> props, Ice.Current current)
{
Ice.InitializationData initData = new Ice.InitializationData();
initData.properties = Ice.Util.createProperties();
for(java.util.Map.Entry<String, String> i : props.entrySet())
{
initData.properties.setProperty(i.getKey(), i.getValue());
}
String[] args = new String[0];
Ice.Communicator communicator = Ice.Util.initialize(args, initData);
Ice.ObjectAdapter adapter = communicator.createObjectAdapterWithEndpoints("ServerAdapter", "ssl");
ServerI server = new ServerI(communicator);
Ice.ObjectPrx obj = adapter.addWithUUID(server);
_servers.put(obj.ice_getIdentity(), server);
adapter.activate();
return ServerPrxHelper.uncheckedCast(obj);
}
public void
destroyServer(ServerPrx srv, Ice.Current current)
{
Ice.Identity key = srv.ice_getIdentity();
if(_servers.containsKey(key))
{
ServerI server = _servers.get(key);
server.destroy();
_servers.remove(key);
}
}
public void
shutdown(Ice.Current current)
{
test(_servers.size() == 0);
current.adapter.getCommunicator().shutdown();
}
private java.util.Map<Ice.Identity, ServerI> _servers = new java.util.HashMap<Ice.Identity, ServerI>();
}
|
