File tree Expand file tree Collapse file tree 1 file changed +2
-2
lines changed Expand file tree Collapse file tree 1 file changed +2
-2
lines changed Original file line number Diff line number Diff line change @@ -48,9 +48,9 @@ int PikaReplClientConn::DealMessage() {
48
48
::google::protobuf::io::ArrayInputStream input (rbuf_ + cur_pos_ - header_len_, header_len_);
49
49
::google::protobuf::io::CodedInputStream decoder (&input);
50
50
decoder.SetTotalBytesLimit (g_pika_conf->max_conn_rbuf_size (), g_pika_conf->max_conn_rbuf_size ());
51
- bool success = response->ParseFromCodedStream (&decoder);
51
+ bool success = response->ParseFromCodedStream (&decoder) && decoder. ConsumedEntireMessage () ;
52
52
if (!success) {
53
- LOG (WARNING) << " ParseFromArray FAILED! rbuf_len: " << rbuf_len_ << " header_len : " << header_len_;
53
+ LOG (WARNING) << " ParseFromArray FAILED! " << " msg_len : " << header_len_;
54
54
g_pika_server->SyncError ();
55
55
return -1 ;
56
56
}
You can’t perform that action at this time.
0 commit comments