--- a/src/pika_repl_client_conn.cc +++ b/src/pika_repl_client_conn.cc @@ -47,7 +47,7 @@ std::shared_ptr response = std::make_shared(); ::google::protobuf::io::ArrayInputStream input(rbuf_ + cur_pos_ - header_len_, header_len_); ::google::protobuf::io::CodedInputStream decoder(&input); - decoder.SetTotalBytesLimit(g_pika_conf->max_conn_rbuf_size(), g_pika_conf->max_conn_rbuf_size()); + decoder.SetTotalBytesLimit(g_pika_conf->max_conn_rbuf_size()); bool success = response->ParseFromCodedStream(&decoder) && decoder.ConsumedEntireMessage(); if (!success) { LOG(WARNING) << "ParseFromArray FAILED! " << " msg_len: " << header_len_;