| /system/cros-codecs/src/c2_wrapper/ |
| D | c2_encoder.rs | 25 use crate::c2_wrapper::Job;
98 let mut job = self.in_flight_queue.pop_front().unwrap(); in poll_complete_frames() localVariable
99 job.output = coded.bitstream; in poll_complete_frames()
100 (*self.work_done_cb.lock().unwrap())(job); in poll_complete_frames()
165 .expect("Failed to add job event to Epoll"); in process_loop()
183 let mut job = (*self.work_queue.lock().unwrap()) in process_loop() localVariable
185 .expect("Missing job from work queue!"); in process_loop()
186 if job.get_drain() != DrainMode::NoDrain { in process_loop()
193 if job.get_drain() == DrainMode::EOSDrain { in process_loop()
197 let frame_y_stride = job.input.as_ref().unwrap().get_plane_pitch()[0]; in process_loop()
[all …]
|
| D | c2_decoder.rs | 27 use crate::c2_wrapper::Job;
272 // Poll for decoder events or pending job events. in process_loop()
284 while let Some(mut job) = possible_job { in process_loop()
285 let bitstream = job.input.as_slice(); in process_loop()
286 let decode_result = if !job.input.is_empty() { in process_loop()
289 job.timestamp, in process_loop()
294 decoder.decode(job.timestamp, bitstream, &mut || { in process_loop()
307 if num_bytes != job.input.len() { in process_loop()
308 job.input = (&job.input[num_bytes..]).to_vec(); in process_loop()
309 (*self.work_queue.lock().unwrap()).push_front(job); in process_loop()
[all …]
|
| /system/security/keystore2/src/async_task/ |
| D | tests.rs | 77 // First queue up a job that blocks until we release it, to avoid in test_async_task()
100 // Finally queue up a low priority job that emits the trace. in test_async_task()
118 // Queue up a job that will queue up another job. This confirms in test_async_task_chain()
119 // that the job is not invoked with any internal AsyncTask locks held. in test_async_task_chain()
134 panic!("Panic from queued job"); in test_async_task_panic()
136 // Queue another job afterwards to ensure that the async thread gets joined. in test_async_task_panic()
162 // Final low-priority job. in test_async_task_idle()
168 // Nothing happens until the last job completes. in test_async_task_idle()
174 // Now that the last low-priority job has completed, the idle task should in test_async_task_idle()
191 // job is taking a while. in test_async_task_idle()
[all …]
|
| /system/cros-codecs/src/ |
| D | c2_wrapper.rs | 59 impl<V> Job for C2DecodeJob<V>
80 pub trait Job: Send + 'static { interface
115 impl<V> Job for C2EncodeJob<V>
153 J: Send + Job + 'static,
166 alloc_cb: Arc<Mutex<dyn FnMut() -> Option<<J as Job>::Frame> + Send + 'static>>, in new()
177 #[error("failed to create EventFd for awaiting job event: {0}")]
184 J: Send + Default + Job + 'static,
195 alloc_cb: Arc<Mutex<dyn FnMut() -> Option<<J as Job>::Frame> + Send + 'static>>,
205 J: Send + Default + Job + 'static,
214 alloc_cb: impl FnMut() -> Option<<J as Job>::Frame> + Send + 'static, in new()
[all …]
|
| D | codec.rs | 7 //! This module does not provide any actual decoding tools - that's the job of the
|
| /system/cros-codecs/examples/ccdec/ |
| D | main.rs | 138 let on_new_frame = move |job: C2DecodeJob<PooledVideoFrame<GenericDmaVideoFrame<()>>>| { in main()
143 if job.output.is_none() { in main()
145 assert_eq!(job.drain, DrainMode::EOSDrain); in main()
149 let width = job.output.as_ref().unwrap().resolution().width as usize; in main()
150 let height = job.output.as_ref().unwrap().resolution().height as usize; in main()
151 let luma_size = job.output.as_ref().unwrap().resolution().get_area(); in main()
157 let src_pitches = job.output.as_ref().unwrap().get_plane_pitch(); in main()
159 job.output.as_ref().unwrap().map().expect("Failed to map output frame!"); in main()
|
| /system/cros-codecs/examples/ccenc/ |
| D | main.rs | 174 let job = C2EncodeJob { in enqueue_work() localVariable
182 encoder.queue(vec![job]); in enqueue_work()
246 let work_done_cb = move |job: C2EncodeJob<PooledVideoFrame<GenericDmaVideoFrame<()>>>| { in main()
249 IvfFrameHeader { timestamp: job.timestamp, frame_size: job.output.len() as u32 }; in main()
254 .write(job.output.as_slice()) in main()
297 // Run the encode job in main()
|
| /system/security/keystore2/src/ |
| D | async_task.rs | 16 //! The worker thread has a high priority and a low priority queue. Adding a job to either
138 /// Adds a one-off job to the high priority queue. High priority jobs are
148 /// Adds a one-off job to the low priority queue. Low priority jobs are
216 // Wait for either a queued job to arrive or a timeout. in spawn_thread()
|
| /system/linkerconfig/ |
| D | rundiff.sh | 125 for job in `jobs -p`
127 wait $job
|
| /system/sepolicy/prebuilts/api/30.0/public/ |
| D | hal_neverallows.te | 13 # Unless a HAL's job is to communicate over the network, or control network
|
| /system/cros-codecs/ci/ |
| D | template.yaml | 13 job:
|
| /system/sepolicy/prebuilts/api/29.0/public/ |
| D | hal_neverallows.te | 12 # Unless a HAL's job is to communicate over the network, or control network
|
| /system/update_engine/payload_generator/ |
| D | payload_properties.h | 44 // Does the main job of reading the payload and extracting information from
|
| /system/sepolicy/prebuilts/api/31.0/public/ |
| D | hal_neverallows.te | 14 # Unless a HAL's job is to communicate over the network, or control network
|
| /system/sepolicy/prebuilts/api/32.0/public/ |
| D | hal_neverallows.te | 14 # Unless a HAL's job is to communicate over the network, or control network
|
| /system/sepolicy/private/ |
| D | hal_neverallows.te | 18 # Unless a HAL's job is to communicate over the network, or control network
|
| /system/sepolicy/prebuilts/api/34.0/public/ |
| D | hal_neverallows.te | 17 # Unless a HAL's job is to communicate over the network, or control network
|
| /system/sepolicy/prebuilts/api/33.0/public/ |
| D | hal_neverallows.te | 17 # Unless a HAL's job is to communicate over the network, or control network
|
| /system/sepolicy/prebuilts/api/202504/private/ |
| D | hal_neverallows.te | 18 # Unless a HAL's job is to communicate over the network, or control network
|
| /system/sepolicy/prebuilts/api/202404/public/ |
| D | hal_neverallows.te | 17 # Unless a HAL's job is to communicate over the network, or control network
|
| /system/core/libcutils/ |
| D | socket_local_client_unix.cpp | 120 * fd is not closed on error. that's your job.
|
| /system/tools/aidl/ |
| D | hiddenapi-greylist | 44 "android.app.job.IJobCallback",
45 "android.app.job.IJobScheduler",
46 "android.app.job.IJobService",
|
| /system/sepolicy/tests/ |
| D | mini_parser.py | 19 # A very limited parser whose job is to process the compatibility mapping
|
| /system/memory/libmemunreachable/tests/ |
| D | MemUnreachable_test.cpp | 34 // Since we're doing such a good job of hiding it, the static analyzer
|
| /system/chre/doc/ |
| D | framework_build.md | 25 all targets. This allows for efficient use of the job scheduler in the Make
|