blob: d47147f6e35f2a957970481a16af657ed2abc3df (
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
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
|
// **********************************************************************
//
// Copyright (c) 2003-2009 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 IceInternal;
abstract public class OutgoingAsyncMessageCallback
{
public abstract void __sent(Ice.ConnectionI connection);
public abstract void __finished(Ice.LocalException ex);
public abstract void ice_exception(Ice.LocalException ex);
public final BasicStream
__os()
{
return __os;
}
public void
__sent(Instance instance)
{
try
{
((Ice.AMISentCallback)this).ice_sent();
}
catch(java.lang.Exception ex)
{
__warning(instance, ex);
}
}
public void
__exception(Ice.LocalException exc)
{
try
{
ice_exception(exc);
}
catch(java.lang.Exception ex)
{
__warning(ex);
}
finally
{
__releaseCallback();
}
}
protected synchronized void
finalize()
throws Throwable
{
assert(__os == null);
assert(__is == null);
}
protected void
__acquireCallback(Ice.ObjectPrx proxy)
{
synchronized(__monitor)
{
//
// We must first wait for other requests to finish.
//
while(__os != null)
{
try
{
__monitor.wait();
}
catch(InterruptedException ex)
{
}
}
Reference ref = ((Ice.ObjectPrxHelperBase)proxy).__reference();
assert(__is == null);
__is = new BasicStream(ref.getInstance());
assert(__os == null);
__os = new BasicStream(ref.getInstance());
}
}
protected void
__releaseCallback(final Ice.LocalException ex)
{
synchronized(__monitor)
{
assert(__os != null);
//
// This is called by the invoking thread to release the callback following a direct
// failure to marhsall/send the request. We call the ice_exception() callback with
// the thread pool to avoid potential deadlocks in case the invoking thread locked
// some mutexes/resources (which couldn't be re-acquired by the callback).
//
try
{
__os.instance().clientThreadPool().execute(new ThreadPoolWorkItem()
{
public void
execute(ThreadPool threadPool)
{
threadPool.promoteFollower(null);
__exception(ex);
}
});
}
catch(Ice.CommunicatorDestroyedException exc)
{
__releaseCallback();
throw exc; // CommunicatorDestroyedException is the only exception that can propagate directly.
}
}
}
protected void
__releaseCallback()
{
synchronized(__monitor)
{
assert(__is != null);
__is = null;
assert(__os != null);
__os = null;
__monitor.notify();
}
}
protected void
__warning(java.lang.Exception ex)
{
if(__os != null)
{
__warning(__os.instance(), ex);
}
}
protected void
__warning(Instance instance, java.lang.Exception ex)
{
if(instance.initializationData().properties.getPropertyAsIntWithDefault("Ice.Warn.AMICallback", 1) > 0)
{
java.io.StringWriter sw = new java.io.StringWriter();
java.io.PrintWriter pw = new java.io.PrintWriter(sw);
IceUtilInternal.OutputBase out = new IceUtilInternal.OutputBase(pw);
out.setUseTab(false);
out.print("exception raised by AMI callback:\n");
ex.printStackTrace(pw);
pw.flush();
instance.initializationData().logger.warning(sw.toString());
}
}
protected final java.lang.Object __monitor = new java.lang.Object();
protected BasicStream __is;
protected BasicStream __os;
};
|
