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
162
163
164
165
166
167
168
169
170
171
172
173
|
// **********************************************************************
//
// 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 java.util.concurrent.ScheduledThreadPoolExecutor;
import java.util.concurrent.TimeUnit;
import Glacier2.CannotCreateSessionException;
import Glacier2.SessionControlPrx;
import Glacier2.SessionPrx;
import Glacier2._PermissionsVerifierDisp;
import Glacier2._SessionManagerDisp;
import Ice.Current;
import Ice.LocalException;
import Ice.NotRegisteredException;
import Ice.ObjectNotExistException;
import Ice.StringHolder;
import Voip.Callback_Control_incomingCall;
import Voip.ControlPrx;
import Voip.SessionPrxHelper;
import Voip._SessionDisp;
public class Server extends Ice.Application
{
private final ScheduledThreadPoolExecutor _executor = new ScheduledThreadPoolExecutor(1);
class SessionI extends _SessionDisp
{
private ControlPrx _ctrl;
private long _timestamp = System.currentTimeMillis();
@Override
public void setControl(ControlPrx ctrl, Current current)
{
_ctrl = ctrl;
}
@Override
public void simulateCall(int delay, Current current)
{
_executor.schedule(new Runnable()
{
@Override
public void run()
{
if(_ctrl != null)
{
System.out.println("calling incoming call");
_ctrl.begin_incomingCall(new Callback_Control_incomingCall()
{
@Override
public void exception(LocalException ex)
{
System.out.println("incoming call failed");
ex.printStackTrace();
}
@Override
public void response()
{
System.out.println("incoming call succeeded");
}
});
}
}
}, delay, TimeUnit.MILLISECONDS);
}
@Override
public void destroy(Current current)
{
try
{
current.adapter.remove(current.id);
}
catch(NotRegisteredException ex)
{
// Ignore.
}
}
@Override
public void refresh(Current current)
{
_timestamp = System.currentTimeMillis();
}
long getTimestamp()
{
return _timestamp;
}
}
class PermissionsVerifierI extends _PermissionsVerifierDisp
{
@Override
public boolean checkPermissions(String userId, String password, StringHolder reason, Current current)
{
return true;
}
}
class SessionManagerI extends _SessionManagerDisp
{
@Override
public SessionPrx create(String userId, SessionControlPrx control,
Current current) throws CannotCreateSessionException
{
// The configured timeout must be greater than 600. This is 601 * 2.
final long sessionTimeout = 1202;
final SessionI session = new SessionI();
final Ice.Identity ident = new Ice.Identity();
ident.name = java.util.UUID.randomUUID().toString();
ident.category = "session";
final SessionPrx proxy = SessionPrxHelper.uncheckedCast(current.adapter.add(session, ident));
_executor.scheduleWithFixedDelay(new Runnable()
{
@Override
public void run()
{
// If the session has already been destroyed the ONE will
// fall out of run canceling the task.
if (System.currentTimeMillis() - session.getTimestamp() > (sessionTimeout * 1000L * 2))
{
proxy.destroy();
throw new ObjectNotExistException();
}
}
}, sessionTimeout, sessionTimeout, TimeUnit.SECONDS);
return proxy;
}
};
Server()
{
// We want the executor to shutdown even if there are scheduled tasks.
_executor.setExecuteExistingDelayedTasksAfterShutdownPolicy(false);
}
@Override
public int
run(String[] args)
{
if(args.length > 0)
{
System.err.println(appName() + ": too many arguments");
return 1;
}
Ice.ObjectAdapter adapter = communicator().createObjectAdapter("VoipServer");
adapter.add(new PermissionsVerifierI(), communicator().stringToIdentity("VoipVerifier"));
adapter.add(new SessionManagerI(), communicator().stringToIdentity("VoipSessionManager"));
adapter.activate();
communicator().waitForShutdown();
_executor.shutdown();
return 0;
}
public static void
main(String[] args)
{
Server app = new Server();
int status = app.main("Server", args, "config.server");
System.exit(status);
}
}
|
