Add tests [18] --filter=[core] --asan

Author: matyhtf

core-tests/src/os/process_pool.cpp

@@ -80,7 +80,7 @@ static void test_func_stream_protocol(ProcessPool &pool) {
 
 TEST(process_pool, tcp) {
     ProcessPool pool{};
-    int svr_port = swoole::test::get_random_port();
+    int svr_port = test::get_random_port();
     ASSERT_EQ(pool.create(1, 0, SW_IPC_SOCKET), SW_OK);
     ASSERT_EQ(pool.listen(TEST_HOST, svr_port, 128), SW_OK);
 
@@ -238,15 +238,24 @@ TEST(process_pool, reload) {
 
     pool.onWorkerStart = [](ProcessPool *pool, Worker *worker) {
         test::counter_incr(0);
+        current_pool = pool;
+
+        DEBUG() << "onWorkerStart " << worker->id << "\n";
 
         sysv_signal(SIGTERM, SIG_IGN);
+        sysv_signal(SIGRTMIN, [](int) { current_pool->reopen_logger(); });
+        sysv_signal(SIGWINCH, [](int) { current_pool->reopen_logger(); });
 
         while (true) {
             sleep(10000);
         }
     };
 
-    pool.onStart = [](ProcessPool *pool) { swoole_timer_after(100, [pool](TIMER_PARAMS) { pool->reload(); }); };
+    pool.onStart = [](ProcessPool *pool) {
+        pool->reopen_logger();
+        swoole_timer_after(50, [pool](TIMER_PARAMS) { kill(pool->get_worker(0)->pid, SIGRTMIN); });
+        swoole_timer_after(100, [pool](TIMER_PARAMS) { pool->reload(); });
+    };
 
     pool.onBeforeReload = [](ProcessPool *pool) { DEBUG() << "onBeforeReload\n"; };
 

src/os/process_pool.cc

@@ -1156,7 +1156,10 @@ void ReloadTask::add_workers(Worker *list, size_t n) {
 }
 
 void ReloadTask::add_timeout_killer(int timeout) {
-    timer = swoole_timer_add(sec2msec(timeout), false, [this](Timer *timer, TimerNode *tnode) { kill_all(); });
+    timer = swoole_timer_add(sec2msec(timeout), false, [this](Timer *, TimerNode *) {
+        kill_all();
+        timer = nullptr;
+    });
 }
 
 bool ReloadTask::remove(pid_t pid) {