blob: 877dccd304e368405b5fea8059bf6b21e144731a (
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
|
// **********************************************************************
//
// Copyright (c) 2003-2007 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.
//
// **********************************************************************
using System;
using System.Threading;
using System.Collections;
using Demo;
public class ReapThread
{
public class SessionProxyPair
{
public SessionProxyPair(SessionPrx p, SessionI s)
{
proxy = p;
session = s;
}
public SessionPrx proxy;
public SessionI session;
}
public ReapThread()
{
_timeout = System.TimeSpan.FromSeconds(10);
_terminated = false;
_sessions = new ArrayList();
}
public void run()
{
lock(this)
{
while(!_terminated)
{
System.Threading.Monitor.Wait(this, _timeout);
if(!_terminated)
{
ArrayList tmp = new ArrayList();
foreach(SessionProxyPair p in _sessions)
{
try
{
//
// Session destruction may take time in a
// real-world example. Therefore the current time
// is computed for each iteration.
//
if((System.DateTime.Now - p.session.timestamp()) > _timeout)
{
string name = p.proxy.getName();
p.proxy.destroy();
Console.Out.WriteLine("The session " + name + " has timed out.");
}
else
{
tmp.Add(p);
}
}
catch(Ice.ObjectNotExistException)
{
// Ignore.
}
}
_sessions = tmp;
}
}
}
}
public void terminate()
{
lock(this)
{
_terminated = true;
System.Threading.Monitor.Pulse(this);
_sessions.Clear();
}
}
public void add(SessionPrx proxy, SessionI session)
{
lock(this)
{
_sessions.Add(new SessionProxyPair(proxy, session));
}
}
private bool _terminated;
private System.TimeSpan _timeout;
private ArrayList _sessions;
}
|
