diff --git a/src/brpc/policy/rtmp_protocol.cpp b/src/brpc/policy/rtmp_protocol.cpp index 8ad63fb958..d72684b1ed 100644 --- a/src/brpc/policy/rtmp_protocol.cpp +++ b/src/brpc/policy/rtmp_protocol.cpp @@ -2714,9 +2714,11 @@ bool RtmpChunkStream::OnCreateStream(const RtmpMessageHeader& mh, PLOG(WARNING) << socket->remote_side() << '[' << mh.stream_id << "] Fail to respond createStream"; // End the stream at server-side. - const bthread_id_t id = stream->_onfail_id; - if (id != INVALID_BTHREAD_ID) { - bthread_id_error(id, 0); + if (stream != nullptr) { + const bthread_id_t id = stream->_onfail_id; + if (id != INVALID_BTHREAD_ID) { + bthread_id_error(id, 0); + } } return false; }