commit f48588f124fb8636f94bf23d098d4483f077e2de
author Jens Geyer <jensg@apache.org> Tue Jul 07 22:23:49 2015 +0200
committer Jens Geyer <jensg@apache.org> Tue Jul 07 22:23:49 2015 +0200
tree 94412127740935921c9480d446ab4367e12a1fa8
parent 7207c22f9d50ee28ea8c0842404541524bde8bcd

THRIFT-3225 Fix TPipeServer unpredictable behavior on close
Client: C++
Patch: Paweł Janicki

lib/cpp/src/thrift/transport/TPipeServer.cpp

diff --git a/lib/cpp/src/thrift/transport/TPipeServer.cpp b/lib/cpp/src/thrift/transport/TPipeServer.cpp
index 3779d7f..44295f1 100644
--- a/lib/cpp/src/thrift/transport/TPipeServer.cpp
+++ b/lib/cpp/src/thrift/transport/TPipeServer.cpp
@@ -119,7 +119,10 @@
     }
   }
 
-  virtual void close() { Pipe_.reset(); }
+  virtual void close() { 
+    TAutoCrit lock(pipe_protect_);
+    Pipe_.reset(); 
+  }
 
   virtual boost::shared_ptr<TTransport> acceptImpl();