Function sim_decoder_process

arch/sim/src/sim/sim_decoder.c:394–444

}

static int sim_decoder_process(sim_decoder_t *sim_decoder,
                               struct v4l2_buffer *dst_buf,
                               struct v4l2_buffer *src_buf)
{
  struct v4l2_event event;
  uint8_t *src_data = NULL;
  uint32_t src_size = 0;
  int64_t src_pts = 0;
  int64_t dst_pts = 0;
  int ret;

  if (src_buf != NULL)
    {
      src_data = (uint8_t *)src_buf->m.userptr;
      src_size = src_buf->bytesused;
      src_pts  = src_buf->timestamp.tv_sec * 1000000 +
                 src_buf->timestamp.tv_usec;
    }

  ret = openh264_decoder_enqueue(sim_decoder->decoder,
                                 src_data, src_pts, src_size);
  if (ret >= 0 && src_buf != NULL)
    {
      codec_output_put_buf(sim_decoder->cookie, src_buf);
    }

  if (ret < 1)
    {
      return ret;
    }

  ret = openh264_decoder_dequeue(sim_decoder->decoder,
                                 (uint8_t *)dst_buf->m.userptr,
                                 &dst_pts,
                                 &dst_buf->bytesused);
  if (ret == 0 && src_buf == NULL)
    {
      sim_decoder->flushing = false;
      dst_buf->flags |= V4L2_BUF_FLAG_LAST;

      memset(&event, 0, sizeof(event));
      event.type = V4L2_EVENT_EOS;
      codec_queue_event(sim_decoder->cookie, &event);
    }

  dst_buf->timestamp.tv_usec = dst_pts % 1000000;
  dst_buf->timestamp.tv_sec  = dst_pts / 1000000;

  codec_capture_put_buf(sim_decoder->cookie, dst_buf);
  return ret;
}

static void sim_decoder_work(void *decoder)
{