fix tests [4]

swoole · Sep 14, 2024 · bb29bfe · bb29bfe
1 parent 7cd6dd2
commit bb29bfe
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 7 deletions.
diff --git a/ext-src/swoole_process_pool.cc b/ext-src/swoole_process_pool.cc
@@ -430,9 +430,9 @@ static PHP_METHOD(swoole_process_pool, write) {
     char *data;
     size_t length;
 
-    if (zend_parse_parameters(ZEND_NUM_ARGS(), "s", &data, &length) == FAILURE) {
-        RETURN_FALSE;
-    }
+    ZEND_PARSE_PARAMETERS_START(1, 1)
+    Z_PARAM_STRING(data, length)
+    ZEND_PARSE_PARAMETERS_END_EX(RETURN_FALSE);
 
     ProcessPool *pool = process_pool_get_and_check_pool(ZEND_THIS);
     if (pool->ipc_mode != SW_IPC_SOCKET) {

diff --git a/src/os/process_pool.cc b/src/os/process_pool.cc
@@ -647,10 +647,6 @@ int ProcessPool::run_with_stream_protocol(ProcessPool *pool, Worker *worker) {
         pool->stream_info_->response_buffer = new String(SW_BUFFER_SIZE_STD);
     }
 
-    if (pool->ipc_mode == SW_IPC_UNIXSOCK && pool->message_bus == nullptr) {
-        pool->create_message_bus();
-    }
-
     QueueNode *outbuf = (QueueNode *) pool->packet_buffer;
     outbuf->mtype = 0;