breeze/FFmpeg
1
0
Fork 0
mirror of https://github.com/FFmpeg/FFmpeg.git synced 2026-01-12 00:06:51 +08:00
Code Issues Packages Projects Releases Wiki Activity

avformat/tls_gnutls: add gnutls_pull_timeout() for dtls

Browse Source 
See https://gnutls.org/manual/gnutls.html#index-gnutls_005ftransport_005fset_005fpull_005ftimeout_005ffunction

This callback is necessary for enforcing the DTLS mode timeouts when in blocking mode.

Otherwise the dtls pull function won't work.

The gnutls_pull_timeout() implementation refers to gnutls example:
https://gnutls.org/manual/gnutls.html#DTLS-echo-server-with-X_002e509-authentication-1

Signed-off-by: Jack Lau <jacklau1222gm@gmail.com>
This commit is contained in:
Jack Lau
2026-01-10 20:37:08 +08:00
committed by Gyan Doshi
parent 202b7d29e8
commit b0fe52ba4e
1 changed files with 26 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

27
libavformat/tls_gnutls.c
View File

@@ -167,6 +167,29 @@ static ssize_t gnutls_url_push(gnutls_transport_ptr_t transport,
return -1;
}
static int gnutls_pull_timeout(gnutls_transport_ptr_t ptr, unsigned int ms)
{
TLSContext *c = (TLSContext*) ptr;
TLSShared *s = &c->tls_shared;
int ret;
fd_set rfds;
struct timeval tv;
int sockfd = ffurl_get_file_handle(s->udp);
if (sockfd < 0)
return 0;
FD_ZERO(&rfds);
FD_SET(sockfd, &rfds);
tv.tv_sec = ms / 1000;
tv.tv_usec = (ms % 1000) * 1000;
ret = select(sockfd + 1, &rfds, NULL, NULL, &tv);
if (ret <= 0)
return ret;
return 1;
}
static int tls_handshake(URLContext *h)
{
TLSContext *c = h->priv_data;
@@ -244,9 +267,11 @@ static int tls_open(URLContext *h, const char *uri, int flags, AVDictionary **op
gnutls_transport_set_pull_function(c->session, gnutls_url_pull);
gnutls_transport_set_push_function(c->session, gnutls_url_push);
gnutls_transport_set_ptr(c->session, c);
if (s->is_dtls)
if (s->is_dtls) {
gnutls_transport_set_pull_timeout_function(c->session, gnutls_pull_timeout);
if (s->mtu)
gnutls_dtls_set_mtu(c->session, s->mtu);
}
gnutls_set_default_priority(c->session);
ret = tls_handshake(h);
if (ret < 0)