From mboxrd@z Thu Jan 1 00:00:00 1970 Return-Path: Received: from ffbox0-bg.mplayerhq.hu (ffbox0-bg.ffmpeg.org [79.124.17.100]) by master.gitmailbox.com (Postfix) with ESMTP id 210CF449C8 for ; Mon, 31 Oct 2022 12:55:55 +0000 (UTC) Received: from [127.0.1.1] (localhost [127.0.0.1]) by ffbox0-bg.mplayerhq.hu (Postfix) with ESMTP id 7879D68BE2A; Mon, 31 Oct 2022 14:55:51 +0200 (EET) Received: from mail-wr1-f42.google.com (mail-wr1-f42.google.com [209.85.221.42]) by ffbox0-bg.mplayerhq.hu (Postfix) with ESMTPS id 586AB68BE1B for ; Mon, 31 Oct 2022 14:55:45 +0200 (EET) Received: by mail-wr1-f42.google.com with SMTP id k8so15874595wrh.1 for ; Mon, 31 Oct 2022 05:55:45 -0700 (PDT) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=gmail.com; s=20210112; h=content-transfer-encoding:mime-version:references:in-reply-to :message-id:date:subject:cc:to:from:from:to:cc:subject:date :message-id:reply-to; bh=cdwqTebHFEgwRqIWtZrSMVpJk52SnFCfOg/kNRElkpg=; b=ZPN8cBMAk1n2NMuffy9abCJEinX1zGLifo5KQopcQvxSHeUZEDtwykcCXia0naXzWu GrMwazlDlHkWIdZA21OMCkfjDUN6ToEpUX9RSH7AYvYmzk4c0J8hIfNtv81yZof5QjX3 K0mBmzUmmygIANpGi0bHR1JO2T0wZvGZlg6DGVjC1KDtZZup/1J/9T7zzwpwmj9/LQtl 1f5+rjHVI6l4pat5FcRiMgOnm1+fh5OKUEAw8PW3bn/ZjRYm7ABd8Ai51t8kOIM109YH KrW2kjssFwK5uxbufxE5JHtq9WkDUMA9QrSv44gSdRdskawh1ir4W9IFi0hebOzIJwOk xZPA== X-Google-DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=1e100.net; s=20210112; h=content-transfer-encoding:mime-version:references:in-reply-to :message-id:date:subject:cc:to:from:x-gm-message-state:from:to:cc :subject:date:message-id:reply-to; bh=cdwqTebHFEgwRqIWtZrSMVpJk52SnFCfOg/kNRElkpg=; b=SYwJQ8nEIOr4eET67k1AQ6SNOp7tRwV0u1h0HeoOUPb5hZe/Hf7g7JdmySy5dtpTBU hQBO8fCgPGMuk5ro1QjtSB0RkIzHFaLYxsZf2y4ZMjdOCVqjyCYzQoaXjcJ+Lkxl56fQ gjdUxHyPaZPNQjHsFljbquv5Cy88UgywWzYLs4D3ibSgnd/jGoMLDdkkrz1vrJkaMVTH gPPqp8AbD2C7UxKy0JSP+UGgTj96Yb36sTxDE78AjYkiLV2ebbddlHKMrgW8/oPYAw6c vKO5Dd2/14FOs5fpOjYPhGqJguImrkMpmsPOPl5IQzsSLADmutX/ELposbRgdf/Q2PCI j+cA== X-Gm-Message-State: ACrzQf2JPrz/jBHUELhC7ZGtclaoHOxTxsw92U5Viz+2JXr/OZAOQdco Jl7we03k1mq8HT9pHbFC+B6+3RPIchQ= X-Google-Smtp-Source: AMsMyM5t1lO55/swD7AVi2AFDTMOAd8C7jBXP3uuwm5AfI6yXbYvztdio+JuLw6I+YqDrfJfs4I9Ww== X-Received: by 2002:adf:e484:0:b0:236:6a2e:154e with SMTP id i4-20020adfe484000000b002366a2e154emr7882574wrm.664.1667220944469; Mon, 31 Oct 2022 05:55:44 -0700 (PDT) Received: from localhost.localdomain ([80.122.30.74]) by smtp.gmail.com with ESMTPSA id q8-20020a05600c46c800b003b4868eb71bsm6837295wmo.25.2022.10.31.05.55.43 (version=TLS1_3 cipher=TLS_AES_256_GCM_SHA384 bits=256/256); Mon, 31 Oct 2022 05:55:44 -0700 (PDT) From: Wolfgang Haupt To: ffmpeg-devel@ffmpeg.org Date: Mon, 31 Oct 2022 13:55:37 +0100 Message-Id: <20221031125537.214216-2-haupt.wolfgang@gmail.com> X-Mailer: git-send-email 2.25.1 In-Reply-To: <20221031125537.214216-1-haupt.wolfgang@gmail.com> References: <20221031105645.75816-2-haupt.wolfgang@gmail.com> <20221031125537.214216-1-haupt.wolfgang@gmail.com> MIME-Version: 1.0 Subject: [FFmpeg-devel] [PATCH] avformat/mpegts: Add "no packet" timeout option X-BeenThere: ffmpeg-devel@ffmpeg.org X-Mailman-Version: 2.1.29 Precedence: list List-Id: FFmpeg development discussions and patches List-Unsubscribe: , List-Archive: List-Post: List-Help: List-Subscribe: , Reply-To: FFmpeg development discussions and patches Cc: Wolfgang Haupt Content-Type: text/plain; charset="us-ascii" Content-Transfer-Encoding: 7bit Errors-To: ffmpeg-devel-bounces@ffmpeg.org Sender: "ffmpeg-devel" Archived-At: List-Archive: List-Post: Retrieving an mpegts stream with only stuffed PAT, results in endless reading. This change adds a new timeout that specifies a timespan in AV_TIME_BASE units until when a full packet must be read successfully. Signed-off-by: Wolfgang Haupt --- libavformat/mpegts.c | 16 ++++++++++++++++ 1 file changed, 16 insertions(+) diff --git a/libavformat/mpegts.c b/libavformat/mpegts.c index d97702fcd7..45bf82f61c 100644 --- a/libavformat/mpegts.c +++ b/libavformat/mpegts.c @@ -32,6 +32,7 @@ #include "libavutil/opt.h" #include "libavutil/avassert.h" #include "libavutil/dovi_meta.h" +#include "libavutil/time.h" #include "libavcodec/avcodec.h" #include "libavcodec/bytestream.h" #include "libavcodec/get_bits.h" @@ -180,6 +181,12 @@ struct MpegTSContext { AVStream *epg_stream; AVBufferPool* pools[32]; + + /** + * Timeout in AV_TIME_BASE units, until at least one packet is read + * from the stream. + */ + int64_t packet_read_timeout; }; #define MPEGTS_OPTIONS \ @@ -203,6 +210,8 @@ static const AVOption options[] = { {.i64 = 0}, 0, 1, 0 }, {"max_packet_size", "maximum size of emitted packet", offsetof(MpegTSContext, max_packet_size), AV_OPT_TYPE_INT, {.i64 = 204800}, 1, INT_MAX/2, AV_OPT_FLAG_DECODING_PARAM }, + {"packet_read_timeout", "Maximum time utnil at least one packet is successfully read from the stream", offsetof(MpegTSContext, packet_read_timeout), AV_OPT_TYPE_INT64, + {.i64 = 0 }, 0, INT64_MAX, AV_OPT_FLAG_DECODING_PARAM }, { NULL }, }; @@ -2972,6 +2981,7 @@ static int handle_packets(MpegTSContext *ts, int64_t nb_packets) const uint8_t *data; int64_t packet_num; int ret = 0; + time_t start = 0; if (avio_tell(s->pb) != ts->last_pos) { int i; @@ -2996,8 +3006,14 @@ static int handle_packets(MpegTSContext *ts, int64_t nb_packets) ts->stop_parse = 0; packet_num = 0; memset(packet + TS_PACKET_SIZE, 0, AV_INPUT_BUFFER_PADDING_SIZE); + start = av_gettime_relative(); for (;;) { packet_num++; + if (ts->packet_read_timeout > 0 && (av_gettime_relative() - start > ts->packet_read_timeout)) { + av_log(ts->stream, AV_LOG_TRACE, "No packet after %"PRId64"ms\n", ts->packet_read_timeout/1000); + break; + } + if (nb_packets != 0 && packet_num >= nb_packets || ts->stop_parse > 1) { ret = AVERROR(EAGAIN); -- 2.25.1 _______________________________________________ ffmpeg-devel mailing list ffmpeg-devel@ffmpeg.org https://ffmpeg.org/mailman/listinfo/ffmpeg-devel To unsubscribe, visit link above, or email ffmpeg-devel-request@ffmpeg.org with subject "unsubscribe".