make server tolerate deserialization failure

10 years ago · f7d05b572b
parent ff30f8e8a9
commit f7d05b572b
1 changed files with 3 additions and 1 deletions
--- 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());
      }