Add tests [3] --filter=[core][unit]

Author: matyhtf

core-tests/src/coroutine/system.cpp

@@ -115,6 +115,22 @@ TEST(coroutine_system, getaddrinfo) {
     });
 }
 
+TEST(coroutine_system, getaddrinfo_fail) {
+    test::coroutine::run([](void *arg) {
+        auto ip_list = System::getaddrinfo("w11.baidu.com-not-exists", AF_INET, SOCK_STREAM, 0, "http", -1);
+        ASSERT_EQ(ip_list.size(), 0);
+        ASSERT_ERREQ(EAI_NONAME);
+    });
+}
+
+TEST(coroutine_system, getaddrinfo_timeout) {
+    test::coroutine::run([](void *arg) {
+        auto ip_list = System::getaddrinfo("w12.baidu.com-not-exists", AF_INET, SOCK_STREAM, 0, "http", 0.005);
+        ASSERT_EQ(ip_list.size(), 0);
+        ASSERT_ERREQ(SW_ERROR_CO_TIMEDOUT);
+    });
+}
+
 TEST(coroutine_system, wait_signal) {
     test::coroutine::run([](void *arg) {
         Coroutine::create([](void *) {
@@ -126,6 +142,22 @@ TEST(coroutine_system, wait_signal) {
     });
 }
 
+TEST(coroutine_system, wait_signal_invalid_signo) {
+    test::coroutine::run([](void *arg) {
+        ASSERT_EQ(System::wait_signal(SW_SIGNO_MAX), SW_ERR);
+        ASSERT_ERREQ(EINVAL);
+    });
+}
+
+TEST(coroutine_system, wait_signal_fail) {
+    test::coroutine::run([](void *arg) {
+        SwooleG.signal_listener_num = 1;
+        ASSERT_EQ(System::wait_signal(SIGUSR1, 1.0), SW_ERR);
+        ASSERT_ERREQ(EBUSY);
+        SwooleG.signal_listener_num = 0;
+    });
+}
+
 static const char *GREETING = "hello world, hello swoole";
 
 TEST(coroutine_system, wait_event_readable) {

core-tests/src/server/server.cpp

@@ -3074,8 +3074,8 @@ TEST(server, send_timeout) {
     ASSERT_EQ(counter[3], 1);
 }
 
-TEST(server, max_request) {
-    Server serv(Server::MODE_PROCESS);
+static void test_max_request(Server::Mode mode) {
+    Server serv(mode);
     serv.worker_num = 2;
     serv.max_request = 128;
 
@@ -3092,16 +3092,26 @@ TEST(server, max_request) {
             lock->lock();
             ListenPort *port = serv->get_primary_port();
 
-            network::SyncClient c(SW_SOCK_TCP);
-            c.connect(TEST_HOST, port->port);
+            auto client_fn = [&]() {
+                network::SyncClient c(SW_SOCK_TCP);
+                c.connect(TEST_HOST, port->port);
 
-            SW_LOOP_N(1024) {
-                c.send(packet, strlen(packet));
-                usleep(1000);
+                SW_LOOP_N(128) {
+                    if (c.send(packet, strlen(packet)) < 0) {
+                        break;
+                    }
+                    usleep(1000);
+                }
+                c.close();
+            };
+
+            SW_LOOP_N(8) {
+                client_fn();
+                usleep(10000);
             }
 
             sleep(1);
-            c.close();
+
             serv->shutdown();
         });
     };
@@ -3121,6 +3131,14 @@ TEST(server, max_request) {
     ASSERT_GE(test::counter_get(0), 8);
 }
 
+TEST(server, max_request_1) {
+    test_max_request(Server::MODE_PROCESS);
+}
+
+TEST(server, max_request_2) {
+    test_max_request(Server::MODE_THREAD);
+}
+
 TEST(server, watermark) {
     Server serv(Server::MODE_PROCESS);
     serv.worker_num = 2;