From patchwork Wed Nov 29 06:19:49 2017 Content-Type: text/plain; charset="utf-8" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit X-Patchwork-Submitter: "Jeyapal, Karthick" X-Patchwork-Id: 6443 Delivered-To: ffmpegpatchwork@gmail.com Received: by 10.2.161.94 with SMTP id m30csp4118798jah; Tue, 28 Nov 2017 22:20:32 -0800 (PST) X-Google-Smtp-Source: AGs4zMaSxOWuVPR3u7PRGuBopH+kv7LLUUMQ80K0EwJ2+dul+EEgn9H/rIBHllt5ZiGNPyciREMN X-Received: by 10.28.169.198 with SMTP id s189mr1392113wme.65.1511936432350; Tue, 28 Nov 2017 22:20:32 -0800 (PST) ARC-Seal: i=1; a=rsa-sha256; t=1511936432; cv=none; d=google.com; s=arc-20160816; b=UIOtvAQPU5AJPEFuJidapr1/L0kka/9DAG1UifsnlGsszuGbL5WUW5ERlGF1QIaZ57 nIWdSg33SI9BmbluMw0R8k2nuCtnh9Yr6yJuOW+N4HQvYTwrQQUS3/nZGQhQtYCdi8zv NTmhtZLH0fA8xyrROZtHmEmVKPztjUdnJ4V2NiUAI+ugc75q1+LXB1Zmk752aIKsBB0d Wxx/RjU9XlP5n6yA5i1BYkkDLsIrP12DXc7H5m7opaw318k0bSV3ytVse0exaIUZ/DpT 7dRC9kYsNlIRnQhDv/sx9BjLQaa1Acqa+UckZtfnXDO/bcjhTpT50AyoIQJ59l6B9ITb SviA== ARC-Message-Signature: i=1; a=rsa-sha256; c=relaxed/relaxed; d=google.com; s=arc-20160816; h=sender:errors-to:content-transfer-encoding:mime-version:cc:reply-to :list-subscribe:list-help:list-post:list-archive:list-unsubscribe :list-id:precedence:subject:feedback-id:references:in-reply-to :message-id:date:to:from:dkim-signature:delivered-to :arc-authentication-results; bh=oC9Qn3ql/h2lRRSMHFNtASKfr3NMU8DpVemwuSmn0x0=; b=XKg5L1U/q4AuNvrN52HiETdVpmPvnoxNuYkJfB95H5nJ178ADlOSgWzi2EuCK2J0hS 7NQm7BAqlXUAhkVN8Ll9eqyEv1GOQ1pd5e4FKPzC3j5qedIWIUCBlhbw4j2A+UQcGuhP pZc9oSHmUQsco44pVINsZINJ+8qYS2w1zEMkXP+KvaeLwn6OxiesYHJotKFWayGMwbhe a9xDcJtx/ALZ7caTjkB0CVWV4YOzUTjPp9iYPm8NannYkAFIFhHRmolFybUaOeOOcL/s avBIMxKh8YiLXarxwTMrqxKWItSKLQdqLl4q1kDAHmhpymxzX2JE0ajl8vuI4LwQGbr3 mLhQ== ARC-Authentication-Results: i=1; mx.google.com; dkim=neutral (body hash did not verify) header.i=@smtpservice.net header.s=m78bu0.a1-4.dyn header.b=JkZ2SPVX; spf=pass (google.com: domain of ffmpeg-devel-bounces@ffmpeg.org designates 79.124.17.100 as permitted sender) smtp.mailfrom=ffmpeg-devel-bounces@ffmpeg.org; dmarc=fail (p=QUARANTINE sp=NONE dis=NONE) header.from=akamai.com Return-Path: Received: from ffbox0-bg.mplayerhq.hu (ffbox0-bg.ffmpeg.org. [79.124.17.100]) by mx.google.com with ESMTP id o27si660661wra.417.2017.11.28.22.20.31; Tue, 28 Nov 2017 22:20:32 -0800 (PST) Received-SPF: pass (google.com: domain of ffmpeg-devel-bounces@ffmpeg.org designates 79.124.17.100 as permitted sender) client-ip=79.124.17.100; Authentication-Results: mx.google.com; dkim=neutral (body hash did not verify) header.i=@smtpservice.net header.s=m78bu0.a1-4.dyn header.b=JkZ2SPVX; spf=pass (google.com: domain of ffmpeg-devel-bounces@ffmpeg.org designates 79.124.17.100 as permitted sender) smtp.mailfrom=ffmpeg-devel-bounces@ffmpeg.org; dmarc=fail (p=QUARANTINE sp=NONE dis=NONE) header.from=akamai.com Received: from [127.0.1.1] (localhost [127.0.0.1]) by ffbox0-bg.mplayerhq.hu (Postfix) with ESMTP id 3FF1968A0AF; Wed, 29 Nov 2017 08:20:16 +0200 (EET) X-Original-To: ffmpeg-devel@ffmpeg.org Delivered-To: ffmpeg-devel@ffmpeg.org Received: from a2i831.smtp2go.com (a2i831.smtp2go.com [103.47.207.63]) by ffbox0-bg.mplayerhq.hu (Postfix) with ESMTPS id ABB97680507 for ; Wed, 29 Nov 2017 08:20:08 +0200 (EET) DKIM-Signature: v=1; a=rsa-sha256; q=dns/txt; c=relaxed/relaxed; d=smtpservice.net; s=m78bu0.a1-4.dyn; x=1511937316; h=Feedback-ID: X-Smtpcorp-Track:Message-Id:Date:Subject:To:From:Reply-To:Sender: List-Unsubscribe; bh=ItIPgwfrg5f6a3lzx1aiPXq0Pkxgs1Bm6h8nBCvgqxk=; b=JkZ2SPVX htkb2YunxPuMy4cRS2R+YyfSewJgT9otprnVC8eY05n2TWsNNKWpRqOXjJnzKWHsCEGwnvp1JiXCf cgwD27E2fuJaUKQfy3+D361olZUIzcEd3tDQtA6PxC0ACFBZZ2QyybtJodOV6b6bgv183QkDUKnQr NJ32AeXVI3LRlWEJy+SjgLwpwB9aXnIDsAquC7Sz3+a5eYmbKfsIDXsqZ3xYskKRX10kBIQ2eq01E W8kU18ZtrCIqZPQjPEFu6fHShTiF+a3s+oPBqC06brAILYgBt+fhQLtzYswlUTy7fwOw1mXt4Lzc5 CE9hedO6FZ+fjR4sYjGNm0xBMg==; From: Karthick J To: ffmpeg-devel@ffmpeg.org Date: Wed, 29 Nov 2017 11:49:49 +0530 Message-Id: <1511936389-30707-3-git-send-email-kjeyapal@akamai.com> X-Mailer: git-send-email 1.9.1 In-Reply-To: <1511936389-30707-1-git-send-email-kjeyapal@akamai.com> References: <15075E69-33A4-4476-9004-8E07E2132FDA@chinaffmpeg.org> <1511936389-30707-1-git-send-email-kjeyapal@akamai.com> X-Smtpcorp-Track: 1-JvM5RyILRC8F.HhGWm5qbV Feedback-ID: 337386m:337386asVRLGB:337386spTEAR_-Cw:SMTPCORP X-Report-Abuse: Please forward a copy of this message, including all headers, to Subject: [FFmpeg-devel] [PATCH v3 3/3] libavformat/hlsenc: Persistent HTTP connections supported as an option X-BeenThere: ffmpeg-devel@ffmpeg.org X-Mailman-Version: 2.1.20 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: Karthick J MIME-Version: 1.0 Errors-To: ffmpeg-devel-bounces@ffmpeg.org Sender: "ffmpeg-devel" --- doc/muxers.texi | 3 +++ libavformat/hlsenc.c | 48 +++++++++++++++++++++++++++++++++++++++++------- 2 files changed, 44 insertions(+), 7 deletions(-) diff --git a/doc/muxers.texi b/doc/muxers.texi index 9d9ca31..8ec48c2 100644 --- a/doc/muxers.texi +++ b/doc/muxers.texi @@ -854,6 +854,9 @@ ffmpeg -re -i in.ts -f hls -master_pl_name master.m3u8 \ This example creates HLS master playlist with name master.m3u8 and keep publishing it repeatedly every after 30 segments i.e. every after 60s. +@item http_persistent +Use persistent HTTP connections. Applicable only for HTTP output. + @end table @anchor{ico} diff --git a/libavformat/hlsenc.c b/libavformat/hlsenc.c index 6997a5c..d5c732f 100644 --- a/libavformat/hlsenc.c +++ b/libavformat/hlsenc.c @@ -45,6 +45,7 @@ #include "avformat.h" #include "avio_internal.h" +#include "http.h" #include "internal.h" #include "os_support.h" @@ -205,6 +206,7 @@ typedef struct HLSContext { char *var_stream_map; /* user specified variant stream map string */ char *master_pl_name; unsigned int master_publish_rate; + int http_persistent; } HLSContext; static int get_int_from_double(double val) @@ -245,10 +247,38 @@ static int mkdir_p(const char *path) { return ret; } +static int is_http_proto(char *filename) { + const char *proto = avio_find_protocol_name(filename); + return proto ? (!av_strcasecmp(proto, "http") || !av_strcasecmp(proto, "https")) : 0; +} + +static int hlsenc_io_open(AVFormatContext *s, AVIOContext **pb, char *filename, + AVDictionary **options) { + HLSContext *hls = s->priv_data; + int http_base_proto = is_http_proto(filename); + int err; + if (!*pb || !http_base_proto || !hls->http_persistent) { + err = s->io_open(s, pb, filename, AVIO_FLAG_WRITE, options); + } else { + URLContext *http_url_context = ffio_geturlcontext(*pb); + av_assert0(http_url_context); + err = ff_http_do_new_request(http_url_context, filename); + } + return err; +} + +static void hlsenc_io_close(AVFormatContext *s, AVIOContext **pb, char *filename) { + HLSContext *hls = s->priv_data; + int http_base_proto = is_http_proto(filename); + + if (!http_base_proto || !hls->http_persistent || hls->key_info_file || hls->encrypt) { + ff_format_io_close(s, pb); + } +} + static void set_http_options(AVFormatContext *s, AVDictionary **options, HLSContext *c) { - const char *proto = avio_find_protocol_name(s->filename); - int http_base_proto = proto ? (!av_strcasecmp(proto, "http") || !av_strcasecmp(proto, "https")) : 0; + int http_base_proto = is_http_proto(s->filename); if (c->method) { av_dict_set(options, "method", c->method, 0); @@ -258,6 +288,8 @@ static void set_http_options(AVFormatContext *s, AVDictionary **options, HLSCont } if (c->user_agent) av_dict_set(options, "user_agent", c->user_agent, 0); + if (c->http_persistent) + av_dict_set_int(options, "multiple_requests", 1, 0); } @@ -1437,17 +1469,17 @@ static int hls_start(AVFormatContext *s, VariantStream *vs) err = AVERROR(ENOMEM); goto fail; } - err = s->io_open(s, &oc->pb, filename, AVIO_FLAG_WRITE, &options); + err = hlsenc_io_open(s, &oc->pb, filename, &options); av_free(filename); av_dict_free(&options); if (err < 0) return err; } else - if ((err = s->io_open(s, &oc->pb, oc->filename, AVIO_FLAG_WRITE, &options)) < 0) + if ((err = hlsenc_io_open(s, &oc->pb, oc->filename, &options)) < 0) goto fail; if (vs->vtt_basename) { set_http_options(s, &options, c); - if ((err = s->io_open(s, &vtt_oc->pb, vtt_oc->filename, AVIO_FLAG_WRITE, &options)) < 0) + if ((err = hlsenc_io_open(s, &vtt_oc->pb, vtt_oc->filename, &options)) < 0) goto fail; } av_dict_free(&options); @@ -2165,11 +2197,12 @@ static int hls_write_packet(AVFormatContext *s, AVPacket *pkt) avio_open_dyn_buf(&oc->pb); vs->packets_written = 0; ff_format_io_close(s, &vs->out); + hlsenc_io_close(s, &vs->out, vs->base_output_dirname); } else { - ff_format_io_close(s, &oc->pb); + hlsenc_io_close(s, &oc->pb, oc->filename); } if (vs->vtt_avf) { - ff_format_io_close(s, &vs->vtt_avf->pb); + hlsenc_io_close(s, &vs->vtt_avf->pb, vs->vtt_avf->filename); } } if ((hls->flags & HLS_TEMP_FILE) && oc->filename[0]) { @@ -2355,6 +2388,7 @@ static const AVOption options[] = { {"var_stream_map", "Variant stream map string", OFFSET(var_stream_map), AV_OPT_TYPE_STRING, {.str = NULL}, 0, 0, E}, {"master_pl_name", "Create HLS master playlist with this name", OFFSET(master_pl_name), AV_OPT_TYPE_STRING, {.str = NULL}, 0, 0, E}, {"master_pl_publish_rate", "Publish master play list every after this many segment intervals", OFFSET(master_publish_rate), AV_OPT_TYPE_INT, {.i64 = 0}, 0, UINT_MAX, E}, + {"http_persistent", "Use persistent HTTP connections", OFFSET(http_persistent), AV_OPT_TYPE_BOOL, {.i64 = 0 }, 0, 1, E }, { NULL }, };