Port swoole/swoole-src@b5129b0

cjavad · cjavad · commit 08c6dc6f9f56 · 2025-11-24T22:58:13.000+01:00
diff --git a/src/protocol/message_bus.cc b/src/protocol/message_bus.cc
@@ -108,6 +108,8 @@ ssize_t MessageBus::read(Socket *sock) {
                          info->msg_id,
                          sock->get_fd(),
                          info->reactor_id);
+        // Read data from the socket buffer and discard it.
+        recv(sock->get_fd(), info, sizeof(buffer_->info), 0);
         return SW_OK;
     }
 

Original file line number	Diff line number	Diff line change
`@@ -108,6 +108,8 @@ ssize_t MessageBus::read(Socket *sock) {`
`108`	`108`	`info->msg_id,`
`109`	`109`	`sock->get_fd(),`
`110`	`110`	`info->reactor_id);`
	`111`	`+ // Read data from the socket buffer and discard it.`
	`112`	`+ recv(sock->get_fd(), info, sizeof(buffer_->info), 0);`
`111`	`113`	`return SW_OK;`
`112`	`114`	`}`
`113`	`115`