From f7d05b572b229a78a08022e286f15fbb6b7266fd Mon Sep 17 00:00:00 2001
From: Yang Gao <yangg@google.com>
Date: Mon, 4 May 2015 00:14:02 -0700
Subject: [PATCH] make server tolerate deserialization failure
---
src/cpp/server/server.cc | 4 +++-
1 file changed, 3 insertions(+), 1 deletion(-)
diff --git a/src/cpp/server/server.cc b/src/cpp/server/server.cc
index b7128da8c4..9338451630 100644
--- a/src/cpp/server/server.cc
+++ b/src/cpp/server/server.cc
@@ -127,7 +127,9 @@ class Server::SyncRequest GRPC_FINAL : public CompletionQueueTag {
GRPC_TIMER_BEGIN(GRPC_PTAG_PROTO_DESERIALIZE, call_.call());
req.reset(method_->AllocateRequestProto());
if (!DeserializeProto(request_payload_, req.get(), call_.max_message_size())) {
- abort(); // for now
+ // FIXME(yangg) deal with deserialization failure
+ cq_.Shutdown();
+ return;
}
GRPC_TIMER_END(GRPC_PTAG_PROTO_DESERIALIZE, call_.call());
}
--
GitLab