summaryrefslogtreecommitdiff
path: root/cs/demo/Ice/session/ReapThread.cs
diff options
context:
space:
mode:
Diffstat (limited to 'cs/demo/Ice/session/ReapThread.cs')
-rwxr-xr-xcs/demo/Ice/session/ReapThread.cs114
1 files changed, 57 insertions, 57 deletions
diff --git a/cs/demo/Ice/session/ReapThread.cs b/cs/demo/Ice/session/ReapThread.cs
index 877dccd304e..24f8078bac3 100755
--- a/cs/demo/Ice/session/ReapThread.cs
+++ b/cs/demo/Ice/session/ReapThread.cs
@@ -16,81 +16,81 @@ public class ReapThread
{
public class SessionProxyPair
{
- public SessionProxyPair(SessionPrx p, SessionI s)
- {
- proxy = p;
- session = s;
- }
+ public SessionProxyPair(SessionPrx p, SessionI s)
+ {
+ proxy = p;
+ session = s;
+ }
- public SessionPrx proxy;
- public SessionI session;
+ public SessionPrx proxy;
+ public SessionI session;
}
public ReapThread()
{
- _timeout = System.TimeSpan.FromSeconds(10);
- _terminated = false;
- _sessions = new ArrayList();
+ _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;
- }
- }
- }
+ 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);
+ lock(this)
+ {
+ _terminated = true;
+ System.Threading.Monitor.Pulse(this);
- _sessions.Clear();
- }
+ _sessions.Clear();
+ }
}
public void add(SessionPrx proxy, SessionI session)
{
- lock(this)
- {
- _sessions.Add(new SessionProxyPair(proxy, session));
- }
+ lock(this)
+ {
+ _sessions.Add(new SessionProxyPair(proxy, session));
+ }
}
private bool _terminated;