socket: Allow selection of TCP Congestion Avoidance algorithm to socket

[elogind.git] / src / socket.c

diff --git a/src/socket.c b/src/socket.c
index 82a9348d13f2f8fa617991de3b92808e25f0aca5..2da3215a3d3ed12d76615bd2c35ad87818391ed5 100644 (file)
--- a/src/socket.c
+++ b/src/socket.c
@@ -31,6 +31,7 @@
 
 #include "unit.h"
 #include "socket.h"
 
 #include "unit.h"
 #include "socket.h"

+#include "netinet/tcp.h"

 #include "log.h"
 #include "load-dropin.h"
 #include "load-fragment.h"
 #include "log.h"
 #include "load-dropin.h"
 #include "load-fragment.h"


@@ -116,6 +117,9 @@ static void socket_done(Unit *u) {
 
         s->service = NULL;
 
 
         s->service = NULL;
 

+        free(s->tcp_congestion);
+        s->tcp_congestion = NULL;
+

         free(s->bind_to_device);
         s->bind_to_device = NULL;
 
         free(s->bind_to_device);
         s->bind_to_device = NULL;
 


@@ -371,14 +375,16 @@ static void socket_dump(Unit *u, FILE *f, const char *prefix) {
                 "%sSocketMode: %04o\n"
                 "%sDirectoryMode: %04o\n"
                 "%sKeepAlive: %s\n"
                 "%sSocketMode: %04o\n"
                 "%sDirectoryMode: %04o\n"
                 "%sKeepAlive: %s\n"

-                "%sFreeBind: %s\n",
+                "%sFreeBind: %s\n"
+                "%sTCPCongestion: %s\n",

                 prefix, socket_state_to_string(s->state),
                 prefix, socket_address_bind_ipv6_only_to_string(s->bind_ipv6_only),
                 prefix, s->backlog,
                 prefix, s->socket_mode,
                 prefix, s->directory_mode,
                 prefix, yes_no(s->keep_alive),
                 prefix, socket_state_to_string(s->state),
                 prefix, socket_address_bind_ipv6_only_to_string(s->bind_ipv6_only),
                 prefix, s->backlog,
                 prefix, s->socket_mode,
                 prefix, s->directory_mode,
                 prefix, yes_no(s->keep_alive),

-                prefix, yes_no(s->free_bind));
+                prefix, yes_no(s->free_bind),
+                prefix, s->tcp_congestion);

 
         if (s->control_pid > 0)
                 fprintf(f,
 
         if (s->control_pid > 0)
                 fprintf(f,


@@ -632,6 +638,10 @@ static void socket_apply_socket_options(Socket *s, int fd) {
                 if (r < 0 && x < 0)
                         log_warning("IP_TTL/IPV6_UNICAST_HOPS failed: %m");
         }
                 if (r < 0 && x < 0)
                         log_warning("IP_TTL/IPV6_UNICAST_HOPS failed: %m");
         }

+
+        if (s->tcp_congestion)
+                if (setsockopt(fd, SOL_TCP, TCP_CONGESTION, s->tcp_congestion, strlen(s->tcp_congestion)+1) < 0)
+                        log_warning("TCP_CONGESTION failed: %m");

 }
 
 static void socket_apply_fifo_options(Socket *s, int fd) {
 }
 
 static void socket_apply_fifo_options(Socket *s, int fd) {