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()
310                         } else if job.get_drain() != DrainMode::NoDrain {  in process_loop()
321                                 if job.get_drain() == DrainMode::EOSDrain {  in process_loop()
324                                         timestamp: job.timestamp,  in process_loop()
334                         (*self.work_queue.lock().unwrap()).push_front(job);  in process_loop()