Home
last modified time | relevance | path

Searched refs:_asyncRequests (Results 1 – 25 of 30) sorted by relevance

12

/dports/devel/php-ice37/ice-3.7.2/cpp/src/Ice/
H A DCollocatedRequestHandler.cpp102 _asyncRequests.erase(p->second); in asyncRequestCanceled()
116 …for(map<Int, OutgoingAsyncBasePtr>::iterator q = _asyncRequests.begin(); q != _asyncRequests.end()… in asyncRequestCanceled()
120 _asyncRequests.erase(q); in asyncRequestCanceled()
153 _asyncRequests.insert(make_pair(requestId, ICE_GET_SHARED_FROM_THIS(outAsync))); in invokeAsyncRequest()
221 map<int, OutgoingAsyncBasePtr>::iterator q = _asyncRequests.find(requestId); in sendResponse()
222 if(q != _asyncRequests.end()) in sendResponse()
229 _asyncRequests.erase(q); in sendResponse()
380 map<int, OutgoingAsyncBasePtr>::iterator q = _asyncRequests.find(requestId); in handleException()
381 if(q != _asyncRequests.end()) in handleException()
387 _asyncRequests.erase(q); in handleException()
H A DConnectionI.cpp510 while(!_asyncRequests.empty())
768 _asyncRequestsHint = _asyncRequests.insert(_asyncRequests.end(),
1272 …for(map<Int, OutgoingAsyncBasePtr>::iterator p = _asyncRequests.begin(); p != _asyncRequests.end()…
1283 _asyncRequests.erase(p);
2112 …for(map<Int, OutgoingAsyncBasePtr>::const_iterator q = _asyncRequests.begin(); q != _asyncRequests…
2120 _asyncRequests.clear();
2253 _asyncRequestsHint(_asyncRequests.end()),
2320 assert(_asyncRequests.empty());
3354 if(q == _asyncRequests.end())
3359 if(q != _asyncRequests.end())
[all …]
H A DCollocatedRequestHandler.h81 std::map<Ice::Int, OutgoingAsyncBasePtr> _asyncRequests; variable
/dports/devel/ice37/ice-3.7.2/cpp/src/Ice/
H A DCollocatedRequestHandler.cpp102 _asyncRequests.erase(p->second); in asyncRequestCanceled()
116 …for(map<Int, OutgoingAsyncBasePtr>::iterator q = _asyncRequests.begin(); q != _asyncRequests.end()… in asyncRequestCanceled()
120 _asyncRequests.erase(q); in asyncRequestCanceled()
153 _asyncRequests.insert(make_pair(requestId, ICE_GET_SHARED_FROM_THIS(outAsync))); in invokeAsyncRequest()
221 map<int, OutgoingAsyncBasePtr>::iterator q = _asyncRequests.find(requestId); in sendResponse()
222 if(q != _asyncRequests.end()) in sendResponse()
229 _asyncRequests.erase(q); in sendResponse()
380 map<int, OutgoingAsyncBasePtr>::iterator q = _asyncRequests.find(requestId); in handleException()
381 if(q != _asyncRequests.end()) in handleException()
387 _asyncRequests.erase(q); in handleException()
H A DConnectionI.cpp510 while(!_asyncRequests.empty()) in close()
768 _asyncRequestsHint = _asyncRequests.insert(_asyncRequests.end(), in sendAsyncRequest()
1272 …for(map<Int, OutgoingAsyncBasePtr>::iterator p = _asyncRequests.begin(); p != _asyncRequests.end()… in asyncRequestCanceled()
1283 _asyncRequests.erase(p); in asyncRequestCanceled()
2112 …for(map<Int, OutgoingAsyncBasePtr>::const_iterator q = _asyncRequests.begin(); q != _asyncRequests… in finish()
2120 _asyncRequests.clear(); in finish()
2253 _asyncRequestsHint(_asyncRequests.end()), in ConnectionI()
2320 assert(_asyncRequests.empty()); in ~ConnectionI()
3354 if(q == _asyncRequests.end()) in parseMessage()
3359 if(q != _asyncRequests.end()) in parseMessage()
[all …]
/dports/devel/py-ice37/ice-3.7.2/cpp/src/Ice/
H A DCollocatedRequestHandler.cpp102 _asyncRequests.erase(p->second); in asyncRequestCanceled()
116 …for(map<Int, OutgoingAsyncBasePtr>::iterator q = _asyncRequests.begin(); q != _asyncRequests.end()… in asyncRequestCanceled()
120 _asyncRequests.erase(q); in asyncRequestCanceled()
153 _asyncRequests.insert(make_pair(requestId, ICE_GET_SHARED_FROM_THIS(outAsync))); in invokeAsyncRequest()
221 map<int, OutgoingAsyncBasePtr>::iterator q = _asyncRequests.find(requestId); in sendResponse()
222 if(q != _asyncRequests.end()) in sendResponse()
229 _asyncRequests.erase(q); in sendResponse()
380 map<int, OutgoingAsyncBasePtr>::iterator q = _asyncRequests.find(requestId); in handleException()
381 if(q != _asyncRequests.end()) in handleException()
387 _asyncRequests.erase(q); in handleException()
H A DConnectionI.cpp510 while(!_asyncRequests.empty()) in close()
768 _asyncRequestsHint = _asyncRequests.insert(_asyncRequests.end(), in sendAsyncRequest()
1272 …for(map<Int, OutgoingAsyncBasePtr>::iterator p = _asyncRequests.begin(); p != _asyncRequests.end()… in asyncRequestCanceled()
1283 _asyncRequests.erase(p); in asyncRequestCanceled()
2112 …for(map<Int, OutgoingAsyncBasePtr>::const_iterator q = _asyncRequests.begin(); q != _asyncRequests… in finish()
2120 _asyncRequests.clear(); in finish()
2253 _asyncRequestsHint(_asyncRequests.end()), in ConnectionI()
2320 assert(_asyncRequests.empty()); in ~ConnectionI()
3354 if(q == _asyncRequests.end()) in parseMessage()
3359 if(q != _asyncRequests.end()) in parseMessage()
[all …]
/dports/devel/php-ice37/ice-3.7.2/csharp/src/Ice/
H A DCollocatedRequestHandler.cs54 _asyncRequests.Remove(requestId); in asyncRequestCanceled()
68 foreach(KeyValuePair<int, OutgoingAsyncBase> e in _asyncRequests) in asyncRequestCanceled()
72 _asyncRequests.Remove(e.Key); in asyncRequestCanceled()
106 if(_asyncRequests.TryGetValue(requestId, out outAsync)) in sendResponse()
113 _asyncRequests.Remove(requestId); in sendResponse()
182 _asyncRequests.Add(requestId, outAsync); in invokeAsyncRequest()
320 if(_asyncRequests.TryGetValue(requestId, out outAsync)) in handleException()
326 _asyncRequests.Remove(requestId); in handleException()
358 …private Dictionary<int, OutgoingAsyncBase> _asyncRequests = new Dictionary<int, OutgoingAsyncBase>… field in IceInternal.CollocatedRequestHandler
H A DConnectionI.cs198 while(_asyncRequests.Count != 0) in close()
363 (acm.close != ACMClose.CloseOnIdle && (_asyncRequests.Count > 0))) in monitor()
373 _asyncRequests.Count == 0) in monitor()
460 _asyncRequests[requestId] = og; in sendAsyncRequest()
803 _asyncRequests.Remove(o.requestId); in asyncRequestCanceled()
835 foreach(KeyValuePair<int, OutgoingAsyncBase> kvp in _asyncRequests) in asyncRequestCanceled()
845 _asyncRequests.Remove(kvp.Key); in asyncRequestCanceled()
1645 _asyncRequests.Remove(o.requestId); in finish()
1651 foreach(OutgoingAsyncBase o in _asyncRequests.Values) in finish()
1658 _asyncRequests.Clear(); in finish()
[all …]
/dports/devel/ice37/ice-3.7.2/csharp/src/Ice/
H A DCollocatedRequestHandler.cs54 _asyncRequests.Remove(requestId); in asyncRequestCanceled()
68 foreach(KeyValuePair<int, OutgoingAsyncBase> e in _asyncRequests) in asyncRequestCanceled()
72 _asyncRequests.Remove(e.Key); in asyncRequestCanceled()
106 if(_asyncRequests.TryGetValue(requestId, out outAsync)) in sendResponse()
113 _asyncRequests.Remove(requestId); in sendResponse()
182 _asyncRequests.Add(requestId, outAsync); in invokeAsyncRequest()
320 if(_asyncRequests.TryGetValue(requestId, out outAsync)) in handleException()
326 _asyncRequests.Remove(requestId); in handleException()
358 …private Dictionary<int, OutgoingAsyncBase> _asyncRequests = new Dictionary<int, OutgoingAsyncBase>… field in IceInternal.CollocatedRequestHandler
H A DConnectionI.cs198 while(_asyncRequests.Count != 0) in close()
363 (acm.close != ACMClose.CloseOnIdle && (_asyncRequests.Count > 0))) in monitor()
373 _asyncRequests.Count == 0) in monitor()
460 _asyncRequests[requestId] = og; in sendAsyncRequest()
803 _asyncRequests.Remove(o.requestId); in asyncRequestCanceled()
835 foreach(KeyValuePair<int, OutgoingAsyncBase> kvp in _asyncRequests) in asyncRequestCanceled()
845 _asyncRequests.Remove(kvp.Key); in asyncRequestCanceled()
1645 _asyncRequests.Remove(o.requestId); in finish()
1651 foreach(OutgoingAsyncBase o in _asyncRequests.Values) in finish()
1658 _asyncRequests.Clear(); in finish()
[all …]
/dports/devel/py-ice37/ice-3.7.2/csharp/src/Ice/
H A DCollocatedRequestHandler.cs54 _asyncRequests.Remove(requestId); in asyncRequestCanceled()
68 foreach(KeyValuePair<int, OutgoingAsyncBase> e in _asyncRequests) in asyncRequestCanceled()
72 _asyncRequests.Remove(e.Key); in asyncRequestCanceled()
106 if(_asyncRequests.TryGetValue(requestId, out outAsync)) in sendResponse()
113 _asyncRequests.Remove(requestId); in sendResponse()
182 _asyncRequests.Add(requestId, outAsync); in invokeAsyncRequest()
320 if(_asyncRequests.TryGetValue(requestId, out outAsync)) in handleException()
326 _asyncRequests.Remove(requestId); in handleException()
358 …private Dictionary<int, OutgoingAsyncBase> _asyncRequests = new Dictionary<int, OutgoingAsyncBase>… field in IceInternal.CollocatedRequestHandler
H A DConnectionI.cs198 while(_asyncRequests.Count != 0) in close()
363 (acm.close != ACMClose.CloseOnIdle && (_asyncRequests.Count > 0))) in monitor()
373 _asyncRequests.Count == 0) in monitor()
460 _asyncRequests[requestId] = og; in sendAsyncRequest()
803 _asyncRequests.Remove(o.requestId); in asyncRequestCanceled()
835 foreach(KeyValuePair<int, OutgoingAsyncBase> kvp in _asyncRequests) in asyncRequestCanceled()
845 _asyncRequests.Remove(kvp.Key); in asyncRequestCanceled()
1645 _asyncRequests.Remove(o.requestId); in finish()
1651 foreach(OutgoingAsyncBase o in _asyncRequests.Values) in finish()
1658 _asyncRequests.Clear(); in finish()
[all …]
/dports/devel/ice37/ice-3.7.2/java/src/Ice/src/main/java/com/zeroc/IceInternal/
H A DCollocatedRequestHandler.java71 _asyncRequests.remove(requestId); in asyncRequestCanceled()
83 for(java.util.Map.Entry<Integer, OutgoingAsyncBase> e : _asyncRequests.entrySet()) in asyncRequestCanceled()
87 _asyncRequests.remove(e.getKey()); in asyncRequestCanceled()
123 outAsync = _asyncRequests.remove(requestId); in sendResponse()
205 _asyncRequests.put(requestId, outAsync); in invokeAsyncRequest()
390 outAsync = _asyncRequests.remove(requestId); in handleException()
435 private java.util.Map<Integer, OutgoingAsyncBase> _asyncRequests = new java.util.HashMap<>(); field in CollocatedRequestHandler
/dports/devel/php-ice37/ice-3.7.2/java/src/Ice/src/main/java/com/zeroc/IceInternal/
H A DCollocatedRequestHandler.java71 _asyncRequests.remove(requestId); in asyncRequestCanceled()
83 for(java.util.Map.Entry<Integer, OutgoingAsyncBase> e : _asyncRequests.entrySet()) in asyncRequestCanceled()
87 _asyncRequests.remove(e.getKey()); in asyncRequestCanceled()
123 outAsync = _asyncRequests.remove(requestId); in sendResponse()
205 _asyncRequests.put(requestId, outAsync); in invokeAsyncRequest()
390 outAsync = _asyncRequests.remove(requestId); in handleException()
435 private java.util.Map<Integer, OutgoingAsyncBase> _asyncRequests = new java.util.HashMap<>(); field in CollocatedRequestHandler
/dports/devel/php-ice37/ice-3.7.2/java-compat/src/Ice/src/main/java/IceInternal/
H A DCollocatedRequestHandler.java70 _asyncRequests.remove(requestId); in asyncRequestCanceled()
84 for(java.util.Map.Entry<Integer, OutgoingAsyncBase> e : _asyncRequests.entrySet()) in asyncRequestCanceled()
88 _asyncRequests.remove(e.getKey()); in asyncRequestCanceled()
123 outAsync = _asyncRequests.remove(requestId); in sendResponse()
205 _asyncRequests.put(requestId, outAsync); in invokeAsyncRequest()
389 outAsync = _asyncRequests.remove(requestId); in handleException()
435 private java.util.Map<Integer, OutgoingAsyncBase> _asyncRequests = field in CollocatedRequestHandler
/dports/devel/ice37/ice-3.7.2/java-compat/src/Ice/src/main/java/IceInternal/
H A DCollocatedRequestHandler.java70 _asyncRequests.remove(requestId); in asyncRequestCanceled()
84 for(java.util.Map.Entry<Integer, OutgoingAsyncBase> e : _asyncRequests.entrySet()) in asyncRequestCanceled()
88 _asyncRequests.remove(e.getKey()); in asyncRequestCanceled()
123 outAsync = _asyncRequests.remove(requestId); in sendResponse()
205 _asyncRequests.put(requestId, outAsync); in invokeAsyncRequest()
389 outAsync = _asyncRequests.remove(requestId); in handleException()
435 private java.util.Map<Integer, OutgoingAsyncBase> _asyncRequests = field in CollocatedRequestHandler
/dports/devel/py-ice37/ice-3.7.2/java-compat/src/Ice/src/main/java/IceInternal/
H A DCollocatedRequestHandler.java70 _asyncRequests.remove(requestId); in asyncRequestCanceled()
84 for(java.util.Map.Entry<Integer, OutgoingAsyncBase> e : _asyncRequests.entrySet()) in asyncRequestCanceled()
88 _asyncRequests.remove(e.getKey()); in asyncRequestCanceled()
123 outAsync = _asyncRequests.remove(requestId); in sendResponse()
205 _asyncRequests.put(requestId, outAsync); in invokeAsyncRequest()
389 outAsync = _asyncRequests.remove(requestId); in handleException()
435 private java.util.Map<Integer, OutgoingAsyncBase> _asyncRequests = field in CollocatedRequestHandler
/dports/devel/py-ice37/ice-3.7.2/java/src/Ice/src/main/java/com/zeroc/IceInternal/
H A DCollocatedRequestHandler.java71 _asyncRequests.remove(requestId); in asyncRequestCanceled()
83 for(java.util.Map.Entry<Integer, OutgoingAsyncBase> e : _asyncRequests.entrySet()) in asyncRequestCanceled()
87 _asyncRequests.remove(e.getKey()); in asyncRequestCanceled()
123 outAsync = _asyncRequests.remove(requestId); in sendResponse()
205 _asyncRequests.put(requestId, outAsync); in invokeAsyncRequest()
390 outAsync = _asyncRequests.remove(requestId); in handleException()
435 private java.util.Map<Integer, OutgoingAsyncBase> _asyncRequests = new java.util.HashMap<>(); field in CollocatedRequestHandler
/dports/devel/php-ice37/ice-3.7.2/java/src/Ice/src/main/java/com/zeroc/Ice/
H A DConnectionI.java206 while(!_asyncRequests.isEmpty()) in closeImpl()
343 (acm.close != ACMClose.CloseOnIdle && (!_asyncRequests.isEmpty()))) in monitor()
352 _asyncRequests.isEmpty()) in monitor()
437 _asyncRequests.put(requestId, out); in sendAsyncRequest()
657 _asyncRequests.remove(o.requestId); in asyncRequestCanceled()
690 java.util.Iterator<OutgoingAsyncBase> it2 = _asyncRequests.values().iterator(); in asyncRequestCanceled()
1501 _asyncRequests.remove(p.requestId); in finish()
1507 for(OutgoingAsyncBase p : _asyncRequests.values()) in finish()
1514 _asyncRequests.clear(); in finish()
1737 com.zeroc.IceUtilInternal.Assert.FinalizerAssert(_asyncRequests.isEmpty()); in finalize()
[all …]
/dports/devel/ice37/ice-3.7.2/java/src/Ice/src/main/java/com/zeroc/Ice/
H A DConnectionI.java206 while(!_asyncRequests.isEmpty()) in closeImpl()
343 (acm.close != ACMClose.CloseOnIdle && (!_asyncRequests.isEmpty()))) in monitor()
352 _asyncRequests.isEmpty()) in monitor()
437 _asyncRequests.put(requestId, out); in sendAsyncRequest()
657 _asyncRequests.remove(o.requestId); in asyncRequestCanceled()
690 java.util.Iterator<OutgoingAsyncBase> it2 = _asyncRequests.values().iterator(); in asyncRequestCanceled()
1501 _asyncRequests.remove(p.requestId); in finish()
1507 for(OutgoingAsyncBase p : _asyncRequests.values()) in finish()
1514 _asyncRequests.clear(); in finish()
1737 com.zeroc.IceUtilInternal.Assert.FinalizerAssert(_asyncRequests.isEmpty()); in finalize()
[all …]
/dports/devel/py-ice37/ice-3.7.2/java/src/Ice/src/main/java/com/zeroc/Ice/
H A DConnectionI.java206 while(!_asyncRequests.isEmpty()) in closeImpl()
343 (acm.close != ACMClose.CloseOnIdle && (!_asyncRequests.isEmpty()))) in monitor()
352 _asyncRequests.isEmpty()) in monitor()
437 _asyncRequests.put(requestId, out); in sendAsyncRequest()
657 _asyncRequests.remove(o.requestId); in asyncRequestCanceled()
690 java.util.Iterator<OutgoingAsyncBase> it2 = _asyncRequests.values().iterator(); in asyncRequestCanceled()
1501 _asyncRequests.remove(p.requestId); in finish()
1507 for(OutgoingAsyncBase p : _asyncRequests.values()) in finish()
1514 _asyncRequests.clear(); in finish()
1737 com.zeroc.IceUtilInternal.Assert.FinalizerAssert(_asyncRequests.isEmpty()); in finalize()
[all …]
/dports/devel/php-ice37/ice-3.7.2/java-compat/src/Ice/src/main/java/Ice/
H A DConnectionI.java196 while(!_asyncRequests.isEmpty()) in closeImpl()
333 (acm.close != ACMClose.CloseOnIdle && (!_asyncRequests.isEmpty()))) in monitor()
342 _asyncRequests.isEmpty()) in monitor()
427 _asyncRequests.put(requestId, out); in sendAsyncRequest()
751 _asyncRequests.remove(o.requestId);
1468 if(_startCallback == null && _sendStreams.isEmpty() && _asyncRequests.isEmpty() &&
1594 _asyncRequests.remove(p.requestId);
1600 for(IceInternal.OutgoingAsyncBase p : _asyncRequests.values())
1607 _asyncRequests.clear();
1824 IceUtilInternal.Assert.FinalizerAssert(_asyncRequests.isEmpty());
[all …]
/dports/devel/ice37/ice-3.7.2/java-compat/src/Ice/src/main/java/Ice/
H A DConnectionI.java196 while(!_asyncRequests.isEmpty()) in closeImpl()
333 (acm.close != ACMClose.CloseOnIdle && (!_asyncRequests.isEmpty()))) in monitor()
342 _asyncRequests.isEmpty()) in monitor()
427 _asyncRequests.put(requestId, out); in sendAsyncRequest()
751 _asyncRequests.remove(o.requestId);
1468 if(_startCallback == null && _sendStreams.isEmpty() && _asyncRequests.isEmpty() &&
1594 _asyncRequests.remove(p.requestId);
1600 for(IceInternal.OutgoingAsyncBase p : _asyncRequests.values())
1607 _asyncRequests.clear();
1824 IceUtilInternal.Assert.FinalizerAssert(_asyncRequests.isEmpty());
[all …]
/dports/devel/py-ice37/ice-3.7.2/java-compat/src/Ice/src/main/java/Ice/
H A DConnectionI.java196 while(!_asyncRequests.isEmpty()) in closeImpl()
333 (acm.close != ACMClose.CloseOnIdle && (!_asyncRequests.isEmpty()))) in monitor()
342 _asyncRequests.isEmpty()) in monitor()
427 _asyncRequests.put(requestId, out); in sendAsyncRequest()
751 _asyncRequests.remove(o.requestId);
1468 if(_startCallback == null && _sendStreams.isEmpty() && _asyncRequests.isEmpty() &&
1594 _asyncRequests.remove(p.requestId);
1600 for(IceInternal.OutgoingAsyncBase p : _asyncRequests.values())
1607 _asyncRequests.clear();
1824 IceUtilInternal.Assert.FinalizerAssert(_asyncRequests.isEmpty());
[all …]

12