Skip to content
Snippets Groups Projects
Commit 27658f41 authored by Yang Gao's avatar Yang Gao
Browse files

Clear receive message buffer when adding it, so that any reused buffer will...

Clear receive message buffer when adding it, so that any reused buffer will not appear when decoding fails.
parent 2cf95273
No related branches found
No related tags found
No related merge requests found
...@@ -31,6 +31,7 @@ ...@@ -31,6 +31,7 @@
* *
*/ */
#include <google/protobuf/message.h>
#include <grpc/support/alloc.h> #include <grpc/support/alloc.h>
#include <grpc++/impl/call.h> #include <grpc++/impl/call.h>
#include <grpc++/client_context.h> #include <grpc++/client_context.h>
...@@ -144,6 +145,7 @@ void CallOpBuffer::AddSendMessage(const google::protobuf::Message& message) { ...@@ -144,6 +145,7 @@ void CallOpBuffer::AddSendMessage(const google::protobuf::Message& message) {
void CallOpBuffer::AddRecvMessage(google::protobuf::Message* message) { void CallOpBuffer::AddRecvMessage(google::protobuf::Message* message) {
recv_message_ = message; recv_message_ = message;
recv_message_->Clear();
} }
void CallOpBuffer::AddClientSendClose() { client_send_close_ = true; } void CallOpBuffer::AddClientSendClose() { client_send_close_ = true; }
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment