From 8c1779d6712f102f2844621508e9f445540be7d2 Mon Sep 17 00:00:00 2001 From: Jens Geyer Date: Tue, 18 Feb 2014 21:55:43 +0100 Subject: [PATCH] THRIFT-2359 TBufferedTransport doesn't clear it's buffer on a failed flush call Patch: Chris Trotman --- lib/php/lib/Thrift/Transport/TBufferedTransport.php | 7 ++++++- 1 file changed, 6 insertions(+), 1 deletion(-) diff --git a/lib/php/lib/Thrift/Transport/TBufferedTransport.php b/lib/php/lib/Thrift/Transport/TBufferedTransport.php index 0d3ad98f..270c0046 100644 --- a/lib/php/lib/Thrift/Transport/TBufferedTransport.php +++ b/lib/php/lib/Thrift/Transport/TBufferedTransport.php @@ -156,8 +156,13 @@ class TBufferedTransport extends TTransport { public function flush() { if (TStringFuncFactory::create()->strlen($this->wBuf_) > 0) { - $this->transport_->write($this->wBuf_); + $out = $this->wBuf_; + + // Note that we clear the internal wBuf_ prior to the underlying write + // to ensure we're in a sane state (i.e. internal buffer cleaned) + // if the underlying write throws up an exception $this->wBuf_ = ''; + $this->transport_->write($out); } $this->transport_->flush(); } -- 2.17.1