+ while (go) {
+ /* Parse data and process result. */
+ state = schro_decoder_wait(decoder);
+ switch (state) {
+ case SCHRO_DECODER_FIRST_ACCESS_UNIT:
+ libschroedinger_handle_first_access_unit(avctx);
+ break;
+
+ case SCHRO_DECODER_NEED_BITS:
+ /* Need more input data - stop iterating over what we have. */
+ go = 0;
+ break;
+
+ case SCHRO_DECODER_NEED_FRAME:
+ /* Decoder needs a frame - create one and push it in. */
+ frame = ff_create_schro_frame(avctx,
+ p_schro_params->frame_format);
+ if (!frame)
+ return AVERROR(ENOMEM);
+ schro_decoder_add_output_picture(decoder, frame);
+ break;
+
+ case SCHRO_DECODER_OK:
+ /* Pull a frame out of the decoder. */
+ tag = schro_decoder_get_picture_tag(decoder);
+ frame = schro_decoder_pull(decoder);
+
+ if (frame) {
+ /* Add relation between schroframe and pts. */
+ framewithpts = av_malloc(sizeof(LibSchroFrameContext));
+ if (!framewithpts) {
+ av_log(avctx, AV_LOG_ERROR, "Unable to allocate FrameWithPts\n");
+ return AVERROR(ENOMEM);
+ }
+ framewithpts->frame = frame;
+ framewithpts->pts = AV_RN64(tag->value);
+ ff_schro_queue_push_back(&p_schro_params->dec_frame_queue,
+ framewithpts);
+ }
+ break;
+ case SCHRO_DECODER_EOS:
+ go = 0;
+ p_schro_params->eos_pulled = 1;
+ schro_decoder_reset(decoder);
+ outer = 0;
+ break;
+
+ case SCHRO_DECODER_ERROR:
+ return -1;
+ break;
+ }