int size = pkt->size;
int ret = 0, got_output = flush;
- if (size || flush) {
- av_packet_unref(out_pkt);
- } else if (st->parser->flags & PARSER_FLAG_COMPLETE_FRAMES) {
+ if (!size && !flush && st->parser->flags & PARSER_FLAG_COMPLETE_FRAMES) {
// preserve 0-size sync packets
compute_pkt_fields(s, st, st->parser, pkt, AV_NOPTS_VALUE, AV_NOPTS_VALUE);
}
ret = avpriv_packet_list_put(&s->internal->parse_queue,
&s->internal->parse_queue_end,
out_pkt, NULL, 0);
- if (ret < 0) {
- av_packet_unref(out_pkt);
+ if (ret < 0)
goto fail;
- }
}
/* end of the stream => close and free the parser */
}
fail:
+ if (ret < 0)
+ av_packet_unref(out_pkt);
av_packet_unref(pkt);
return ret;
}