From a6b9d8d08df9ac3c8bdcd0fc697f9443b44ec5e3 Mon Sep 17 00:00:00 2001
From: YuQing <384681@qq.com>
Date: Sun, 6 Dec 2020 17:00:14 +0800
Subject: [PATCH] TCP_SET_QUICK_ACK for Linux

---
 src/sf_global.c | 11 ++++++++---
 src/sf_global.h |  1 +
 src/sf_nio.c    |  1 +
 3 files changed, 10 insertions(+), 3 deletions(-)

diff --git a/src/sf_global.c b/src/sf_global.c
index ee03954..aa14973 100644
--- a/src/sf_global.c
+++ b/src/sf_global.c
@@ -34,7 +34,7 @@
 
 SFGlobalVariables g_sf_global_vars = {
     DEFAULT_CONNECT_TIMEOUT, DEFAULT_NETWORK_TIMEOUT,
-    {'/', 't', 'm', 'p', '\0'}, true, DEFAULT_MAX_CONNECTONS,
+    {'/', 't', 'm', 'p', '\0'}, true, true, DEFAULT_MAX_CONNECTONS,
     SF_DEF_MAX_PACKAGE_SIZE, SF_DEF_MIN_BUFF_SIZE,
     SF_DEF_MAX_BUFF_SIZE, 0, SF_DEF_THREAD_STACK_SIZE,
     SYNC_LOG_BUFF_DEF_INTERVAL, 0, 0, 0, {'\0'}, {'\0'}, false, 0, {0, 0}
@@ -165,6 +165,9 @@ int sf_load_global_config_ex(const char *server_name,
         return ENOTDIR;
     }
 
+    g_sf_global_vars.tcp_quick_ack = iniGetBoolValue(NULL,
+            "tcp_quick_ack", ini_ctx->context, true);
+    tcp_set_quick_ack(g_sf_global_vars.tcp_quick_ack);
     if (load_network_params) {
         if ((result=load_network_parameters(ini_ctx,
                         task_buffer_extra_size)) != 0)
@@ -390,8 +393,9 @@ void sf_global_config_to_string(char *output, const int size)
             "base_path=%s, max_connections=%d, connect_timeout=%d, "
             "network_timeout=%d, thread_stack_size=%s, max_pkg_size=%s, "
             "min_buff_size=%s, max_buff_size=%s, task_buffer_extra_size=%d, "
-            "log_level=%s, sync_log_buff_interval=%d, rotate_error_log=%d, "
-            "log_file_keep_days=%d, run_by_group=%s, run_by_user=%s",
+            "tcp_quick_ack=%d, log_level=%s, sync_log_buff_interval=%d, "
+            "rotate_error_log=%d, log_file_keep_days=%d, "
+            "run_by_group=%s, run_by_user=%s",
             g_sf_global_vars.base_path,
             g_sf_global_vars.max_connections,
             g_sf_global_vars.connect_timeout,
@@ -402,6 +406,7 @@ void sf_global_config_to_string(char *output, const int size)
             int_to_comma_str(g_sf_global_vars.min_buff_size, sz_min_buff_size),
             int_to_comma_str(g_sf_global_vars.max_buff_size, sz_max_buff_size),
             g_sf_global_vars.task_buffer_extra_size,
+            g_sf_global_vars.tcp_quick_ack,
             log_get_level_caption(),
             g_sf_global_vars.sync_log_buff_interval,
             g_sf_global_vars.rotate_error_log,
diff --git a/src/sf_global.h b/src/sf_global.h
index 0b0accb..f2fbb9b 100644
--- a/src/sf_global.h
+++ b/src/sf_global.h
@@ -35,6 +35,7 @@ typedef struct sf_global_variables {
     char base_path[MAX_PATH_SIZE];
 
     volatile bool continue_flag;
+    bool tcp_quick_ack;
     int max_connections;
     int max_pkg_size;
     int min_buff_size;
diff --git a/src/sf_nio.c b/src/sf_nio.c
index 81f5ff1..99fdf24 100644
--- a/src/sf_nio.c
+++ b/src/sf_nio.c
@@ -547,6 +547,7 @@ int sf_client_sock_read(int sock, short event, void *arg)
             return -1;
         }
 
+        TCP_SET_QUICK_ACK(sock);
         total_read += bytes;
         task->offset += bytes;
         if (task->length == 0) { //header