Home
last modified time | relevance | path

Searched refs:pending_jobs (Results 1 – 25 of 127) sorted by relevance

123456

/dports/www/qt5-webengine/qtwebengine-everywhere-src-5.15.2/src/3rdparty/chromium/net/proxy_resolution/
H A Dconfigured_proxy_resolution_service_unittest.cc921 resolver.pending_jobs()[0]->CompleteNow(OK); in TEST_F()
1013 resolver.pending_jobs()[0]->CompleteNow(OK); in TEST_F()
1122 resolver.pending_jobs()[0]->CompleteNow(OK); in TEST_F()
1173 resolver.pending_jobs()[0]->CompleteNow(OK); in TEST_F()
1243 resolver.pending_jobs()[0]->CompleteNow(OK); in TEST_F()
1315 resolver.pending_jobs()[0]->CompleteNow(OK); in TEST_F()
1553 resolver.pending_jobs()[0]->CompleteNow(OK); in TEST_F()
1595 resolver.pending_jobs()[0]->CompleteNow(OK); in TEST_F()
1639 resolver.pending_jobs()[0]->CompleteNow(OK); in TEST_F()
1686 resolver.pending_jobs()[0]->CompleteNow(OK); in TEST_F()
[all …]
/dports/www/chromium-legacy/chromium-88.0.4324.182/net/proxy_resolution/
H A Dconfigured_proxy_resolution_service_unittest.cc894 resolver.pending_jobs()[0]->CompleteNow(OK); in TEST_F()
987 resolver.pending_jobs()[0]->CompleteNow(OK); in TEST_F()
1096 resolver.pending_jobs()[0]->CompleteNow(OK); in TEST_F()
1148 resolver.pending_jobs()[0]->CompleteNow(OK); in TEST_F()
1218 resolver.pending_jobs()[0]->CompleteNow(OK); in TEST_F()
1291 resolver.pending_jobs()[0]->CompleteNow(OK); in TEST_F()
1533 resolver.pending_jobs()[0]->CompleteNow(OK); in TEST_F()
1576 resolver.pending_jobs()[0]->CompleteNow(OK); in TEST_F()
1620 resolver.pending_jobs()[0]->CompleteNow(OK); in TEST_F()
1667 resolver.pending_jobs()[0]->CompleteNow(OK); in TEST_F()
[all …]
/dports/devel/dispy/dispy-4.10.6/py2/dispy/examples/
H A Dbounded_submit.py28 global pending_jobs, jobs_cond
36 pending_jobs.pop(job.id)
38 if len(pending_jobs) <= lower_bound:
52 pending_jobs = {} variable
60 pending_jobs[i] = job
62 if len(pending_jobs) >= upper_bound:
63 while len(pending_jobs) > lower_bound:
/dports/devel/dispy/dispy-4.10.6/py3.7/dispy/examples/
H A Dbounded_submit.py28 global pending_jobs, jobs_cond
36 pending_jobs.pop(job.id)
38 if len(pending_jobs) <= lower_bound:
52 pending_jobs = {} variable
60 pending_jobs[i] = job
62 if len(pending_jobs) >= upper_bound:
63 while len(pending_jobs) > lower_bound:
/dports/devel/dispy/dispy-4.10.6/py3/dispy/examples/
H A Dbounded_submit.py28 global pending_jobs, jobs_cond
36 pending_jobs.pop(job.id)
38 if len(pending_jobs) <= lower_bound:
52 pending_jobs = {} variable
60 pending_jobs[i] = job
62 if len(pending_jobs) >= upper_bound:
63 while len(pending_jobs) > lower_bound:
/dports/www/chromium-legacy/chromium-88.0.4324.182/content/browser/service_worker/
H A Dservice_worker_job_coordinator.cc138 auto pending_jobs = job_queues_.find(scope); in Abort() local
139 if (pending_jobs == job_queues_.end()) in Abort()
141 pending_jobs->second.AbortAll(); in Abort()
142 job_queues_.erase(pending_jobs); in Abort()
159 auto pending_jobs = job_queues_.find(scope); in FinishJob() local
160 DCHECK(pending_jobs != job_queues_.end()) << "Deleting non-existent job."; in FinishJob()
161 pending_jobs->second.Pop(job); in FinishJob()
162 if (pending_jobs->second.empty()) in FinishJob()
163 job_queues_.erase(pending_jobs); in FinishJob()
/dports/www/qt5-webengine/qtwebengine-everywhere-src-5.15.2/src/3rdparty/chromium/content/browser/service_worker/
H A Dservice_worker_job_coordinator.cc138 auto pending_jobs = job_queues_.find(scope); in Abort() local
139 if (pending_jobs == job_queues_.end()) in Abort()
141 pending_jobs->second.AbortAll(); in Abort()
142 job_queues_.erase(pending_jobs); in Abort()
159 auto pending_jobs = job_queues_.find(scope); in FinishJob() local
160 DCHECK(pending_jobs != job_queues_.end()) << "Deleting non-existent job."; in FinishJob()
161 pending_jobs->second.Pop(job); in FinishJob()
162 if (pending_jobs->second.empty()) in FinishJob()
163 job_queues_.erase(pending_jobs); in FinishJob()
/dports/multimedia/libde265/libde265-1.0.2/scripts/
H A Ddecodestreams.py104 self.pending_jobs = []
112 self.pending_jobs.append(job)
118 self.pending_jobs = [x for x in self.pending_jobs if not x.ready()]
121 job = self.pending_jobs[0]
131 self.pending_jobs.pop(0)
134 self.pending_jobs.pop(0)
152 prev_remaining = len(self.pending_jobs)
153 while self.pending_jobs:
156 remaining = len(self.pending_jobs)
/dports/devel/py-os-win/os-win-5.5.0/os_win/utils/
H A Djobutils.py166 pending_jobs = []
171 pending_jobs.append(mapping.AffectingElement)
178 return pending_jobs
181 pending_jobs = self._get_pending_jobs_affecting_element(element)
182 for job in pending_jobs:
199 pending_jobs = self._get_pending_jobs_affecting_element(element)
200 if pending_jobs:
202 for job in pending_jobs]
208 pending_count=len(pending_jobs),
209 pending_jobs=pending_job_details))
/dports/games/openage/openage-0.3.0-1262-ga554ab49/libopenage/job/
H A Dworker.cpp35 this->pending_jobs.push(job); in enqueue()
77 while (this->pending_jobs.empty() and not this->manager->has_job()) { in process()
89 if (not this->pending_jobs.empty()) { in process()
91 auto job = this->pending_jobs.front(); in process()
92 this->pending_jobs.pop(); in process()
H A Djob_manager.cpp92 this->pending_jobs.push(state); in enqueue_state()
101 if (this->pending_jobs.empty()) { in fetch_job()
105 auto job = this->pending_jobs.front(); in fetch_job()
106 this->pending_jobs.pop(); in fetch_job()
113 return not this->pending_jobs.empty(); in has_job()
/dports/www/qt5-webengine/qtwebengine-everywhere-src-5.15.2/src/3rdparty/chromium/services/proxy_resolver/
H A Dproxy_resolver_impl_unittest.cc173 const std::vector<std::unique_ptr<Job>>& pending_jobs() { in pending_jobs() function in proxy_resolver::__anon34bca44c0111::MockProxyResolverV8Tracing
239 ASSERT_EQ(1u, mock_proxy_resolver_->pending_jobs().size()); in TEST_F()
241 mock_proxy_resolver_->pending_jobs()[0].get(); in TEST_F()
290 ASSERT_EQ(1u, mock_proxy_resolver_->pending_jobs().size()); in TEST_F()
292 mock_proxy_resolver_->pending_jobs()[0].get(); in TEST_F()
304 ASSERT_EQ(1u, mock_proxy_resolver_->pending_jobs().size()); in TEST_F()
306 mock_proxy_resolver_->pending_jobs()[0].get(); in TEST_F()
329 ASSERT_EQ(2u, mock_proxy_resolver_->pending_jobs().size()); in TEST_F()
331 mock_proxy_resolver_->pending_jobs()[0].get(); in TEST_F()
334 mock_proxy_resolver_->pending_jobs()[1].get(); in TEST_F()
[all …]
/dports/www/chromium-legacy/chromium-88.0.4324.182/services/proxy_resolver/
H A Dproxy_resolver_impl_unittest.cc173 const std::vector<std::unique_ptr<Job>>& pending_jobs() { in pending_jobs() function in proxy_resolver::__anone1e700d10111::MockProxyResolverV8Tracing
239 ASSERT_EQ(1u, mock_proxy_resolver_->pending_jobs().size()); in TEST_F()
241 mock_proxy_resolver_->pending_jobs()[0].get(); in TEST_F()
290 ASSERT_EQ(1u, mock_proxy_resolver_->pending_jobs().size()); in TEST_F()
292 mock_proxy_resolver_->pending_jobs()[0].get(); in TEST_F()
304 ASSERT_EQ(1u, mock_proxy_resolver_->pending_jobs().size()); in TEST_F()
306 mock_proxy_resolver_->pending_jobs()[0].get(); in TEST_F()
329 ASSERT_EQ(2u, mock_proxy_resolver_->pending_jobs().size()); in TEST_F()
331 mock_proxy_resolver_->pending_jobs()[0].get(); in TEST_F()
334 mock_proxy_resolver_->pending_jobs()[1].get(); in TEST_F()
[all …]
/dports/www/chromium-legacy/chromium-88.0.4324.182/chrome/browser/chromeos/extensions/printing/
H A Dprint_job_controller.cc198 auto& pending_jobs = it->second; in OnPrintJobCreated() local
199 if (!pending_jobs.empty()) { in OnPrintJobCreated()
203 print_jobs_map_[job_id] = pending_jobs.front().job; in OnPrintJobCreated()
206 auto callback = std::move(pending_jobs.front().callback); in OnPrintJobCreated()
207 pending_jobs.pop(); in OnPrintJobCreated()
208 if (pending_jobs.empty()) in OnPrintJobCreated()
/dports/sysutils/consolekit2/ConsoleKit2-520b862/src/
H A Dck-session-leader.c69 GList *pending_jobs; member
115 if (leader->priv->pending_jobs != NULL) { in ck_session_leader_cancel()
116 g_list_foreach (leader->priv->pending_jobs, (GFunc)remove_pending_job, NULL); in ck_session_leader_cancel()
117 g_list_free (leader->priv->pending_jobs); in ck_session_leader_cancel()
118 leader->priv->pending_jobs = NULL; in ck_session_leader_cancel()
394 data->leader->priv->pending_jobs = g_list_remove (data->leader->priv->pending_jobs, job); in job_completed()
474 … session_leader->priv->pending_jobs = g_list_prepend (session_leader->priv->pending_jobs, job); in ck_session_leader_collect_parameters()
/dports/www/qt5-webengine/qtwebengine-everywhere-src-5.15.2/src/3rdparty/chromium/storage/browser/quota/
H A Dclient_usage_tracker.cc66 size_t pending_jobs = 0; member
108 info->pending_jobs = non_cached_limited_origins_by_host_.size() + 1; in GetGlobalLimitedUsage()
263 DCHECK_GT(info->pending_jobs, 0U); in AccumulateLimitedOriginUsage()
266 if (--info->pending_jobs) in AccumulateLimitedOriginUsage()
288 info->pending_jobs = origins_by_host.size() + 1; in DidGetOriginsForGlobalUsage()
308 DCHECK_GT(info->pending_jobs, 0U); in AccumulateHostUsage()
312 if (--info->pending_jobs) in AccumulateHostUsage()
340 info->pending_jobs = origins.size() + 1; in GetUsageForOrigins()
366 DCHECK_GT(info->pending_jobs, 0U); in AccumulateOriginUsage()
389 if (--info->pending_jobs) in AccumulateOriginUsage()
/dports/emulators/qemu-powernv/qemu-powernv-3.0.50/tests/qemu-iotests/
H A D030208 pending_jobs = []
212 pending_jobs.append(job_id)
217 while len(pending_jobs) > 0:
221 self.assertTrue(job_id in pending_jobs)
223 pending_jobs.remove(job_id)
333 pending_jobs = ['node2', 'drive0']
334 while len(pending_jobs) > 0:
340 pending_jobs.remove(node_name)
365 pending_jobs = ['node4', 'drive0']
366 while len(pending_jobs) > 0:
[all …]
/dports/emulators/qemu-utils/qemu-4.2.1/tests/qemu-iotests/
H A D030236 pending_jobs = []
240 pending_jobs.append(job_id)
244 for job in pending_jobs:
249 while len(pending_jobs) > 0:
255 pending_jobs.remove(job_id)
434 pending_jobs = ['node2', 'drive0']
435 while len(pending_jobs) > 0:
441 pending_jobs.remove(node_name)
470 pending_jobs = ['node4', 'drive0']
471 while len(pending_jobs) > 0:
[all …]
/dports/emulators/qemu5/qemu-5.2.0/tests/qemu-iotests/
H A D030243 pending_jobs = []
247 pending_jobs.append(job_id)
251 for job in pending_jobs:
256 while len(pending_jobs) > 0:
262 pending_jobs.remove(job_id)
441 pending_jobs = ['node2', 'drive0']
442 while len(pending_jobs) > 0:
448 pending_jobs.remove(node_name)
477 pending_jobs = ['node4', 'drive0']
478 while len(pending_jobs) > 0:
[all …]
/dports/emulators/qemu-guest-agent/qemu-5.0.1/tests/qemu-iotests/
H A D030236 pending_jobs = []
240 pending_jobs.append(job_id)
244 for job in pending_jobs:
249 while len(pending_jobs) > 0:
255 pending_jobs.remove(job_id)
434 pending_jobs = ['node2', 'drive0']
435 while len(pending_jobs) > 0:
441 pending_jobs.remove(node_name)
470 pending_jobs = ['node4', 'drive0']
471 while len(pending_jobs) > 0:
[all …]
/dports/emulators/qemu42/qemu-4.2.1/tests/qemu-iotests/
H A D030236 pending_jobs = []
240 pending_jobs.append(job_id)
244 for job in pending_jobs:
249 while len(pending_jobs) > 0:
255 pending_jobs.remove(job_id)
434 pending_jobs = ['node2', 'drive0']
435 while len(pending_jobs) > 0:
441 pending_jobs.remove(node_name)
470 pending_jobs = ['node4', 'drive0']
471 while len(pending_jobs) > 0:
[all …]
/dports/emulators/qemu-cheri/qemu-0a323821042c36e21ea80e58b9545dfc3b0cb8ef/tests/qemu-iotests/
H A D030236 pending_jobs = []
240 pending_jobs.append(job_id)
244 for job in pending_jobs:
249 while len(pending_jobs) > 0:
255 pending_jobs.remove(job_id)
434 pending_jobs = ['node2', 'drive0']
435 while len(pending_jobs) > 0:
441 pending_jobs.remove(node_name)
470 pending_jobs = ['node4', 'drive0']
471 while len(pending_jobs) > 0:
[all …]
/dports/emulators/qemu-devel/qemu-de8ed1055c2ce18c95f597eb10df360dcb534f99/tests/qemu-iotests/
H A D030244 pending_jobs = []
248 pending_jobs.append(job_id)
254 for job in pending_jobs:
259 while len(pending_jobs) > 0:
265 pending_jobs.remove(job_id)
446 pending_jobs = ['node2', 'drive0']
447 while len(pending_jobs) > 0:
453 pending_jobs.remove(node_name)
482 pending_jobs = ['node4', 'drive0']
483 while len(pending_jobs) > 0:
[all …]
/dports/emulators/qemu/qemu-6.2.0/tests/qemu-iotests/
H A D030244 pending_jobs = []
248 pending_jobs.append(job_id)
263 for job in reversed(pending_jobs):
268 while len(pending_jobs) > 0:
274 pending_jobs.remove(job_id)
455 pending_jobs = ['node2', 'drive0']
456 while len(pending_jobs) > 0:
462 pending_jobs.remove(node_name)
491 pending_jobs = ['node4', 'drive0']
492 while len(pending_jobs) > 0:
[all …]
/dports/emulators/qemu60/qemu-6.0.0/tests/qemu-iotests/
H A D030244 pending_jobs = []
248 pending_jobs.append(job_id)
254 for job in pending_jobs:
259 while len(pending_jobs) > 0:
265 pending_jobs.remove(job_id)
446 pending_jobs = ['node2', 'drive0']
447 while len(pending_jobs) > 0:
453 pending_jobs.remove(node_name)
482 pending_jobs = ['node4', 'drive0']
483 while len(pending_jobs) > 0:
[all …]

123456