mirrors/gstreamer
mirrors/gstreamer
1
1
Fork 0
mirror of https://gitlab.freedesktop.org/gstreamer/gstreamer.git synced 2025-02-17 19:55:32 +00:00
Code Issues 1 Projects Releases Wiki Activity

server: use SO_LINGER

Browse source 
SO_LINGER on the socket will make sure that any pending data on the socket is
flushed ASAP and that the socket connection is reset. This makes sure that the
socket can be reused immediately.

Fixes 622757
This commit is contained in:
Robert Krakora 2010-08-16 12:32:28 +02:00 committed by Wim Taymans
parent f2a2577f13
commit 8f6fd32065
1 changed files with 21 additions and 11 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

32
gst/rtsp-server/rtsp-server.c
View file

@ -421,6 +421,7 @@ gst_rtsp_server_sink_init_send (GstRTSPServer * server)
int ret, sockfd; int ret, sockfd;
struct addrinfo hints; struct addrinfo hints;
struct addrinfo *result, *rp; struct addrinfo *result, *rp;
struct linger linger;
memset(&hints, 0, sizeof(struct addrinfo)); memset(&hints, 0, sizeof(struct addrinfo));
hints.ai_family = AF_UNSPEC; /* Allow IPv4 or IPv6 */ hints.ai_family = AF_UNSPEC; /* Allow IPv4 or IPv6 */
@ -476,6 +477,14 @@ gst_rtsp_server_sink_init_send (GstRTSPServer * server)
(void *) &ret, sizeof (ret)) < 0) (void *) &ret, sizeof (ret)) < 0)
goto keepalive_failed; goto keepalive_failed;
/* make sure socket is reset immediately after close. This ensure that we can
* reuse the socket quickly. */
linger.l_onoff = 1;
linger.l_linger = 0;
if (setsockopt (server->server_sock.fd, SOL_SOCKET, SO_LINGER,
(void *) &linger, sizeof (linger)) < 0)
goto linger_failed;
/* set the server socket to nonblocking */ /* set the server socket to nonblocking */
fcntl (server->server_sock.fd, F_SETFL, O_NONBLOCK); fcntl (server->server_sock.fd, F_SETFL, O_NONBLOCK);
@ -505,29 +514,30 @@ no_socket:
} }
reuse_failed: reuse_failed:
{ {
if (server->server_sock.fd >= 0) {
close (server->server_sock.fd);
server->server_sock.fd = -1;
}
GST_ERROR_OBJECT (server, "failed to reuse socket: %s", g_strerror (errno)); GST_ERROR_OBJECT (server, "failed to reuse socket: %s", g_strerror (errno));
return FALSE; goto close_error;
} }
keepalive_failed: keepalive_failed:
{ {
if (server->server_sock.fd >= 0) {
close (server->server_sock.fd);
server->server_sock.fd = -1;
}
GST_ERROR_OBJECT (server, "failed to configure keepalive socket: %s", g_strerror (errno)); GST_ERROR_OBJECT (server, "failed to configure keepalive socket: %s", g_strerror (errno));
return FALSE; goto close_error;
}
linger_failed:
{
GST_ERROR_OBJECT (server, "failed to no linger socket: %s", g_strerror (errno));
goto close_error;
} }
listen_failed: listen_failed:
{
GST_ERROR_OBJECT (server, "failed to listen on socket: %s", g_strerror (errno));
goto close_error;
}
close_error:
{ {
if (server->server_sock.fd >= 0) { if (server->server_sock.fd >= 0) {
close (server->server_sock.fd); close (server->server_sock.fd);
server->server_sock.fd = -1; server->server_sock.fd = -1;
} }
GST_ERROR_OBJECT (server, "failed to listen on socket: %s", g_strerror (errno));
return FALSE; return FALSE;
} }
} }