Lines Matching defs:ret
129 int ret, i;
131 ret = av_dict_copy(&format_options, fifo->format_options, 0);
132 if (ret < 0)
135 ret = ff_format_output_open(avf2, avf->url, &format_options);
136 if (ret < 0) {
138 av_err2str(ret));
145 ret = avformat_write_header(avf2, &format_options);
146 if (!ret)
154 ret = AVERROR(EINVAL);
159 return ret;
186 int ret, s_idx;
211 ret = av_write_frame(avf2, pkt);
212 if (ret >= 0) {
220 return ret;
228 int ret;
233 ret = av_write_trailer(avf2);
236 return ret;
241 int ret = AVERROR(EINVAL);
247 ret = fifo_thread_write_header(ctx);
248 if (ret < 0)
249 return ret;
254 av_assert0(ret >= 0);
255 return ret;
298 int ret;
317 ret = err_no;
319 ret = AVERROR(EAGAIN);
322 return ret;
331 int ret;
334 ret = err_no;
377 ret = fifo_thread_dispatch_message(ctx, msg);
378 if (ret < 0) {
379 if (is_recoverable(fifo, ret)) {
380 return fifo_thread_process_recovery_failure(ctx, pkt, ret);
393 return ret;
400 int ret;
410 ret = fifo_thread_attempt_recovery(ctx, msg, err_no);
411 } while (ret == AVERROR(EAGAIN) && !fifo->drop_pkts_on_overflow);
413 if (ret == AVERROR(EAGAIN) && fifo->drop_pkts_on_overflow) {
416 ret = 0;
419 return ret;
428 int ret;
439 ret = fifo_thread_dispatch_message(&fifo_thread_ctx, &msg);
441 if (ret < 0 || fifo_thread_ctx.recovery_nr > 0) {
442 int rec_ret = fifo_thread_recover(&fifo_thread_ctx, &msg, ret);
471 ret = av_thread_message_queue_recv(queue, &msg, 0);
472 if (ret < 0) {
473 av_thread_message_queue_set_err_send(queue, ret);
488 int ret = 0, i;
490 ret = avformat_alloc_output_context2(&avf2, oformat, NULL, filename);
491 if (ret < 0)
492 return ret;
498 ret = av_dict_copy(&avf2->metadata, avf->metadata, 0);
499 if (ret < 0)
500 return ret;
512 ret = ff_stream_encode_params_copy(st, avf->streams[i]);
513 if (ret < 0)
514 return ret;
524 int ret = 0;
536 ret = AVERROR_MUXER_NOT_FOUND;
537 return ret;
540 ret = fifo_mux_init(avf, oformat, avf->url);
541 if (ret < 0)
542 return ret;
544 ret = av_thread_message_queue_alloc(&fifo->queue, (unsigned) fifo->queue_size,
546 if (ret < 0)
547 return ret;
551 ret = pthread_mutex_init(&fifo->overflow_flag_lock, NULL);
552 if (ret < 0)
553 return AVERROR(ret);
562 int ret;
564 ret = pthread_create(&fifo->writer_thread, NULL, fifo_consumer_thread, avf);
565 if (ret) {
567 av_err2str(AVERROR(ret)));
568 ret = AVERROR(ret);
571 return ret;
578 int ret;
581 ret = av_packet_ref(&msg.pkt,pkt);
582 if (ret < 0)
583 return ret;
586 ret = av_thread_message_queue_send(fifo->queue, &msg,
589 if (ret == AVERROR(EAGAIN)) {
602 ret = 0;
604 } else if (ret < 0) {
611 return ret;
615 return ret;
621 int ret;
641 ret = av_thread_message_queue_send(fifo->queue, &msg, AV_THREAD_MESSAGE_NONBLOCK);
642 } while (ret >= 0 || ret == AVERROR(EAGAIN));
646 ret = pthread_join(fifo->writer_thread, NULL);
647 if (ret < 0) {
649 av_err2str(AVERROR(ret)));
650 return AVERROR(ret);
653 ret = fifo->write_trailer_ret;
654 return ret;