Fix the race when creating agent socket

c5c671fa · zhujiashun · gejun · f12bd910 · c5c671fa
Commit c5c671fa authored May 31, 2018 by zhujiashun Committed by gejun Sep 26, 2018
Hide whitespace changes
Inline Side-by-side

Showing with 1 addition and 4 deletions

http2_rpc_protocol.cpp src/brpc/policy/http2_rpc_protocol.cpp +1 -4

No files found.
--- a/src/brpc/policy/http2_rpc_protocol.cpp
+++ b/src/brpc/policy/http2_rpc_protocol.cpp
@@ -1534,10 +1534,7 @@ void H2GlobalStreamCreator::ReplaceSocketForStream(
            break;
        }
        H2Context* ctx = static_cast<H2Context*>((*inout)->_agent_socket->parsing_context());
-        if (ctx == NULL) {
-            break;
-        }
-        if (ctx->RunOutStreams()) {
+        if (ctx && ctx->RunOutStreams()) {
            break;
        }
        (*inout)->_agent_socket->ReAddress(inout);