Skip to content

Commit bb29bfe

Browse files
committed
fix tests [4]
1 parent 7cd6dd2 commit bb29bfe

File tree

2 files changed

+3
-7
lines changed

2 files changed

+3
-7
lines changed

ext-src/swoole_process_pool.cc

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -430,9 +430,9 @@ static PHP_METHOD(swoole_process_pool, write) {
430430
char *data;
431431
size_t length;
432432

433-
if (zend_parse_parameters(ZEND_NUM_ARGS(), "s", &data, &length) == FAILURE) {
434-
RETURN_FALSE;
435-
}
433+
ZEND_PARSE_PARAMETERS_START(1, 1)
434+
Z_PARAM_STRING(data, length)
435+
ZEND_PARSE_PARAMETERS_END_EX(RETURN_FALSE);
436436

437437
ProcessPool *pool = process_pool_get_and_check_pool(ZEND_THIS);
438438
if (pool->ipc_mode != SW_IPC_SOCKET) {

src/os/process_pool.cc

Lines changed: 0 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -647,10 +647,6 @@ int ProcessPool::run_with_stream_protocol(ProcessPool *pool, Worker *worker) {
647647
pool->stream_info_->response_buffer = new String(SW_BUFFER_SIZE_STD);
648648
}
649649

650-
if (pool->ipc_mode == SW_IPC_UNIXSOCK && pool->message_bus == nullptr) {
651-
pool->create_message_bus();
652-
}
653-
654650
QueueNode *outbuf = (QueueNode *) pool->packet_buffer;
655651
outbuf->mtype = 0;
656652

0 commit comments

Comments
 (0)