Fix tests [1] --filter=[core] --verbose

Author: matyhtf

core-tests/src/main.cpp

@@ -22,6 +22,10 @@ int main(int argc, char **argv) {
     swoole_set_trace_flags(SW_TRACE_ALL);
 #endif
 
+    if (getenv("VERBOSE") != nullptr && std::string(getenv("VERBOSE")) == "0") {
+        swoole_set_log_level(SW_LOG_INFO);
+    }
+
     ::testing::InitGoogleTest(&argc, argv);
     int retval = RUN_ALL_TESTS();
 

core-tests/src/server/server.cpp

@@ -2266,11 +2266,14 @@ static void test_clean_worker(Server::Mode mode) {
     };
 
     serv.onStart = [port, &ac, counter](Server *_serv) {
-        swoole_timer_after(50, [port, _serv, &ac, counter](TIMER_PARAMS) {
+        swoole_timer_after(100, [port, _serv, &ac, counter](TIMER_PARAMS) {
             ac.on_connect([&](AsyncClient *ac) { ac->send(SW_STRL(TEST_STR)); });
 
-            ac.on_close(
-                [_serv](AsyncClient *ac) { swoole_timer_after(50, [_serv](TIMER_PARAMS) { _serv->shutdown(); }); });
+            ac.on_close([_serv](AsyncClient *ac) {
+                swoole_timer_after(100, [_serv, ac](TIMER_PARAMS) {
+                    _serv->shutdown();
+                });
+            });
 
             ac.on_error([](AsyncClient *ac) {});
 

src/server/worker.cc

@@ -359,7 +359,7 @@ bool Server::kill_worker(int worker_id, bool wait_reactor) {
         return send_to_worker_from_worker(get_worker(worker_id), &event, sizeof(event), SW_PIPE_MASTER) != -1;
     }
 
-    if (current_worker && worker_id == current_worker->id && !wait_reactor) {
+    if (current_worker && (WorkerId) worker_id == current_worker->id && !wait_reactor) {
         if (swoole_event_is_available()) {
             swoole_event_defer([](void *data) { sw_reactor()->running = false; }, nullptr);
         }