From mboxrd@z Thu Jan 1 00:00:00 1970 Return-Path: Received: from ffbox0-bg.ffmpeg.org (ffbox0-bg.ffmpeg.org [79.124.17.100]) by master.gitmailbox.com (Postfix) with ESMTPS id E98384B974 for ; Tue, 22 Jul 2025 12:38:11 +0000 (UTC) Received: from [127.0.1.1] (localhost [127.0.0.1]) by ffbox0-bg.ffmpeg.org (Postfix) with ESMTP id 5368768D0D3; Tue, 22 Jul 2025 15:37:03 +0300 (EEST) Received: from mail-pl1-f174.google.com (mail-pl1-f174.google.com [209.85.214.174]) by ffbox0-bg.ffmpeg.org (Postfix) with ESMTPS id 70F6A68D096 for ; Tue, 22 Jul 2025 15:37:01 +0300 (EEST) Received: by mail-pl1-f174.google.com with SMTP id d9443c01a7336-23f8bcce78dso8731565ad.3 for ; Tue, 22 Jul 2025 05:37:01 -0700 (PDT) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=gmail.com; s=20230601; t=1753187819; x=1753792619; darn=ffmpeg.org; 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=T6x+p0d6zEP4hIgm8b2D1gbcL3IhjU6HPOfWhX4+7kQ=; b=fK2FNqHVdmbN7KiDQBqwrfeP45p7NYIEVqo2bqjygxtufeglove5SqPTx5i9Q5CnCy 2VPwlzsGGU7IM4fWy24Eu4aosGpmJBBwBs47NCK+w2RaNF9yRy0ck59uNCZRR51PeItc XyzyJw+jcothyljeyea41zku6QnDAD3f/8RBU/RxTXEdrZBTwPOI90nMxjdfsyO8hFdM b2KfgrwQ0xrXn5SwmkQgJpwjnjsCbtlFhlSdYl1PiC+JihENc8tkAT7Gx0bpdEEZ/wef ulGgPp82WMmyPvq9T4xNP79Hfde7QT6N08bAG+9jWrzyAVQurScjuH89Lwvxs//b+Bq4 Q1CQ== X-Google-DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=1e100.net; s=20230601; t=1753187819; x=1753792619; 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=T6x+p0d6zEP4hIgm8b2D1gbcL3IhjU6HPOfWhX4+7kQ=; b=ZH1TKeYeAyKaK2pE66Tbnm8IkHfIu8ACFWVBzFpvRXA4yBlm17hvuG5s+q8YcefUqd 2XHIOG+aOWGxd0tWbygqP6oPxVWYBmYyHPzmVarbO2gVR9nwfLj+Oum7BiFKFTwNQrOP rDVzfjsVhXnw8Kmmwtwkz0EhjhjOlCGviRA9zl+PLnDNXNWktQNfMsgNOPH0RWs+BhFU B2rM2SEVErIgCtYJDAyKyxYtgSXBXdeD9w3LXWpgneRtU02kUMn2eLMUXkePe07xDZuA mudR4tg64bCIM4uJZ40AYOE+mfxPMj8sOP3HiLTNCU/LykAexb1lz7eSKN1nEVgchAT9 8Brg== X-Gm-Message-State: AOJu0YzmA5jxleQLeLlHJmQKak3IbhwKV2WwfqHL7CAT0HUQ82nlBa4R gacHfvdV8hT3ehGXwl7QPD+f3ujWwI4m5go8CjHfiYt/d7tcjSjLEuNfWDU0SWtTXH8= X-Gm-Gg: ASbGnct78QVYsor6TQe70Sc2ns9poE/9PskfAzT/IgSzdSQhNTgL8RvDF6GLBkkgX8/ As/41gFapRUquPW0agOAxqE33nFDUAQQzcNmMHtIlE/iFh8BQ5rTBrX5Ir4eEeZhoYoMwuNSzJU FI3pzv7d4V/BziRzaPoy9rIcWXr341tjo1Cmv3fZDBuFhbLBTFqGb44xzkn+8DKm/UMKKa484Ty zwPjBRtKsedJwqHED4pinqNjQbc8ruaM6TIaIIktdkdfzcZgypBNZBa1/JZ3JBElpRgR+RwLRH1 M23BwM1mvybT9HzEzSZgIQ3vhqzrXIsyjLhKS+4YcDGlC1/lC0x86Hv+Tdj9PtdaMOMg+8RPLpG pgUNO2NqwqFnM6nuayBYV3lD4LPuCnXzCQ4EfQdRhVvV0/Q== X-Google-Smtp-Source: AGHT+IG394w161p3ukCqcpjQ6/zAflIcudRIPq9n8lebjt9mpPvxPklxvOZJnD7ExcVmpAiVRkKfAQ== X-Received: by 2002:a17:903:350d:b0:234:c549:da14 with SMTP id d9443c01a7336-23e303389aamr310867435ad.29.1753187819333; Tue, 22 Jul 2025 05:36:59 -0700 (PDT) Received: from localhost.localdomain ([182.126.128.169]) by smtp.gmail.com with ESMTPSA id d9443c01a7336-23e3b60edbasm75740715ad.70.2025.07.22.05.36.57 (version=TLS1_3 cipher=TLS_CHACHA20_POLY1305_SHA256 bits=256/256); Tue, 22 Jul 2025 05:36:59 -0700 (PDT) From: Jack Lau X-Google-Original-From: Jack Lau To: ffmpeg-devel@ffmpeg.org Date: Tue, 22 Jul 2025 20:36:09 +0800 Message-ID: <20250722123616.53164-9-jacklau1222@qq.com> X-Mailer: git-send-email 2.49.0 In-Reply-To: <20250722123616.53164-1-jacklau1222@qq.com> References: <20250722123616.53164-1-jacklau1222@qq.com> MIME-Version: 1.0 X-Unsent: 1 Subject: [FFmpeg-devel] [PATCH v5 08/15] avformat/whip: remove DTLSState enum 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: Jack Lau 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: This patch aims to simplify the dtls handshake process since dtls handshake use force block mode We can just use the return code instead of DTLSState enum Signed-off-by: Jack Lau --- libavformat/tls.h | 15 ---------- libavformat/tls_openssl.c | 7 ----- libavformat/tls_schannel.c | 7 ----- libavformat/whip.c | 59 ++++++++------------------------------ 4 files changed, 12 insertions(+), 76 deletions(-) diff --git a/libavformat/tls.h b/libavformat/tls.h index 0c02a4ab27..157c0d0256 100644 --- a/libavformat/tls.h +++ b/libavformat/tls.h @@ -33,17 +33,6 @@ */ #define MAX_CERTIFICATE_SIZE 8192 -enum DTLSState { - DTLS_STATE_NONE, - - /* Whether DTLS handshake is finished. */ - DTLS_STATE_FINISHED, - /* Whether DTLS session is closed. */ - DTLS_STATE_CLOSED, - /* Whether DTLS handshake is failed. */ - DTLS_STATE_FAILED, -}; - typedef struct TLSShared { char *ca_file; int verify; @@ -63,8 +52,6 @@ typedef struct TLSShared { int is_dtls; - enum DTLSState state; - /* The certificate and private key content used for DTLS handshake */ char* cert_buf; char* key_buf; @@ -103,8 +90,6 @@ int ff_tls_set_external_socket(URLContext *h, URLContext *sock); int ff_dtls_export_materials(URLContext *h, char *dtls_srtp_materials, size_t materials_sz); -int ff_dtls_state(URLContext *h); - int ff_ssl_read_key_cert(char *key_url, char *cert_url, char *key_buf, size_t key_sz, char *cert_buf, size_t cert_sz, char **fingerprint); int ff_ssl_gen_key_cert(char *key_buf, size_t key_sz, char *cert_buf, size_t cert_sz, char **fingerprint); diff --git a/libavformat/tls_openssl.c b/libavformat/tls_openssl.c index 2689aa5090..fa852aac18 100644 --- a/libavformat/tls_openssl.c +++ b/libavformat/tls_openssl.c @@ -541,12 +541,6 @@ int ff_dtls_export_materials(URLContext *h, char *dtls_srtp_materials, size_t ma return 0; } -int ff_dtls_state(URLContext *h) -{ - TLSContext *c = h->priv_data; - return c->tls_shared.state; -} - static int print_ssl_error(URLContext *h, int ret) { TLSContext *c = h->priv_data; @@ -725,7 +719,6 @@ static int dtls_handshake(URLContext *h) goto end; ret = 0; - p->tls_shared.state = DTLS_STATE_FINISHED; end: return ret; } diff --git a/libavformat/tls_schannel.c b/libavformat/tls_schannel.c index c92870347f..50f35acdd6 100644 --- a/libavformat/tls_schannel.c +++ b/libavformat/tls_schannel.c @@ -681,12 +681,6 @@ int ff_dtls_export_materials(URLContext *h, char *dtls_srtp_materials, size_t ma #endif } -int ff_dtls_state(URLContext *h) -{ - TLSContext *c = h->priv_data; - return c->tls_shared.state; -} - static void init_sec_buffer(SecBuffer *buffer, unsigned long type, void *data, unsigned long size) { @@ -1111,7 +1105,6 @@ static int tls_handshake(URLContext *h) #endif c->connected = 1; - s->state = DTLS_STATE_FINISHED; fail: return ret; diff --git a/libavformat/whip.c b/libavformat/whip.c index e02ed7a8a4..fe35ab7205 100644 --- a/libavformat/whip.c +++ b/libavformat/whip.c @@ -217,9 +217,6 @@ typedef struct WHIPContext { uint32_t flags; // enum WHIPFlags /* The state of the RTC connection. */ enum WHIPState state; - /* The callback return value for DTLS. */ - int dtls_ret; - int dtls_closed; /* Parameters for the input audio and video codecs. */ AVCodecParameters *audio_par; @@ -377,41 +374,6 @@ static av_cold int certificate_key_init(AVFormatContext *s) return ret; } -/** - * When DTLS state change. - */ -static int dtls_context_on_state(AVFormatContext *s, const char* type, const char* desc) -{ - int ret = 0; - WHIPContext *whip = s->priv_data; - int state = ff_dtls_state(whip->dtls_uc); - - if (state == DTLS_STATE_CLOSED) { - whip->dtls_closed = 1; - av_log(whip, AV_LOG_VERBOSE, "DTLS session closed, type=%s, desc=%s, elapsed=%dms\n", - type ? type : "", desc ? desc : "", ELAPSED(whip->whip_starttime, av_gettime())); - goto error; - } - - if (state == DTLS_STATE_FAILED) { - whip->state = WHIP_STATE_FAILED; - av_log(whip, AV_LOG_ERROR, "DTLS session failed, type=%s, desc=%s\n", - type ? type : "", desc ? desc : ""); - whip->dtls_ret = AVERROR(EIO); - goto error; - } - - if (state == DTLS_STATE_FINISHED && whip->state < WHIP_STATE_DTLS_FINISHED) { - whip->state = WHIP_STATE_DTLS_FINISHED; - whip->whip_dtls_time = av_gettime(); - av_log(whip, AV_LOG_VERBOSE, "DTLS handshake is done, elapsed=%dms\n", - ELAPSED(whip->whip_starttime, av_gettime())); - return ret; - } -error: - return -1; -} - static av_cold int dtls_initialize(AVFormatContext *s) { WHIPContext *whip = s->priv_data; @@ -1377,9 +1339,18 @@ next_packet: /* If got any DTLS messages, handle it. */ if ((is_dtls_packet(whip->buf, ret) || is_dtls_active) && whip->state >= WHIP_STATE_ICE_CONNECTED || whip->state == WHIP_STATE_DTLS_CONNECTING) { whip->state = WHIP_STATE_DTLS_CONNECTING; - if ((ret = ffurl_handshake(whip->dtls_uc)) < 0) + ret = ffurl_handshake(whip->dtls_uc); + if (ret < 0) { + whip->state = WHIP_STATE_FAILED; + av_log(whip, AV_LOG_VERBOSE, "DTLS session failed\n"); goto end; - dtls_context_on_state(s, NULL, NULL); + } + if (!ret) { + whip->state = WHIP_STATE_DTLS_FINISHED; + whip->whip_dtls_time = av_gettime(); + av_log(whip, AV_LOG_VERBOSE, "DTLS handshake is done, elapsed=%dms\n", + ELAPSED(whip->whip_starttime, whip->whip_dtls_time)); + } goto next_packet; } } @@ -1910,8 +1881,6 @@ static av_cold int whip_init(AVFormatContext *s) end: if (ret < 0 && whip->state < WHIP_STATE_FAILED) whip->state = WHIP_STATE_FAILED; - if (ret >= 0 && whip->state >= WHIP_STATE_FAILED && whip->dtls_ret < 0) - ret = whip->dtls_ret; return ret; } @@ -2022,12 +1991,8 @@ write_packet: end: if (buf) av_freep(&buf); - if (ret < 0 && whip->state < WHIP_STATE_FAILED) + if (ret < 0) whip->state = WHIP_STATE_FAILED; - if (ret >= 0 && whip->state >= WHIP_STATE_FAILED && whip->dtls_ret < 0) - ret = whip->dtls_ret; - if (ret >= 0 && whip->dtls_closed) - ret = AVERROR(EIO); return ret; } -- 2.49.0 _______________________________________________ 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".