Home
last modified time | relevance | path

Searched refs:outAsync (Results 1 – 25 of 141) sorted by relevance

123456

/dports/devel/php-ice37/ice-3.7.2/csharp/src/Ice/
H A DCollocatedRequestHandler.cs64 if(outAsync is OutgoingAsync) in asyncRequestCanceled()
86 OutgoingAsyncBase outAsync; in sendResponse()
109 if(!outAsync.response()) in sendResponse()
111 outAsync = null; in sendResponse()
117 if(outAsync != null) in sendResponse()
220 if(sentAsync(outAsync)) in invokeAsyncRequest()
237 if(!outAsync.sent()) in sentAsync()
242 outAsync.invokeSent(); in sentAsync()
317 OutgoingAsyncBase outAsync; in handleException()
324 outAsync = null; in handleException()
[all …]
H A DConnectRequestHandler.cs41 _requests.AddLast(outAsync); in sendAsyncRequest()
62 if(p.Value == outAsync) in asyncRequestCanceled()
65 if(outAsync.exception(ex)) in asyncRequestCanceled()
67 outAsync.invokeExceptionAsync(); in asyncRequestCanceled()
76 _connection.asyncRequestCanceled(outAsync, ex); in asyncRequestCanceled()
159 if(outAsync.exception(_exception)) in setException()
161 outAsync.invokeExceptionAsync(); in setException()
253 outAsync.invokeSentAsync(); in flushRequests()
263 outAsync.retryException(ex.get()); in flushRequests()
268 if(outAsync.exception(ex)) in flushRequests()
[all …]
H A DRetryQueue.cs12 public RetryTask(Instance instance, RetryQueue retryQueue, ProxyOutgoingAsyncBase outAsync) in RetryTask() argument
16 _outAsync = outAsync; in RetryTask()
32 public void asyncRequestCanceled(OutgoingAsyncBase outAsync, Ice.LocalException ex) in asyncRequestCanceled() argument
34 Debug.Assert(_outAsync == outAsync); in asyncRequestCanceled()
73 public void add(ProxyOutgoingAsyncBase outAsync, int interval) in add() argument
81 RetryTask task = new RetryTask(_instance, this, outAsync); in add()
82 outAsync.cancelable(task); // This will throw if the request is canceled. in add()
H A DConnectionRequestHandler.cs34 public int sendAsyncRequest(ProxyOutgoingAsyncBase outAsync) in sendAsyncRequest() argument
36 return outAsync.invokeRemote(_connection, _compress, _response); in sendAsyncRequest()
39 public void asyncRequestCanceled(OutgoingAsyncBase outAsync, Ice.LocalException ex) in asyncRequestCanceled() argument
41 _connection.asyncRequestCanceled(outAsync, ex); in asyncRequestCanceled()
/dports/devel/ice37/ice-3.7.2/csharp/src/Ice/
H A DCollocatedRequestHandler.cs64 if(outAsync is OutgoingAsync) in asyncRequestCanceled()
86 OutgoingAsyncBase outAsync; in sendResponse()
109 if(!outAsync.response()) in sendResponse()
111 outAsync = null; in sendResponse()
117 if(outAsync != null) in sendResponse()
220 if(sentAsync(outAsync)) in invokeAsyncRequest()
237 if(!outAsync.sent()) in sentAsync()
242 outAsync.invokeSent(); in sentAsync()
317 OutgoingAsyncBase outAsync; in handleException()
324 outAsync = null; in handleException()
[all …]
H A DConnectRequestHandler.cs41 _requests.AddLast(outAsync); in sendAsyncRequest()
62 if(p.Value == outAsync) in asyncRequestCanceled()
65 if(outAsync.exception(ex)) in asyncRequestCanceled()
67 outAsync.invokeExceptionAsync(); in asyncRequestCanceled()
76 _connection.asyncRequestCanceled(outAsync, ex); in asyncRequestCanceled()
159 if(outAsync.exception(_exception)) in setException()
161 outAsync.invokeExceptionAsync(); in setException()
253 outAsync.invokeSentAsync(); in flushRequests()
263 outAsync.retryException(ex.get()); in flushRequests()
268 if(outAsync.exception(ex)) in flushRequests()
[all …]
H A DRetryQueue.cs12 public RetryTask(Instance instance, RetryQueue retryQueue, ProxyOutgoingAsyncBase outAsync) in RetryTask() argument
16 _outAsync = outAsync; in RetryTask()
32 public void asyncRequestCanceled(OutgoingAsyncBase outAsync, Ice.LocalException ex) in asyncRequestCanceled() argument
34 Debug.Assert(_outAsync == outAsync); in asyncRequestCanceled()
73 public void add(ProxyOutgoingAsyncBase outAsync, int interval) in add() argument
81 RetryTask task = new RetryTask(_instance, this, outAsync); in add()
82 outAsync.cancelable(task); // This will throw if the request is canceled. in add()
/dports/devel/py-ice37/ice-3.7.2/csharp/src/Ice/
H A DCollocatedRequestHandler.cs64 if(outAsync is OutgoingAsync) in asyncRequestCanceled()
86 OutgoingAsyncBase outAsync; in sendResponse()
109 if(!outAsync.response()) in sendResponse()
111 outAsync = null; in sendResponse()
117 if(outAsync != null) in sendResponse()
220 if(sentAsync(outAsync)) in invokeAsyncRequest()
237 if(!outAsync.sent()) in sentAsync()
242 outAsync.invokeSent(); in sentAsync()
317 OutgoingAsyncBase outAsync; in handleException()
324 outAsync = null; in handleException()
[all …]
H A DConnectRequestHandler.cs41 _requests.AddLast(outAsync); in sendAsyncRequest()
62 if(p.Value == outAsync) in asyncRequestCanceled()
65 if(outAsync.exception(ex)) in asyncRequestCanceled()
67 outAsync.invokeExceptionAsync(); in asyncRequestCanceled()
76 _connection.asyncRequestCanceled(outAsync, ex); in asyncRequestCanceled()
159 if(outAsync.exception(_exception)) in setException()
161 outAsync.invokeExceptionAsync(); in setException()
253 outAsync.invokeSentAsync(); in flushRequests()
263 outAsync.retryException(ex.get()); in flushRequests()
268 if(outAsync.exception(ex)) in flushRequests()
[all …]
H A DRetryQueue.cs12 public RetryTask(Instance instance, RetryQueue retryQueue, ProxyOutgoingAsyncBase outAsync) in RetryTask() argument
16 _outAsync = outAsync; in RetryTask()
32 public void asyncRequestCanceled(OutgoingAsyncBase outAsync, Ice.LocalException ex) in asyncRequestCanceled() argument
34 Debug.Assert(_outAsync == outAsync); in asyncRequestCanceled()
73 public void add(ProxyOutgoingAsyncBase outAsync, int interval) in add() argument
81 RetryTask task = new RetryTask(_instance, this, outAsync); in add()
82 outAsync.cancelable(task); // This will throw if the request is canceled. in add()
/dports/devel/ice37/ice-3.7.2/java/src/Ice/src/main/java/com/zeroc/IceInternal/
H A DCollocatedRequestHandler.java14 _outAsync = outAsync; in InvokeAllAsync()
73 if(outAsync.completed(ex)) in asyncRequestCanceled()
124 if(outAsync != null && !outAsync.completed(is)) in sendResponse()
126 outAsync = null; in sendResponse()
130 if(outAsync != null) in sendResponse()
235 if(sentAsync(outAsync)) in invokeAsyncRequest()
258 if(!outAsync.sent()) in sentAsync()
264 outAsync.invokeSent(); in sentAsync()
391 if(outAsync != null && !outAsync.completed(ex)) in handleException()
393 outAsync = null; in handleException()
[all …]
H A DConnectRequestHandler.java67 if(request == outAsync) in asyncRequestCanceled()
70 if(outAsync.completed(ex)) in asyncRequestCanceled()
80 _connection.asyncRequestCanceled(outAsync, ex); in asyncRequestCanceled()
166 for(OutgoingAsyncBase outAsync : _requests) in setException()
168 if(outAsync.completed(_exception)) in setException()
170 outAsync.invokeCompletedAsync(); in setException()
311 for(ProxyOutgoingAsyncBase outAsync : _requests) in flushRequestsImpl()
317 outAsync.invokeSentAsync(); in flushRequestsImpl()
326 outAsync.retryException(ex.get()); in flushRequestsImpl()
331 if(outAsync.completed(ex)) in flushRequestsImpl()
[all …]
/dports/devel/php-ice37/ice-3.7.2/java/src/Ice/src/main/java/com/zeroc/IceInternal/
H A DCollocatedRequestHandler.java14 _outAsync = outAsync; in InvokeAllAsync()
73 if(outAsync.completed(ex)) in asyncRequestCanceled()
124 if(outAsync != null && !outAsync.completed(is)) in sendResponse()
126 outAsync = null; in sendResponse()
130 if(outAsync != null) in sendResponse()
235 if(sentAsync(outAsync)) in invokeAsyncRequest()
258 if(!outAsync.sent()) in sentAsync()
264 outAsync.invokeSent(); in sentAsync()
391 if(outAsync != null && !outAsync.completed(ex)) in handleException()
393 outAsync = null; in handleException()
[all …]
H A DConnectRequestHandler.java67 if(request == outAsync) in asyncRequestCanceled()
70 if(outAsync.completed(ex)) in asyncRequestCanceled()
80 _connection.asyncRequestCanceled(outAsync, ex); in asyncRequestCanceled()
166 for(OutgoingAsyncBase outAsync : _requests) in setException()
168 if(outAsync.completed(_exception)) in setException()
170 outAsync.invokeCompletedAsync(); in setException()
311 for(ProxyOutgoingAsyncBase outAsync : _requests) in flushRequestsImpl()
317 outAsync.invokeSentAsync(); in flushRequestsImpl()
326 outAsync.retryException(ex.get()); in flushRequestsImpl()
331 if(outAsync.completed(ex)) in flushRequestsImpl()
[all …]
/dports/devel/php-ice37/ice-3.7.2/java-compat/src/Ice/src/main/java/IceInternal/
H A DCollocatedRequestHandler.java13 _outAsync = outAsync; in InvokeAllAsync()
72 if(outAsync.completed(ex)) in asyncRequestCanceled()
124 if(outAsync != null && !outAsync.completed(is)) in sendResponse()
126 outAsync = null; in sendResponse()
130 if(outAsync != null) in sendResponse()
235 if(sentAsync(outAsync)) in invokeAsyncRequest()
258 if(!outAsync.sent()) in sentAsync()
264 outAsync.invokeSent(); in sentAsync()
390 if(outAsync != null && !outAsync.completed(ex)) in handleException()
392 outAsync = null; in handleException()
[all …]
H A DConnectRequestHandler.java69 if(request == outAsync) in asyncRequestCanceled()
72 if(outAsync.completed(ex)) in asyncRequestCanceled()
82 _connection.asyncRequestCanceled(outAsync, ex); in asyncRequestCanceled()
168 for(OutgoingAsyncBase outAsync : _requests) in setException()
170 if(outAsync.completed(_exception)) in setException()
172 outAsync.invokeCompletedAsync(); in setException()
313 for(ProxyOutgoingAsyncBase outAsync : _requests) in flushRequestsImpl()
319 outAsync.invokeSentAsync(); in flushRequestsImpl()
328 outAsync.retryException(ex.get()); in flushRequestsImpl()
333 if(outAsync.completed(ex)) in flushRequestsImpl()
[all …]
/dports/devel/ice37/ice-3.7.2/java-compat/src/Ice/src/main/java/IceInternal/
H A DCollocatedRequestHandler.java13 _outAsync = outAsync; in InvokeAllAsync()
72 if(outAsync.completed(ex)) in asyncRequestCanceled()
124 if(outAsync != null && !outAsync.completed(is)) in sendResponse()
126 outAsync = null; in sendResponse()
130 if(outAsync != null) in sendResponse()
235 if(sentAsync(outAsync)) in invokeAsyncRequest()
258 if(!outAsync.sent()) in sentAsync()
264 outAsync.invokeSent(); in sentAsync()
390 if(outAsync != null && !outAsync.completed(ex)) in handleException()
392 outAsync = null; in handleException()
[all …]
H A DConnectRequestHandler.java69 if(request == outAsync) in asyncRequestCanceled()
72 if(outAsync.completed(ex)) in asyncRequestCanceled()
82 _connection.asyncRequestCanceled(outAsync, ex); in asyncRequestCanceled()
168 for(OutgoingAsyncBase outAsync : _requests) in setException()
170 if(outAsync.completed(_exception)) in setException()
172 outAsync.invokeCompletedAsync(); in setException()
313 for(ProxyOutgoingAsyncBase outAsync : _requests) in flushRequestsImpl()
319 outAsync.invokeSentAsync(); in flushRequestsImpl()
328 outAsync.retryException(ex.get()); in flushRequestsImpl()
333 if(outAsync.completed(ex)) in flushRequestsImpl()
[all …]
/dports/devel/py-ice37/ice-3.7.2/java-compat/src/Ice/src/main/java/IceInternal/
H A DCollocatedRequestHandler.java13 _outAsync = outAsync; in InvokeAllAsync()
72 if(outAsync.completed(ex)) in asyncRequestCanceled()
124 if(outAsync != null && !outAsync.completed(is)) in sendResponse()
126 outAsync = null; in sendResponse()
130 if(outAsync != null) in sendResponse()
235 if(sentAsync(outAsync)) in invokeAsyncRequest()
258 if(!outAsync.sent()) in sentAsync()
264 outAsync.invokeSent(); in sentAsync()
390 if(outAsync != null && !outAsync.completed(ex)) in handleException()
392 outAsync = null; in handleException()
[all …]
H A DConnectRequestHandler.java69 if(request == outAsync) in asyncRequestCanceled()
72 if(outAsync.completed(ex)) in asyncRequestCanceled()
82 _connection.asyncRequestCanceled(outAsync, ex); in asyncRequestCanceled()
168 for(OutgoingAsyncBase outAsync : _requests) in setException()
170 if(outAsync.completed(_exception)) in setException()
172 outAsync.invokeCompletedAsync(); in setException()
313 for(ProxyOutgoingAsyncBase outAsync : _requests) in flushRequestsImpl()
319 outAsync.invokeSentAsync(); in flushRequestsImpl()
328 outAsync.retryException(ex.get()); in flushRequestsImpl()
333 if(outAsync.completed(ex)) in flushRequestsImpl()
[all …]
/dports/devel/py-ice37/ice-3.7.2/java/src/Ice/src/main/java/com/zeroc/IceInternal/
H A DCollocatedRequestHandler.java14 _outAsync = outAsync; in InvokeAllAsync()
73 if(outAsync.completed(ex)) in asyncRequestCanceled()
124 if(outAsync != null && !outAsync.completed(is)) in sendResponse()
126 outAsync = null; in sendResponse()
130 if(outAsync != null) in sendResponse()
235 if(sentAsync(outAsync)) in invokeAsyncRequest()
258 if(!outAsync.sent()) in sentAsync()
264 outAsync.invokeSent(); in sentAsync()
391 if(outAsync != null && !outAsync.completed(ex)) in handleException()
393 outAsync = null; in handleException()
[all …]
H A DConnectRequestHandler.java67 if(request == outAsync) in asyncRequestCanceled()
70 if(outAsync.completed(ex)) in asyncRequestCanceled()
80 _connection.asyncRequestCanceled(outAsync, ex); in asyncRequestCanceled()
166 for(OutgoingAsyncBase outAsync : _requests) in setException()
168 if(outAsync.completed(_exception)) in setException()
170 outAsync.invokeCompletedAsync(); in setException()
311 for(ProxyOutgoingAsyncBase outAsync : _requests) in flushRequestsImpl()
317 outAsync.invokeSentAsync(); in flushRequestsImpl()
326 outAsync.retryException(ex.get()); in flushRequestsImpl()
331 if(outAsync.completed(ex)) in flushRequestsImpl()
[all …]
/dports/devel/php-ice37/ice-3.7.2/cpp/src/Ice/
H A DCollocatedRequestHandler.cpp105 if(outAsync->exception(ex)) in asyncRequestCanceled()
192 if(sentAsync(outAsync)) in invokeAsyncRequest()
203 OutgoingAsyncBasePtr outAsync; in sendResponse() local
227 outAsync = q->second; in sendResponse()
233 if(outAsync) in sendResponse()
246 outAsync->invokeResponse(); in sendResponse()
296 if(!outAsync->sent()) in sentAsync()
301 outAsync->invokeSent(); in sentAsync()
376 OutgoingAsyncBasePtr outAsync; in handleException() local
385 outAsync = q->second; in handleException()
[all …]
/dports/devel/ice37/ice-3.7.2/cpp/src/Ice/
H A DCollocatedRequestHandler.cpp105 if(outAsync->exception(ex)) in asyncRequestCanceled()
192 if(sentAsync(outAsync)) in invokeAsyncRequest()
203 OutgoingAsyncBasePtr outAsync; in sendResponse() local
227 outAsync = q->second; in sendResponse()
233 if(outAsync) in sendResponse()
246 outAsync->invokeResponse(); in sendResponse()
296 if(!outAsync->sent()) in sentAsync()
301 outAsync->invokeSent(); in sentAsync()
376 OutgoingAsyncBasePtr outAsync; in handleException() local
385 outAsync = q->second; in handleException()
[all …]
/dports/devel/py-ice37/ice-3.7.2/cpp/src/Ice/
H A DCollocatedRequestHandler.cpp105 if(outAsync->exception(ex)) in asyncRequestCanceled()
192 if(sentAsync(outAsync)) in invokeAsyncRequest()
203 OutgoingAsyncBasePtr outAsync; in sendResponse() local
227 outAsync = q->second; in sendResponse()
233 if(outAsync) in sendResponse()
246 outAsync->invokeResponse(); in sendResponse()
296 if(!outAsync->sent()) in sentAsync()
301 outAsync->invokeSent(); in sentAsync()
376 OutgoingAsyncBasePtr outAsync; in handleException() local
385 outAsync = q->second; in handleException()
[all …]

123456