blob: e5f205fe289cd84bd4928bea14a066cec603cdd1 (
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
|
// **********************************************************************
//
// Copyright (c) 2003-2016 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 Test;
using System.Collections.Generic;
internal class BackgroundControllerI : BackgroundControllerDisp_
{
public override void pauseCall(string opName, Ice.Current current)
{
lock(this)
{
_pausedCalls.Add(opName);
}
}
public override void resumeCall(string opName, Ice.Current current)
{
lock(this)
{
_pausedCalls.Remove(opName);
System.Threading.Monitor.PulseAll(this);
}
}
internal void checkCallPause(Ice.Current current)
{
lock(this)
{
while(_pausedCalls.Contains(current.operation))
{
System.Threading.Monitor.Wait(this);
break;
}
}
}
public override void holdAdapter(Ice.Current current)
{
_adapter.hold();
}
public override void resumeAdapter(Ice.Current current)
{
_adapter.activate();
}
public override void initializeException(bool enable, Ice.Current current)
{
_configuration.initializeException(enable ? new Ice.SocketException() : null);
}
public override void readReady(bool enable, Ice.Current current)
{
_configuration.readReady(enable);
}
public override void readException(bool enable, Ice.Current current)
{
_configuration.readException(enable ? new Ice.SocketException() : null);
}
public override void writeReady(bool enable, Ice.Current current)
{
_configuration.writeReady(enable);
}
public override void writeException(bool enable, Ice.Current current)
{
_configuration.writeException(enable ? new Ice.SocketException() : null);
}
public override void buffered(bool enable, Ice.Current current)
{
_configuration.buffered(enable);
}
internal BackgroundControllerI(Ice.ObjectAdapter adapter)
{
_adapter = adapter;
_configuration = Configuration.getInstance();
}
private Ice.ObjectAdapter _adapter;
private HashSet<string> _pausedCalls = new HashSet<string>();
private Configuration _configuration;
}
|
