From 2710a30afb02ab97cb4b8dd67f3d2053d7fcdcef Mon Sep 17 00:00:00 2001 From: jenrryyou Date: Thu, 5 Feb 2026 14:49:58 +0800 Subject: [PATCH] Fix stream closed before response during batch stream creation --- src/brpc/controller.cpp | 1 + 1 file changed, 1 insertion(+) diff --git a/src/brpc/controller.cpp b/src/brpc/controller.cpp index d7b511dbd4..d3821eca80 100644 --- a/src/brpc/controller.cpp +++ b/src/brpc/controller.cpp @@ -1448,6 +1448,7 @@ void Controller::HandleStreamConnection(Socket *host_socket) { auto extra_stream_ids = std::move(*_remote_stream_settings->mutable_extra_stream_ids()); _remote_stream_settings->clear_extra_stream_ids(); for (size_t i = 1; i < stream_num; ++i) { + if(!ptrs[i]) continue; Stream* extra_stream = (Stream *) ptrs[i]->conn(); _remote_stream_settings->set_stream_id(extra_stream_ids[i - 1]); s->SetHostSocket(host_socket);