/dports/devel/php-ice37/ice-3.7.2/csharp/src/Ice/ |
H A D | CollocatedRequestHandler.cs | 64 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 D | ConnectRequestHandler.cs | 41 _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 D | RetryQueue.cs | 12 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 D | ConnectionRequestHandler.cs | 34 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 D | CollocatedRequestHandler.cs | 64 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 D | ConnectRequestHandler.cs | 41 _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 D | RetryQueue.cs | 12 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 D | CollocatedRequestHandler.cs | 64 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 D | ConnectRequestHandler.cs | 41 _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 D | RetryQueue.cs | 12 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 D | CollocatedRequestHandler.java | 14 _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 D | ConnectRequestHandler.java | 67 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 D | CollocatedRequestHandler.java | 14 _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 D | ConnectRequestHandler.java | 67 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 D | CollocatedRequestHandler.java | 13 _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 D | ConnectRequestHandler.java | 69 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 D | CollocatedRequestHandler.java | 13 _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 D | ConnectRequestHandler.java | 69 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 D | CollocatedRequestHandler.java | 13 _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 D | ConnectRequestHandler.java | 69 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 D | CollocatedRequestHandler.java | 14 _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 D | ConnectRequestHandler.java | 67 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 D | CollocatedRequestHandler.cpp | 105 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 D | CollocatedRequestHandler.cpp | 105 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 D | CollocatedRequestHandler.cpp | 105 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 …]
|