diff --git a/src/cpp/common/call.cc b/src/cpp/common/call.cc index 70daa6a3b0425c34b6a221f6868d4984e5a2a5b4..f1142cf8e568acf50d75fd348ef9dbddf0d081e7 100644 --- a/src/cpp/common/call.cc +++ b/src/cpp/common/call.cc @@ -255,7 +255,7 @@ void CallOpBuffer::FinalizeResult(void** tag, bool* status) { // Parse received message if any. if (recv_message_) { if (recv_message_buf_) { - got_message = true; + got_message = *status; *status = *status && DeserializeProto(recv_message_buf_, recv_message_); grpc_byte_buffer_destroy(recv_message_buf_); recv_message_buf_ = nullptr;