| /dports/devel/folly/folly-2021.12.27.00/folly/fibers/test/ |
| H A D | FibersTestApp.cpp | 34 if (pendingRequests.size() == maxOutstanding || toSend == 0) { in loop()
35 if (pendingRequests.empty()) { in loop()
41 pendingRequests.front().setValue(value); in loop()
42 pendingRequests.pop(); in loop()
52 pendingRequests.push(std::move(fiber)); in loop()
59 pendingRequests.push(std::move(fiber)); in loop()
75 std::queue<Promise<int>> pendingRequests; member
|
| H A D | FibersBenchmark.cpp | 37 std::queue<Promise<int>> pendingRequests; in runBenchmark() local
42 &pendingRequests, in runBenchmark()
47 if (pendingRequests.size() == maxOutstanding || toSend == 0) { in runBenchmark()
48 if (pendingRequests.empty()) { in runBenchmark()
51 pendingRequests.front().setValue(0); in runBenchmark()
52 pendingRequests.pop(); in runBenchmark()
55 [&pendingRequests]() { in runBenchmark()
57 auto result = await([&pendingRequests](Promise<int> promise) { in runBenchmark()
58 pendingRequests.push(std::move(promise)); in runBenchmark()
|
| /dports/sysutils/loganalyzer/loganalyzer-4.1.12/src/classes/phpClickHouse/src/Transport/ |
| H A D | CurlerRolling.php | 33 private $pendingRequests = []; variable in ClickHouseDB\\Transport\\CurlerRolling
106 if (!$force && isset($this->pendingRequests[$id])) {
114 $this->pendingRequests[$id] = $req;
195 return sizeof($this->pendingRequests);
276 …urn "runningRequests = {$this->runningRequests} , pending=" . sizeof($this->pendingRequests) . " ";
304 $request = $this->pendingRequests[$this->handleMapTasks[$key]];
309 $this->pendingRequests[$task_id]->setResponse($response);
310 $this->pendingRequests[$task_id]->onCallback();
314 unset($this->pendingRequests[$task_id]);
346 foreach ($this->pendingRequests as $task_id => $params) {
[all …]
|
| /dports/lang/mono/mono-5.10.1.57/mcs/class/referencesource/System.ServiceModel/System/ServiceModel/Channels/ |
| H A D | RequestChannel.cs | 78 IRequestBase[] pendingRequests = SetupWaitForPendingRequests(); in BeginWaitForPendingRequests()
79 … return new WaitForPendingRequestsAsyncResult(timeout, this, pendingRequests, callback, state); in BeginWaitForPendingRequests()
109 IRequestBase[] pendingRequests = SetupWaitForPendingRequests(); in WaitForPendingRequests()
110 if (pendingRequests != null) in WaitForPendingRequests()
114 foreach (IRequestBase request in pendingRequests) in WaitForPendingRequests()
359 IRequestBase[] pendingRequests; field in System.ServiceModel.Channels.RequestChannel.WaitForPendingRequestsAsyncResult
364 …sult(TimeSpan timeout, RequestChannel requestChannel, IRequestBase[] pendingRequests, AsyncCallbac… in WaitForPendingRequestsAsyncResult() argument
368 this.pendingRequests = pendingRequests; in WaitForPendingRequestsAsyncResult()
371 if (this.timeout == TimeSpan.Zero || this.pendingRequests == null) in WaitForPendingRequestsAsyncResult()
385 if (pendingRequests != null) in AbortRequests()
[all …]
|
| /dports/lang/spidermonkey60/firefox-60.9.0/browser/extensions/pdfjs/content/ |
| H A D | PdfJsNetwork.jsm | 58 this.pendingRequests = Object.create(null);
129 var pendingRequest = this.pendingRequests[xhrId];
147 var pendingRequest = this.pendingRequests[xhrId];
163 if (!(xhrId in this.pendingRequests)) {
169 delete this.pendingRequests[xhrId];
219 for (var xhrId in this.pendingRequests) {
226 return this.pendingRequests[xhrId].xhr;
234 return xhrId in this.pendingRequests;
242 for (var xhrId in this.pendingRequests) {
248 var xhr = this.pendingRequests[xhrId].xhr;
[all …]
|
| /dports/www/firefox-legacy/firefox-52.8.0esr/browser/extensions/pdfjs/content/ |
| H A D | PdfJsNetwork.jsm | 45 this.pendingRequests = Object.create(null);
130 var pendingRequest = this.pendingRequests[xhrId];
148 var pendingRequest = this.pendingRequests[xhrId];
164 if (!(xhrId in this.pendingRequests)) {
170 delete this.pendingRequests[xhrId];
220 for (var xhrId in this.pendingRequests) {
227 return this.pendingRequests[xhrId].xhr;
235 return xhrId in this.pendingRequests;
243 for (var xhrId in this.pendingRequests) {
249 var xhr = this.pendingRequests[xhrId].xhr;
[all …]
|
| /dports/lang/spidermonkey78/firefox-78.9.0/browser/extensions/pdfjs/content/ |
| H A D | PdfJsNetwork.jsm | 59 this.pendingRequests = Object.create(null);
80 var pendingRequest = (this.pendingRequests[xhrId] = {
123 var pendingRequest = this.pendingRequests[xhrId];
136 var pendingRequest = this.pendingRequests[xhrId];
152 if (!(xhrId in this.pendingRequests)) {
158 delete this.pendingRequests[xhrId];
206 for (var xhrId in this.pendingRequests) {
213 for (var xhrId in this.pendingRequests) {
219 var xhr = this.pendingRequests[xhrId].xhr;
220 delete this.pendingRequests[xhrId];
|
| /dports/www/firefox/firefox-99.0/toolkit/components/pdfjs/content/ |
| H A D | PdfJsNetwork.jsm | 59 this.pendingRequests = Object.create(null);
80 var pendingRequest = (this.pendingRequests[xhrId] = {
123 var pendingRequest = this.pendingRequests[xhrId];
136 var pendingRequest = this.pendingRequests[xhrId];
152 if (!(xhrId in this.pendingRequests)) {
158 delete this.pendingRequests[xhrId];
206 for (var xhrId in this.pendingRequests) {
213 for (var xhrId in this.pendingRequests) {
219 var xhr = this.pendingRequests[xhrId].xhr;
220 delete this.pendingRequests[xhrId];
|
| /dports/mail/thunderbird/thunderbird-91.8.0/toolkit/components/pdfjs/content/ |
| H A D | PdfJsNetwork.jsm | 59 this.pendingRequests = Object.create(null);
80 var pendingRequest = (this.pendingRequests[xhrId] = {
123 var pendingRequest = this.pendingRequests[xhrId];
136 var pendingRequest = this.pendingRequests[xhrId];
152 if (!(xhrId in this.pendingRequests)) {
158 delete this.pendingRequests[xhrId];
206 for (var xhrId in this.pendingRequests) {
213 for (var xhrId in this.pendingRequests) {
219 var xhr = this.pendingRequests[xhrId].xhr;
220 delete this.pendingRequests[xhrId];
|
| /dports/www/firefox-esr/firefox-91.8.0/toolkit/components/pdfjs/content/ |
| H A D | PdfJsNetwork.jsm | 59 this.pendingRequests = Object.create(null);
80 var pendingRequest = (this.pendingRequests[xhrId] = {
123 var pendingRequest = this.pendingRequests[xhrId];
136 var pendingRequest = this.pendingRequests[xhrId];
152 if (!(xhrId in this.pendingRequests)) {
158 delete this.pendingRequests[xhrId];
206 for (var xhrId in this.pendingRequests) {
213 for (var xhrId in this.pendingRequests) {
219 var xhr = this.pendingRequests[xhrId].xhr;
220 delete this.pendingRequests[xhrId];
|
| /dports/www/chromium-legacy/chromium-88.0.4324.182/third_party/perfetto/ui/src/common/ |
| H A D | wasm_engine_proxy.ts | 78 private pendingRequests = new Array<PendingRequest>(); property in WasmEngineProxy
136 this.pendingRequests.push({id, respHandler});
143 assertTrue(this.pendingRequests.length > 0);
144 const request = this.pendingRequests.shift()!;
|
| /dports/www/qt5-webengine/qtwebengine-everywhere-src-5.15.2/src/3rdparty/chromium/third_party/perfetto/ui/src/common/ |
| H A D | wasm_engine_proxy.ts | 78 private pendingRequests = new Array<PendingRequest>(); property in WasmEngineProxy
121 this.pendingRequests.push({id, respHandler});
128 assertTrue(this.pendingRequests.length > 0);
129 const request = this.pendingRequests.shift()!;
|
| /dports/java/openjdk12/openjdk-jdk12u-jdk-12.0.2-10-4/src/java.naming/share/classes/com/sun/jndi/ldap/ |
| H A D | Connection.java | 157 private LdapRequest pendingRequests = null; field in Connection
478 LdapRequest ldr = pendingRequests; in addRequest()
480 pendingRequests = ldapRequest; in addRequest()
483 ldapRequest.next = pendingRequests; in addRequest()
484 pendingRequests = ldapRequest; in addRequest()
490 LdapRequest ldr = pendingRequests; in findRequest()
502 LdapRequest ldr = pendingRequests; in removeRequest()
512 pendingRequests = ldr.next; in removeRequest()
559 LdapRequest ldr = pendingRequests; in abandonOutstandingReqs()
563 pendingRequests = ldr = ldr.next; in abandonOutstandingReqs()
[all …]
|
| /dports/java/openjdk15/jdk15u-jdk-15.0.6-1-1/src/java.naming/share/classes/com/sun/jndi/ldap/ |
| H A D | Connection.java | 157 private LdapRequest pendingRequests = null; field in Connection
469 LdapRequest ldr = pendingRequests; in addRequest()
471 pendingRequests = ldapRequest; in addRequest()
474 ldapRequest.next = pendingRequests; in addRequest()
475 pendingRequests = ldapRequest; in addRequest()
481 LdapRequest ldr = pendingRequests; in findRequest()
493 LdapRequest ldr = pendingRequests; in removeRequest()
503 pendingRequests = ldr.next; in removeRequest()
550 LdapRequest ldr = pendingRequests; in abandonOutstandingReqs()
554 pendingRequests = ldr = ldr.next; in abandonOutstandingReqs()
[all …]
|
| /dports/java/openjdk14/jdk14u-jdk-14.0.2-12-1/src/java.naming/share/classes/com/sun/jndi/ldap/ |
| H A D | Connection.java | 157 private LdapRequest pendingRequests = null; field in Connection
450 LdapRequest ldr = pendingRequests; in addRequest()
452 pendingRequests = ldapRequest; in addRequest()
455 ldapRequest.next = pendingRequests; in addRequest()
456 pendingRequests = ldapRequest; in addRequest()
462 LdapRequest ldr = pendingRequests; in findRequest()
474 LdapRequest ldr = pendingRequests; in removeRequest()
484 pendingRequests = ldr.next; in removeRequest()
531 LdapRequest ldr = pendingRequests; in abandonOutstandingReqs()
535 pendingRequests = ldr = ldr.next; in abandonOutstandingReqs()
[all …]
|
| /dports/java/openjdk11/jdk11u-jdk-11.0.13-8-1/src/java.naming/share/classes/com/sun/jndi/ldap/ |
| H A D | Connection.java | 165 private LdapRequest pendingRequests = null; field in Connection
478 LdapRequest ldr = pendingRequests; in addRequest()
480 pendingRequests = ldapRequest; in addRequest()
483 ldapRequest.next = pendingRequests; in addRequest()
484 pendingRequests = ldapRequest; in addRequest()
490 LdapRequest ldr = pendingRequests; in findRequest()
502 LdapRequest ldr = pendingRequests; in removeRequest()
512 pendingRequests = ldr.next; in removeRequest()
559 LdapRequest ldr = pendingRequests; in abandonOutstandingReqs()
563 pendingRequests = ldr = ldr.next; in abandonOutstandingReqs()
[all …]
|
| /dports/java/openjdk13/jdk13u-jdk-13.0.10-1-1/src/java.naming/share/classes/com/sun/jndi/ldap/ |
| H A D | Connection.java | 165 private LdapRequest pendingRequests = null; field in Connection
478 LdapRequest ldr = pendingRequests; in addRequest()
480 pendingRequests = ldapRequest; in addRequest()
483 ldapRequest.next = pendingRequests; in addRequest()
484 pendingRequests = ldapRequest; in addRequest()
490 LdapRequest ldr = pendingRequests; in findRequest()
502 LdapRequest ldr = pendingRequests; in removeRequest()
512 pendingRequests = ldr.next; in removeRequest()
559 LdapRequest ldr = pendingRequests; in abandonOutstandingReqs()
563 pendingRequests = ldr = ldr.next; in abandonOutstandingReqs()
[all …]
|
| /dports/java/openjdk11-jre/jdk11u-jdk-11.0.13-8-1/src/java.naming/share/classes/com/sun/jndi/ldap/ |
| H A D | Connection.java | 165 private LdapRequest pendingRequests = null; field in Connection
478 LdapRequest ldr = pendingRequests; in addRequest()
480 pendingRequests = ldapRequest; in addRequest()
483 ldapRequest.next = pendingRequests; in addRequest()
484 pendingRequests = ldapRequest; in addRequest()
490 LdapRequest ldr = pendingRequests; in findRequest()
502 LdapRequest ldr = pendingRequests; in removeRequest()
512 pendingRequests = ldr.next; in removeRequest()
559 LdapRequest ldr = pendingRequests; in abandonOutstandingReqs()
563 pendingRequests = ldr = ldr.next; in abandonOutstandingReqs()
[all …]
|
| /dports/java/openjdk8/jdk8u-jdk8u312-b07.1/jdk/src/share/classes/com/sun/jndi/ldap/ |
| H A D | Connection.java | 154 private LdapRequest pendingRequests = null; field in Connection
504 LdapRequest ldr = pendingRequests; in addRequest()
506 pendingRequests = ldapRequest; in addRequest()
509 ldapRequest.next = pendingRequests; in addRequest()
510 pendingRequests = ldapRequest; in addRequest()
516 LdapRequest ldr = pendingRequests; in findRequest()
528 LdapRequest ldr = pendingRequests; in removeRequest()
538 pendingRequests = ldr.next; in removeRequest()
585 LdapRequest ldr = pendingRequests; in abandonOutstandingReqs()
589 pendingRequests = ldr = ldr.next; in abandonOutstandingReqs()
[all …]
|
| /dports/java/openjdk16/jdk16u-jdk-16.0.2-7-1/src/java.naming/share/classes/com/sun/jndi/ldap/ |
| H A D | Connection.java | 165 private LdapRequest pendingRequests = null; field in Connection
478 LdapRequest ldr = pendingRequests; in addRequest()
480 pendingRequests = ldapRequest; in addRequest()
483 ldapRequest.next = pendingRequests; in addRequest()
484 pendingRequests = ldapRequest; in addRequest()
490 LdapRequest ldr = pendingRequests; in findRequest()
502 LdapRequest ldr = pendingRequests; in removeRequest()
512 pendingRequests = ldr.next; in removeRequest()
559 LdapRequest ldr = pendingRequests; in abandonOutstandingReqs()
563 pendingRequests = ldr = ldr.next; in abandonOutstandingReqs()
[all …]
|
| /dports/java/openjdk17/jdk17u-jdk-17.0.1-12-1/src/java.naming/share/classes/com/sun/jndi/ldap/ |
| H A D | Connection.java | 165 private LdapRequest pendingRequests = null; field in Connection
479 LdapRequest ldr = pendingRequests; in addRequest()
481 pendingRequests = ldapRequest; in addRequest()
484 ldapRequest.next = pendingRequests; in addRequest()
485 pendingRequests = ldapRequest; in addRequest()
491 LdapRequest ldr = pendingRequests; in findRequest()
503 LdapRequest ldr = pendingRequests; in removeRequest()
513 pendingRequests = ldr.next; in removeRequest()
560 LdapRequest ldr = pendingRequests; in abandonOutstandingReqs()
564 pendingRequests = ldr = ldr.next; in abandonOutstandingReqs()
[all …]
|
| /dports/java/openjdk8-jre/jdk8u-jdk8u312-b07.1/jdk/src/share/classes/com/sun/jndi/ldap/ |
| H A D | Connection.java | 154 private LdapRequest pendingRequests = null; field in Connection
504 LdapRequest ldr = pendingRequests; in addRequest()
506 pendingRequests = ldapRequest; in addRequest()
509 ldapRequest.next = pendingRequests; in addRequest()
510 pendingRequests = ldapRequest; in addRequest()
516 LdapRequest ldr = pendingRequests; in findRequest()
528 LdapRequest ldr = pendingRequests; in removeRequest()
538 pendingRequests = ldr.next; in removeRequest()
585 LdapRequest ldr = pendingRequests; in abandonOutstandingReqs()
589 pendingRequests = ldr = ldr.next; in abandonOutstandingReqs()
[all …]
|
| /dports/databases/akonadi/akonadi-21.12.3/src/server/storage/ |
| H A D | itemretriever.cpp | 202 std::vector<ItemRetrievalRequest::Id> pendingRequests; in runItemRetrievalRequests() local
206 …[this, &eventLoop, &pendingRequests](const ItemRetrievalResult &result) { // clazy:exclude=lambda-… in runItemRetrievalRequests()
207 …const auto requestId = std::find(pendingRequests.begin(), pendingRequests.end(), result.request.id… in runItemRetrievalRequests()
208 if (requestId != pendingRequests.end()) { in runItemRetrievalRequests()
216 pendingRequests.erase(requestId); in runItemRetrievalRequests()
217 if (pendingRequests.empty()) { in runItemRetrievalRequests()
241 pendingRequests.push_back(request.id); in runItemRetrievalRequests()
250 if (!pendingRequests.empty()) { in runItemRetrievalRequests()
|
| /dports/devel/libzookeeper/apache-zookeeper-3.7.0/zookeeper-server/src/main/java/org/apache/zookeeper/server/quorum/ |
| H A D | CommitProcessor.java | 120 protected final Map<Long, Deque<Request>> pendingRequests = new HashMap<>(10000); field in CommitProcessor
252 if (needCommit(request) || pendingRequests.containsKey(request.sessionId)) { in run()
254 …Deque<Request> requests = pendingRequests.computeIfAbsent(request.sessionId, sid -> new ArrayDeque… in run()
273 … if (maxReadBatchSize < 0 && !pendingRequests.isEmpty() && !committedRequests.isEmpty()) { in run()
332 Deque<Request> sessionQueue = pendingRequests.get(request.sessionId); in run()
333 … ServerMetrics.getMetrics().PENDING_SESSION_QUEUE_SIZE.add(pendingRequests.size()); in run()
395 Deque<Request> sessionQueue = pendingRequests.get(sessionId); in run()
407 pendingRequests.remove(sessionId); in run()
|
| /dports/emulators/mgba/mgba-0.9.2/src/core/ |
| H A D | thread.c | 227 int pendingRequests = 0; in _mCoreThreadRun() local
267 impl->requested &= ~pendingRequests | mTHREAD_REQ_PAUSE | mTHREAD_REQ_WAIT; in _mCoreThreadRun()
268 pendingRequests = impl->requested; in _mCoreThreadRun()
271 if (pendingRequests) { in _mCoreThreadRun()
272 if (pendingRequests & mTHREAD_REQ_PAUSE) { in _mCoreThreadRun()
275 if (pendingRequests & mTHREAD_REQ_WAIT) { in _mCoreThreadRun()
286 if (!wasPaused && (pendingRequests & mTHREAD_REQ_PAUSE)) { in _mCoreThreadRun()
292 if (wasPaused && !(pendingRequests & mTHREAD_REQ_PAUSE)) { in _mCoreThreadRun()
298 if (pendingRequests & mTHREAD_REQ_RESET) { in _mCoreThreadRun()
304 if (pendingRequests & mTHREAD_REQ_RUN_ON) { in _mCoreThreadRun()
|