Not call gRPC Finish if Write fail. (envoyproxy#38)

* Call gRPC WritesDone if Write fail. * no to call WritesDone()
rshriram · Mar 9, 2017 · 3011c03 · 3011c03
1 parent 0019653
commit 3011c03
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/mixerclient/src/grpc_transport.cc b/mixerclient/src/grpc_transport.cc
@@ -44,7 +44,7 @@ class GrpcStream final : public WriteInterface<RequestType> {
   void Write(const RequestType& request) override {
     std::lock_guard<std::mutex> lock(write_mutex_);
     if (!stream_->Write(request)) {
-      stream_->Finish();
+      write_closed_ = true;
     }
   }