Home
last modified time | relevance | path

Searched refs:pending_workers (Results 1 – 4 of 4) sorted by relevance

/external/libgav1/libgav1/src/post_filter/
Dsuper_res.cc167 BlockingCounter pending_workers(num_threads - 1); in ApplySuperResThreaded() local
199 [this, src, rows, line_buffer_row, dst, &pending_workers]() { in ApplySuperResThreaded()
201 pending_workers.Decrement(); in ApplySuperResThreaded()
208 pending_workers.Wait(); in ApplySuperResThreaded()
Dpost_filter.cc520 BlockingCounter pending_workers(num_workers); in RunJobs() local
522 thread_pool_->Schedule([this, &row4x4, &pending_workers, worker]() { in RunJobs()
524 pending_workers.Decrement(); in RunJobs()
530 pending_workers.Wait(); in RunJobs()
/external/libgav1/libgav1/src/
Dfilm_grain.cc737 BlockingCounter pending_workers(num_workers); in AddNoise() local
740 thread_pool_->Schedule([this, dsp, &pending_workers, &planes_to_blend, in AddNoise()
750 pending_workers.Decrement(); in AddNoise()
758 pending_workers.Wait(); in AddNoise()
780 BlockingCounter pending_workers(num_workers); in AddNoise() local
784 [this, dsp, &pending_workers, &job_counter, min_value, max_luma, in AddNoise()
789 pending_workers.Decrement(); in AddNoise()
796 pending_workers.Wait(); in AddNoise()
Ddecoder_impl.cc162 BlockingCounterWithStatus pending_workers(num_workers); in DecodeTilesThreadedNonFrameParallel() local
170 &pending_workers, in DecodeTilesThreadedNonFrameParallel()
186 pending_workers.Decrement(!failed); in DecodeTilesThreadedNonFrameParallel()
205 tile_decoding_failed |= !pending_workers.Wait(); in DecodeTilesThreadedNonFrameParallel()