When the entire op fails, the recv_message is always discarded.

pull/501/head
Yang Gao 10 years ago
parent 0b7c4d29d4
commit 467d7bd414
  1. 2
      src/cpp/common/call.cc
  2. 2
      src/cpp/server/server.cc

@ -256,7 +256,7 @@ void CallOpBuffer::FinalizeResult(void** tag, bool* status) {
if (recv_message_) { if (recv_message_) {
if (recv_message_buf_) { if (recv_message_buf_) {
got_message = true; got_message = true;
*status &= DeserializeProto(recv_message_buf_, recv_message_); *status = *status && DeserializeProto(recv_message_buf_, recv_message_);
grpc_byte_buffer_destroy(recv_message_buf_); grpc_byte_buffer_destroy(recv_message_buf_);
recv_message_buf_ = nullptr; recv_message_buf_ = nullptr;
} else { } else {

@ -314,7 +314,7 @@ class Server::AsyncRequest final : public CompletionQueueTag {
*tag = tag_; *tag = tag_;
if (*status && request_) { if (*status && request_) {
if (payload_) { if (payload_) {
*status &= DeserializeProto(payload_, request_); *status = *status && DeserializeProto(payload_, request_);
} else { } else {
*status = false; *status = false;
} }

Loading…
Cancel
Save