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 9CD2B47F2B for ; Mon, 6 Nov 2023 15:20:11 +0000 (UTC) Received: from [127.0.1.1] (localhost [127.0.0.1]) by ffbox0-bg.mplayerhq.hu (Postfix) with ESMTP id 1586D68CAE8; Mon, 6 Nov 2023 17:19:38 +0200 (EET) Received: from EUR03-DBA-obe.outbound.protection.outlook.com (mail-dbaeur03on2042.outbound.protection.outlook.com [40.107.104.42]) by ffbox0-bg.mplayerhq.hu (Postfix) with ESMTPS id 85B4368CAD8 for ; Mon, 6 Nov 2023 17:19:36 +0200 (EET) ARC-Seal: i=1; a=rsa-sha256; s=arcselector9901; d=microsoft.com; cv=none; b=IGvKLmL6erMEifq1qrlOfSLFle1iNH5e+QxgpG2Y19xYpVAMXXtQzZkl3k5MZ5yigfQG5qW7x+ruOD2ltkTt+AUiOODtcQnsCTKYEcCFucAh3/bGGCFq03Kanf615HHkduQGBy/EN9j/xK/LJXx2oqHcAJtnB6heSki/EOt3FveXQu88qrhLAYdIHt9bVOwAOeCU6ld8mNMOYXu4MiWxDVzFnX3K76rOSJbFKwH0PXK6ikmeMOxB/SmKeCG7Aq6fkZNsdsx/2PT2sn21XCuuMCS2lPFOF2dnykvyZ1HPjUOUKUMmngetxDv0VkK8vSPPLmDr2ENUa+3ibCL3t08MiQ== ARC-Message-Signature: i=1; a=rsa-sha256; c=relaxed/relaxed; d=microsoft.com; s=arcselector9901; h=From:Date:Subject:Message-ID:Content-Type:MIME-Version:X-MS-Exchange-AntiSpam-MessageData-ChunkCount:X-MS-Exchange-AntiSpam-MessageData-0:X-MS-Exchange-AntiSpam-MessageData-1; bh=npT8a3kCW/vwCmNSB3glcn5sad13FtY3QPf881pXvaQ=; b=cHDcjNZhxGv1473Z6xq4A4FcuRTEbKYtNn3ZeKwKWgZNkHwtXAConljwiQoBT4bc4irZr7kS9wtQ0abQPvqHake5j5scXiSYVToGa8yIzAXqdxcBHzj9SU3ob6r35bNB9NacaVKM1/mPnkcL6U+3rSHduIntXDFV2r8it98LgAQkCuOGAl/YaB1KqniCU+x6TsO/TyqLdTz/G9sxXnRF5WCy3s1mAsqlA8NXflCOdpxn3abGjA1mDvy1nSVKiTgQrRynKjEV5BmYLt46FrkOxLcpAdyJ8eaNqAzhud9Ncgx5VYOTtvDwgyDwslBHXiM/ojYBmZ8cjLufORp+yH+vUw== ARC-Authentication-Results: i=1; mx.microsoft.com 1; spf=pass smtp.mailfrom=nativewaves.com; dmarc=pass action=none header.from=nativewaves.com; dkim=pass header.d=nativewaves.com; arc=none DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=nativewaves.onmicrosoft.com; s=selector2-nativewaves-onmicrosoft-com; h=From:Date:Subject:Message-ID:Content-Type:MIME-Version:X-MS-Exchange-SenderADCheck; bh=npT8a3kCW/vwCmNSB3glcn5sad13FtY3QPf881pXvaQ=; b=hI6P+m7G96TdRgIRp6cG7AnEPMMrqt3dgoOpkEHXIbelSOqaIx/ItRYLJMMM7igNDRuOa0g1AR8ZItuI9j0IRv3tn/6WnNAItM3IcwHIewbGThJuRKMLyhjHZQBw+LBmxQbpkXNtD8Jd4VYBHWvgktN93F+Fl2WQGIUzpO6qz2Y= Authentication-Results: dkim=none (message not signed) header.d=none;dmarc=none action=none header.from=nativewaves.com; Received: from VI1PR03MB4239.eurprd03.prod.outlook.com (2603:10a6:803:5f::26) by PAVPR03MB10143.eurprd03.prod.outlook.com (2603:10a6:102:327::20) with Microsoft SMTP Server (version=TLS1_2, cipher=TLS_ECDHE_RSA_WITH_AES_256_GCM_SHA384) id 15.20.6954.28; Mon, 6 Nov 2023 15:19:34 +0000 Received: from VI1PR03MB4239.eurprd03.prod.outlook.com ([fe80::150d:b41:699f:42b6]) by VI1PR03MB4239.eurprd03.prod.outlook.com ([fe80::150d:b41:699f:42b6%6]) with mapi id 15.20.6954.028; Mon, 6 Nov 2023 15:19:34 +0000 Message-ID: <2a21d6de-578c-4426-bbd5-a6f86515d976@nativewaves.com> Date: Mon, 6 Nov 2023 16:19:33 +0100 User-Agent: Mozilla Thunderbird From: Michael Riedl To: ffmpeg-devel@ffmpeg.org Content-Language: en-US X-ClientProxiedBy: VI1PR0102CA0021.eurprd01.prod.exchangelabs.com (2603:10a6:802::34) To VI1PR03MB4239.eurprd03.prod.outlook.com (2603:10a6:803:5f::26) MIME-Version: 1.0 X-MS-PublicTrafficType: Email X-MS-TrafficTypeDiagnostic: VI1PR03MB4239:EE_|PAVPR03MB10143:EE_ X-MS-Office365-Filtering-Correlation-Id: 6dd7b248-cc80-4d53-9891-08dbdedbc840 X-MS-Exchange-SenderADCheck: 1 X-MS-Exchange-AntiSpam-Relay: 0 X-Microsoft-Antispam: BCL:0; X-Microsoft-Antispam-Message-Info: ghUtFsombMDrann4rHzCjxzBLd1xgSOgHS6yc23rJv6Dh2Flp2vHgzJcIbivL4p3Sk1WaQbJJD05qxYOhgtpwBgz7rSwT32gbT54KMNVhKYGqN+UiU3f4TjSUXrX8DjM3/qdGfcQFRMagCCD7p6q+E79EmcHUKcvaJxoRaU1h0lAFeQieyVBKKbLKeOpQvrprHv8F+ohBzlHorOqoLqWennBiGu4rKzmoU8OHE+Fta3/lt8KJYhW+OPNo0tpT+M20uTSE5/ea2EmlpPnEADgte19fZ/5DFVog/vT3EgtJCuGQMx90l4dPw1ALK4WdyAw8TxHdxCs90FH0rsyKu+RtigD9pVi+lcPi+x48mJ55uujcrAigv8xjPGKzXOacavS9U72RkhbAYz3NWwlXM2bQDEFIPzwFw3ennFYnGYp+gHmboLeIbCaKgixVf31plfHnI2D/IXs1tkjvNAw9l1LBSryxdZ6GThuxXMZUdAsCIJ6KtcfCJeZJN+H1AhpcqwjqA8w5KRnxnQ0jBpu8cvmdnUkFNdQodVBXtAXmAVZJ2f25ZcfMZMwMMwZDFYuxo9lYsGzrJ3W17en+KPnHtWbsA44xVQPUG2VHNAJ0eJE4Wt3PjbObBMi6bImRJWdjUsM5uZ+8PBhW1NEYjEAaUZiquIzjOuBHNEp+V3ttmQW3PpPwQslE8fx8mNaJ1cXgxZudx0fr++xiy9oJEKZsjX8Fw== X-Forefront-Antispam-Report: CIP:255.255.255.255; CTRY:; LANG:en; SCL:1; SRV:; IPV:NLI; SFV:NSPM; H:VI1PR03MB4239.eurprd03.prod.outlook.com; PTR:; CAT:NONE; SFS:(13230031)(136003)(366004)(396003)(346002)(39830400003)(376002)(230273577357003)(230173577357003)(230922051799003)(186009)(1800799009)(64100799003)(451199024)(36756003)(316002)(8936002)(8676002)(83380400001)(26005)(66476007)(66946007)(6916009)(66556008)(5660300002)(44832011)(41300700001)(478600001)(6486002)(6512007)(6506007)(2616005)(31686004)(2906002)(31696002)(86362001)(38100700002)(2004002)(43740500002)(45980500001); DIR:OUT; SFP:1101; X-MS-Exchange-AntiSpam-MessageData-ChunkCount: 1 X-MS-Exchange-AntiSpam-MessageData-0: =?utf-8?B?ckI3bUhsQVVtTmcwQ0JXVDJFa2E3eVdJWXFiamtDc0RaM3FZUjE5YklrdWFy?= =?utf-8?B?dytHYk9jU3JZVzZEMVJGWjNKUTFNRlhuYmtoRkZkWW1wVjZMNzJJZCtxaFpL?= =?utf-8?B?NzJmT0oyMmZIUkdkMmZ3OTEwMHQyNG1jZWt1QXBmT3NRRFljSjd4L09DZm1j?= =?utf-8?B?TkhuWm94REJSZmRRUUs0alNvQU9MUERIeEJTekJESm1ISkxnZStnd0tWcDBv?= =?utf-8?B?emVzY1lROTRwU1h6Um9PNitNR0RkekJ1eER0OVU1Y0NjZ0VUSUFoZk15a01T?= =?utf-8?B?d0ZjYThKOXpOQkc2Nmpob1AxdXdBV2YzaTFLZXJyZmxzMXc2Qkx5VWMvTlY1?= =?utf-8?B?YjNtcHRYcENDcUdEZ040aTB6dzV1M3o1T1ZCTjVaQmdEWjRyYXd3RDkydE05?= =?utf-8?B?cjBBWnMzMWhUR2xCSTZEMlRDbVpKZ0JCbmg0R093L1kzNXFXdEZ5WTNKVXJI?= =?utf-8?B?NmxncFV5UXRKdVFvWnRHb3psYVJvWEhSVnE3UnV0MWRjN2VSaHJPakxTOEMw?= =?utf-8?B?bHZEMnV0dHU4R2tXd0g1ZTNsYTFvZno0cERuTVJwODlVOU9hd2JHMExmZkVI?= =?utf-8?B?OC9MbzdMNWx6c3RpdnRmMUI0eVJqYXhFWkJRbGk4ck9kZXpCM0ZpMWVOOUw1?= =?utf-8?B?Skh2S21jU2NQQjdZSEFRaHVwMVRvNGFvNUtEUkl4d0Jnb1ROSWJ2c1FCcGNv?= =?utf-8?B?S3RwMzN1VXZpcU9kZFY4dHpJdHVWOW1HNXJNUXdLd29jWVJSVVI2aDZDdm5s?= =?utf-8?B?bmd5czl1SW5iZzdGSkVPblZDMk8xbnFWYUdTcGZ6cWoyaStSYXlQMkxFUHE3?= =?utf-8?B?YjRJb3pMK0RsTmpqWjk5d0M2R1ZLeWhJb1hIOThKNkJ0T3R6ejdKSjdleGpl?= =?utf-8?B?NjhyeWRreERsY0FtUnFPVEhnVUxmU1RDQzVUZ3J2K0lYY1hKT0c5SWdBV1g0?= =?utf-8?B?aTZPUGhlQTB6SXM5cExiUThVcm55VVJ6cEd2NXM1ejM2a1J4V3pnTE9hOHU3?= =?utf-8?B?ZEFEV2FhSGxpL2huRFFGZHdpdnhEU3dpSHdLbU83ZjdQTTdhVVJORHRrRnZa?= =?utf-8?B?WHNtc3VWdkRzZlQ0VFhpOWx1L1NOMUJBUnRnWk80MFE2ZXFwVFNzUmJJOWl6?= =?utf-8?B?cm5EK0VtUTA0eis1azkrb3pyRkU0VnhneVZMb0owbHA3YVhCa2M0N1ByL3B3?= =?utf-8?B?SzA3SjZhUHNiZS91enY1dkNlcmdKTnA4aVg2c0FxbWV3WlgxcERUdzhpTlZV?= =?utf-8?B?TVFYUWlQWUUzRXhLZk1CTGJHS1JiUUFhTHVJcEhOeTJQU2JiN1gzMjRvZ1VQ?= =?utf-8?B?TjRuN2JGVDV2NVA4bFBobC9GYXY0Tm5Od1A2blJtTDBENVNoVmoySGxINFBR?= =?utf-8?B?cTFmTnUralVpVXhlaXBaaHVaM0trbUhtb0tBTUdLemxEOC9IbVhOK0tBdzZm?= =?utf-8?B?a0tZd2FxRmFaSmVmeW1TZmRzNXgzZklrL25tZDVuUkI3MDJmZ1BNU1RKRTRQ?= =?utf-8?B?cDdvTTJBWmpEZGxZN21aN1dIQ1Qwd2lSRkROVjBEZ042VzQydHJwZWc2RFpx?= =?utf-8?B?K1czSi9NNkxFaWFlSGNhb0JGRmNra0ZVYUVNRitkMG1ISUJFT2FIdlNXeTNv?= =?utf-8?B?clY4eXVCWUw5ejE2bXJSM0pPdnIzZnFuZW1PS2d2SHlxQkJZc3FPNGpVaThG?= =?utf-8?B?VXVhU3ZEU21idXpFdWQ5RjhiZmpqN1BjZUdqNzVyZUV0R2VNem92VUl0NDdj?= =?utf-8?B?OExEWWswUjRsbUZ1WUlDaDh4RDExZ25lN3lvK0FiUGN4bHh3bXlqdzVkWklH?= =?utf-8?B?T040V090d0g3N2Y2V0lKYmV1aG5aNkxRZGFTTWJ0SGhGRTRRcUlDL21mSXkx?= =?utf-8?B?dXJ0Qnc3UFM2Ykt4alJoWHUyUjVQdzdFZnY1V3JOTStHZkI5d0kzQzFLUEU4?= =?utf-8?B?WEEzZk1wVXZSZHVpTnQ0MDY2YS9nQVFRTUxqSnlqeitucU1NdFpHejF0clpB?= =?utf-8?B?SzUyWk95L3hFWDg2UWZWZWY4WkhZekxRZ2wza3p1d2FoOUFwZnA1RnV2YlZQ?= =?utf-8?B?SHJ4Y2hkUnAzUHJZY2VOaEVMR3kyREYvZUcxWk9KMkF1aDR5dnBPZVJuVXpC?= =?utf-8?B?R1RWZXBIWEFkOUpMLzJSbFdjb1ZYTGpxSVF1cVdpR0xtN0hyWHNwNUFRWkxU?= =?utf-8?Q?LnXIhzH/psMuMcsDXMCRyoI=3D?= X-OriginatorOrg: nativewaves.com X-MS-Exchange-CrossTenant-Network-Message-Id: 6dd7b248-cc80-4d53-9891-08dbdedbc840 X-MS-Exchange-CrossTenant-AuthSource: VI1PR03MB4239.eurprd03.prod.outlook.com X-MS-Exchange-CrossTenant-AuthAs: Internal X-MS-Exchange-CrossTenant-OriginalArrivalTime: 06 Nov 2023 15:19:34.7465 (UTC) X-MS-Exchange-CrossTenant-FromEntityHeader: Hosted X-MS-Exchange-CrossTenant-Id: e4239718-b000-4513-8314-02ef46bd0276 X-MS-Exchange-CrossTenant-MailboxType: HOSTED X-MS-Exchange-CrossTenant-UserPrincipalName: TzvMzw8xSfzmmvp0TXMQPcB7+x/jTqjI7X6NrVDebY/a+uSUXyHOjqnWLNX4ABG8WlbzQwbWypWuCkUi+YFoX4ZaInTY3Zrn3fnFsdLhyIY= X-MS-Exchange-Transport-CrossTenantHeadersStamped: PAVPR03MB10143 Subject: [FFmpeg-devel] [PATCH 5/6] libavformat/webrtc_demux: add WebRTC-HTTP egress protocol (WHEP) demuxer 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 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: Signed-off-by: Michael Riedl --- configure | 2 + libavformat/Makefile | 1 + libavformat/allformats.c | 1 + libavformat/webrtc_demux.c | 231 +++++++++++++++++++++++++++++++++++++ 4 files changed, 235 insertions(+) create mode 100644 libavformat/webrtc_demux.c diff --git a/configure b/configure index 187f16b425d..02c6f7f2c5d 100755 --- a/configure +++ b/configure @@ -3557,6 +3557,8 @@ wav_demuxer_select="riffdec" wav_muxer_select="riffenc" webm_chunk_muxer_select="webm_muxer" webm_dash_manifest_demuxer_select="matroska_demuxer" +whep_demuxer_deps="libdatachannel sdp_demuxer" +whep_demuxer_select="http_protocol" wtv_demuxer_select="mpegts_demuxer riffdec" wtv_muxer_select="mpegts_muxer riffenc" xmv_demuxer_select="riffdec" diff --git a/libavformat/Makefile b/libavformat/Makefile index 329055ccfd9..f790fa8cae4 100644 --- a/libavformat/Makefile +++ b/libavformat/Makefile @@ -621,6 +621,7 @@ OBJS-$(CONFIG_WEBM_CHUNK_MUXER) += webm_chunk.o OBJS-$(CONFIG_WEBP_MUXER) += webpenc.o OBJS-$(CONFIG_WEBVTT_DEMUXER) += webvttdec.o subtitles.o OBJS-$(CONFIG_WEBVTT_MUXER) += webvttenc.o +OBJS-$(CONFIG_WHEP_DEMUXER) += webrtc.o webrtc_demux.o OBJS-$(CONFIG_WSAUD_DEMUXER) += westwood_aud.o OBJS-$(CONFIG_WSAUD_MUXER) += westwood_audenc.o OBJS-$(CONFIG_WSD_DEMUXER) += wsddec.o rawdec.o diff --git a/libavformat/allformats.c b/libavformat/allformats.c index d4b505a5a32..7acb05634c8 100644 --- a/libavformat/allformats.c +++ b/libavformat/allformats.c @@ -504,6 +504,7 @@ extern const FFOutputFormat ff_webm_chunk_muxer; extern const FFOutputFormat ff_webp_muxer; extern const AVInputFormat ff_webvtt_demuxer; extern const FFOutputFormat ff_webvtt_muxer; +extern const AVInputFormat ff_whep_demuxer; extern const AVInputFormat ff_wsaud_demuxer; extern const FFOutputFormat ff_wsaud_muxer; extern const AVInputFormat ff_wsd_demuxer; diff --git a/libavformat/webrtc_demux.c b/libavformat/webrtc_demux.c new file mode 100644 index 00000000000..7ef4e3d3ce3 --- /dev/null +++ b/libavformat/webrtc_demux.c @@ -0,0 +1,231 @@ +/* + * WebRTC-HTTP egress protocol (WHEP) demuxer using libdatachannel + * + * Copyright (C) 2023 NativeWaves GmbH + * This work is supported by FFG project 47168763. + * + * This file is part of FFmpeg. + * + * FFmpeg is free software; you can redistribute it and/or + * modify it under the terms of the GNU Lesser General Public + * License as published by the Free Software Foundation; either + * version 2.1 of the License, or (at your option) any later version. + * + * FFmpeg is distributed in the hope that it will be useful, + * but WITHOUT ANY WARRANTY; without even the implied warranty of + * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU + * Lesser General Public License for more details. + * + * You should have received a copy of the GNU Lesser General Public + * License along with FFmpeg; if not, write to the Free Software Foundation, + * Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA + */ + +#include "internal.h" +#include "libavutil/avstring.h" +#include "libavutil/random_seed.h" +#include "version.h" +#include "rtsp.h" +#include "webrtc.h" + +typedef struct WHEPContext { + const AVClass *av_class; + DataChannelContext data_channel; +} WHEPContext; + +static int whep_read_header(AVFormatContext* avctx) +{ + WHEPContext*const ctx = (WHEPContext*const)avctx->priv_data; + int ret, i; + char media_stream_id[37] = { 0 }; + rtcTrackInit track_init; + AVDictionary* options = NULL; + const AVInputFormat* infmt; + AVStream* stream; + FFIOContext sdp_pb; + + webrtc_init_logger(); + ret = webrtc_init_connection(&ctx->data_channel); + if (ret < 0) { + av_log(avctx, AV_LOG_ERROR, "Failed to initialize connection\n"); + goto fail; + } + + /* configure audio and video track */ + ret = webrtc_generate_media_stream_id(media_stream_id); + if (ret < 0) { + av_log(avctx, AV_LOG_ERROR, "Failed to generate media stream id\n"); + goto fail; + } + ctx->data_channel.tracks = av_mallocz(2 * sizeof(DataChannelTrack)); + ctx->data_channel.nb_tracks = 2; + ctx->data_channel.avctx = avctx; + if (!ctx->data_channel.tracks) { + ret = AVERROR(ENOMEM); + goto fail; + } + for (i=0; i < ctx->data_channel.nb_tracks; i++) { + ctx->data_channel.tracks[i].avctx = avctx; + } + + /* configure video track */ + memset(&track_init, 0, sizeof(rtcTrackInit)); + track_init.direction = RTC_DIRECTION_RECVONLY; + track_init.codec = RTC_CODEC_H264; // TODO: support more codecs once libdatachannel C api supports them + track_init.payloadType = 96; + track_init.ssrc = av_get_random_seed(); + track_init.mid = "0"; + track_init.name = LIBAVFORMAT_IDENT; + track_init.msid = media_stream_id; + track_init.trackId = av_asprintf("%s-video", media_stream_id); + track_init.profile = "profile-level-id=42e01f;packetization-mode=1;level-asymmetry-allowed=1"; + + ctx->data_channel.tracks[0].track_id = rtcAddTrackEx(ctx->data_channel.peer_connection, &track_init); + if (!ctx->data_channel.tracks[0].track_id) { + av_log(avctx, AV_LOG_ERROR, "Failed to add track\n"); + ret = AVERROR_EXTERNAL; + goto fail; + } + + /* configure audio track */ + memset(&track_init, 0, sizeof(rtcTrackInit)); + track_init.direction = RTC_DIRECTION_RECVONLY; + track_init.codec = RTC_CODEC_OPUS; // TODO: support more codecs once libdatachannel C api supports them + track_init.payloadType = 97; + track_init.ssrc = av_get_random_seed(); + track_init.mid = "1"; + track_init.name = LIBAVFORMAT_IDENT; + track_init.msid = media_stream_id; + track_init.trackId = av_asprintf("%s-audio", media_stream_id); + track_init.profile = "minptime=10;maxaveragebitrate=96000;stereo=1;sprop-stereo=1;useinbandfec=1"; + + ctx->data_channel.tracks[1].track_id = rtcAddTrackEx(ctx->data_channel.peer_connection, &track_init); + if (!ctx->data_channel.tracks[1].track_id) { + av_log(avctx, AV_LOG_ERROR, "Failed to add track\n"); + ret = AVERROR_EXTERNAL; + goto fail; + } + + /* create resource */ + ret = webrtc_create_resource(&ctx->data_channel); + if (ret < 0) { + av_log(avctx, AV_LOG_ERROR, "webrtc_create_resource failed\n"); + goto fail; + } + + /* initialize SDP muxer per track */ + for (int i = 0; i < ctx->data_channel.nb_tracks; i++) { + char sdp_track[SDP_MAX_SIZE] = { 0 }; + ret = rtcGetTrackDescription(ctx->data_channel.tracks[i].track_id, sdp_track, sizeof(sdp_track)); + if (ret < 0) { + av_log(avctx, AV_LOG_ERROR, "rtcGetTrackDescription failed\n"); + goto fail; + } + + ffio_init_read_context(&sdp_pb, (uint8_t*)sdp_track, strlen(sdp_track)); + + infmt = av_find_input_format("sdp"); + if (!infmt) + goto fail; + ctx->data_channel.tracks[i].rtp_ctx = avformat_alloc_context(); + if (!ctx->data_channel.tracks[i].rtp_ctx) { + ret = AVERROR(ENOMEM); + goto fail; + } + ctx->data_channel.tracks[i].rtp_ctx->max_delay = avctx->max_delay; + ctx->data_channel.tracks[i].rtp_ctx->pb = &sdp_pb.pub; + ctx->data_channel.tracks[i].rtp_ctx->interrupt_callback = avctx->interrupt_callback; + + if ((ret = ff_copy_whiteblacklists(ctx->data_channel.tracks[i].rtp_ctx, avctx)) < 0) + goto fail; + + av_dict_set(&options, "sdp_flags", "custom_io", 0); + + ret = avformat_open_input(&ctx->data_channel.tracks[i].rtp_ctx, "temp.sdp", infmt, &options); + if (ret < 0) { + av_log(avctx, AV_LOG_ERROR, "avformat_open_input failed\n"); + goto fail; + } + + ret = webrtc_init_urlcontext(&ctx->data_channel, i); + if (ret < 0) { + av_log(avctx, AV_LOG_ERROR, "webrtc_init_urlcontext failed\n"); + goto fail; + } + ret = ffio_fdopen(&ctx->data_channel.tracks[i].rtp_ctx->pb, ctx->data_channel.tracks[i].rtp_url_context); + if (ret < 0) { + av_log(avctx, AV_LOG_ERROR, "ffio_fdopen failed\n"); + goto fail; + } + + /* copy codec parameters */ + stream = avformat_new_stream(avctx, NULL); + if (!stream) { + ret = AVERROR(ENOMEM); + goto fail; + } + + ret = avcodec_parameters_copy(stream->codecpar, ctx->data_channel.tracks[i].rtp_ctx->streams[0]->codecpar); + if (ret < 0) { + av_log(avctx, AV_LOG_ERROR, "avcodec_parameters_copy failed\n"); + goto fail; + } + stream->time_base = ctx->data_channel.tracks[i].rtp_ctx->streams[0]->time_base; + } + + return 0; + +fail: + webrtc_deinit(&ctx->data_channel); + return ret; +} + +static int whep_read_close(AVFormatContext* avctx) +{ + WHEPContext*const ctx = (WHEPContext*const)avctx->priv_data; + int ret = 0; + + /* close resource */ + ret = webrtc_close_resource(&ctx->data_channel); + if (ret < 0) { + av_log(avctx, AV_LOG_ERROR, "webrtc_close_resource failed\n"); + } + + webrtc_deinit(&ctx->data_channel); + + return ret; +} + +static int whep_read_packet(AVFormatContext* avctx, AVPacket* pkt) +{ + const WHEPContext*const s = (const WHEPContext*const)avctx->priv_data; + const DataChannelTrack*const track = &s->data_channel.tracks[pkt->stream_index]; + pkt->stream_index = 0; + return av_read_frame(track->rtp_ctx, pkt); +} + + +#define OFFSET(x) offsetof(WHEPContext, x) +#define DEC AV_OPT_FLAG_DECODING_PARAM +static const AVOption options[] = { + WEBRTC_OPTIONS(DEC, OFFSET(data_channel)), + { NULL }, +}; + +static const AVClass whep_demuxer_class = { + .class_name = "WHEP demuxer", + .item_name = av_default_item_name, + .option = options, + .version = LIBAVUTIL_VERSION_INT, +}; + +const AVInputFormat ff_whep_demuxer = { + .name = "whep", + .long_name = NULL_IF_CONFIG_SMALL("WebRTC-HTTP egress protocol (WHEP) demuxer"), + .flags = AVFMT_NOFILE | AVFMT_EXPERIMENTAL, + .priv_class = &whep_demuxer_class, + .priv_data_size = sizeof(WHEPContext), + .read_header = whep_read_header, + .read_packet = whep_read_packet, + .read_close = whep_read_close, +}; -- 2.39.2 _______________________________________________ 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".