From 030520cb3aad56004e92ab097fc6f1e0a10c652e Mon Sep 17 00:00:00 2001
From: YuQing <384681@qq.com>
Date: Fri, 29 Dec 2023 10:21:41 +0800
Subject: [PATCH] use INIT_SCHEDULE_ENTRY_EX1 for new thread

---
 storage/fdfs_storaged.c         |  4 ++--
 storage/tracker_client_thread.c | 10 ++++------
 2 files changed, 6 insertions(+), 8 deletions(-)

diff --git a/storage/fdfs_storaged.c b/storage/fdfs_storaged.c
index 643d4a7..248c408 100644
--- a/storage/fdfs_storaged.c
+++ b/storage/fdfs_storaged.c
@@ -492,9 +492,9 @@ static int setup_schedule_tasks()
 
 	if (g_compress_binlog)
 	{
-		INIT_SCHEDULE_ENTRY_EX(scheduleEntries[scheduleArray.count],
+		INIT_SCHEDULE_ENTRY_EX1(scheduleEntries[scheduleArray.count],
 			sched_generate_next_id(), g_compress_binlog_time,
-			24 * 3600, fdfs_binlog_compress_func, NULL);
+			24 * 3600, fdfs_binlog_compress_func, NULL, true);
 		scheduleArray.count++;
     }
 
diff --git a/storage/tracker_client_thread.c b/storage/tracker_client_thread.c
index d9813d0..1074fad 100644
--- a/storage/tracker_client_thread.c
+++ b/storage/tracker_client_thread.c
@@ -1236,21 +1236,19 @@ static int do_set_trunk_server_myself(ConnectionInfo *pTrackerServer)
     if (g_trunk_create_file_advance &&
             g_trunk_create_file_interval > 0)
     {
-        INIT_SCHEDULE_ENTRY_EX(*entry, TRUNK_FILE_CREATOR_TASK_ID,
+        INIT_SCHEDULE_ENTRY_EX1(*entry, TRUNK_FILE_CREATOR_TASK_ID,
                 g_trunk_create_file_time_base,
                 g_trunk_create_file_interval,
-                trunk_create_trunk_file_advance, NULL);
-        entry->new_thread = true;
+                trunk_create_trunk_file_advance, NULL, true);
         entry++;
     }
 
     if (g_trunk_compress_binlog_interval > 0)
     {
-        INIT_SCHEDULE_ENTRY_EX(*entry, TRUNK_BINLOG_COMPRESS_TASK_ID,
+        INIT_SCHEDULE_ENTRY_EX1(*entry, TRUNK_BINLOG_COMPRESS_TASK_ID,
                 g_trunk_compress_binlog_time_base,
                 g_trunk_compress_binlog_interval,
-                trunk_binlog_compress_func, NULL);
-        entry->new_thread = true;
+                trunk_binlog_compress_func, NULL, true);
         entry++;
     }