Searched refs:pending_jobs (Results 1 – 9 of 9) sorted by relevance
| /external/cronet/net/proxy_resolution/ |
| D | configured_proxy_resolution_service_unittest.cc | 329 for (MockAsyncProxyResolver::Job* it : resolver.pending_jobs()) { in GetPendingJobsForURLs()
589 ASSERT_EQ(2u, resolver.pending_jobs().size()); in TEST_F()
594 if (resolver.pending_jobs()[i]->url() == url) { in TEST_F()
602 resolver.pending_jobs()[deleting_job]->results()->UseNamedProxy("foopy"); in TEST_F()
603 resolver.pending_jobs()[deleting_job]->CompleteNow(OK); in TEST_F()
609 ASSERT_EQ(0u, resolver.pending_jobs().size()); in TEST_F()
711 ASSERT_EQ(3u, resolver.pending_jobs().size()); in TEST_F()
716 if (resolver.pending_jobs()[i]->url() == url2) { in TEST_F()
724 resolver.pending_jobs()[self_deleting_job]->results()->UseNamedProxy("foopy"); in TEST_F()
725 resolver.pending_jobs()[self_deleting_job]->CompleteNow(OK); in TEST_F()
[all …]
|
| D | mock_proxy_resolver.h | 69 const std::vector<Job*>& pending_jobs() const { return pending_jobs_; } in pending_jobs() function
|
| /external/wmediumd/wmediumd/inc/usfstl/ |
| D | sched.h | 97 struct usfstl_list pending_jobs; member
129 .pending_jobs = USFSTL_LIST_INIT(name.pending_jobs), \
|
| /external/crosvm/media/cros-codecs/src/utils/ |
| D | vaapi.rs | 652 pub(crate) pending_jobs: VecDeque<Rc<RefCell<GenericBackendHandle>>>, field
662 pending_jobs: Default::default(), in new()
682 BlockingMode::NonBlocking => self.pending_jobs.push_back(Rc::clone(&handle)), in process_picture()
777 let candidates = self.pending_jobs.drain(..).collect::<VecDeque<_>>(); in poll()
782 self.pending_jobs.push_back(job); in poll()
807 for i in 0..self.pending_jobs.len() { in block_on_handle()
809 let job = &self.pending_jobs[i]; in block_on_handle()
812 let job = self.pending_jobs.remove(i).unwrap(); in block_on_handle()
|
| /external/perfetto/infra/ci/controller/ |
| D | controller.py | 266 pending_jobs = []
269 pending_jobs += [job_id] if job_status in ('QUEUED', 'STARTED') else []
271 if pending_jobs:
279 map(lambda x: defer('cancel_job', job_id=x), pending_jobs)
|
| /external/wmediumd/wmediumd/lib/ |
| D | sched.c | 82 usfstl_list_append(&sched->pending_jobs, &job->entry); in usfstl_sched_add_job()
267 usfstl_list_append(&sched->pending_jobs, &job->entry); in usfstl_sched_block_job()
303 usfstl_for_each_list_item_continue_safe(job, next, &sched->pending_jobs, in usfstl_sched_restore_blocked_jobs()
|
| /external/libgav1/src/ |
| D | decoder_impl.cc | 343 PostFilter* const post_filter, BlockingCounter* const pending_jobs) { in DecodeSuperBlockRowInTile() argument
402 pending_jobs->IncrementBy(1); in DecodeSuperBlockRowInTile()
405 post_filter, pending_jobs]() { in DecodeSuperBlockRowInTile()
408 frame_scratch_buffer, post_filter, pending_jobs); in DecodeSuperBlockRowInTile()
409 pending_jobs->Decrement(); in DecodeSuperBlockRowInTile()
492 BlockingCounter pending_jobs( in DecodeTilesThreadedFrameParallel() local
498 thread_pool.Schedule([&tiles, tile_count, &tile_counter, &pending_jobs, in DecodeTilesThreadedFrameParallel()
516 pending_jobs.Decrement(); in DecodeTilesThreadedFrameParallel()
524 &pending_jobs]() { in DecodeTilesThreadedFrameParallel()
527 frame_scratch_buffer, post_filter, &pending_jobs); in DecodeTilesThreadedFrameParallel()
[all …]
|
| D | tile.h | 225 int pending_jobs LIBGAV1_GUARDED_BY(mutex) = 0;
|
| /external/libgav1/src/tile/ |
| D | tile.cc | 753 ++threading_.pending_jobs; in ThreadedParseAndDecode()
782 ++threading_.pending_jobs; in ThreadedParseAndDecode()
804 const bool no_pending_jobs = (--threading_.pending_jobs == 0); in ThreadedParseAndDecode()
881 ++threading_.pending_jobs; in DecodeSuperBlock()
898 const bool no_pending_jobs = (--threading_.pending_jobs == 0); in DecodeSuperBlock()
|