Searched refs:pending_jobs (Results 1 – 4 of 4) sorted by relevance
| /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/libgav1/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 | 223 int pending_jobs LIBGAV1_GUARDED_BY(mutex) = 0;
|
| /external/libgav1/libgav1/src/tile/ |
| D | tile.cc | 758 ++threading_.pending_jobs; in ThreadedParseAndDecode()
787 ++threading_.pending_jobs; in ThreadedParseAndDecode()
809 const bool no_pending_jobs = (--threading_.pending_jobs == 0); in ThreadedParseAndDecode()
886 ++threading_.pending_jobs; in DecodeSuperBlock()
903 const bool no_pending_jobs = (--threading_.pending_jobs == 0); in DecodeSuperBlock()
|