mirror of
https://github.com/valitydev/thrift.git
synced 2024-11-07 10:48:51 +00:00
Same fix to thrift codebase
Reviewed By: aditya line, and those below, will be ignored-- M php/src/Thrift.php M php/src/transport/TSocket.php M php/src/transport/TPhpStream.php git-svn-id: https://svn.apache.org/repos/asf/incubator/thrift/trunk@665021 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
parent
49aea10d7a
commit
d395d57d3b
@ -29,6 +29,7 @@ class TType {
|
||||
class TMessageType {
|
||||
const CALL = 1;
|
||||
const REPLY = 2;
|
||||
const EXCEPTION = 3;
|
||||
}
|
||||
|
||||
class TException extends Exception {
|
||||
|
@ -66,7 +66,7 @@ class TPhpStream extends TTransport {
|
||||
}
|
||||
|
||||
public function write($buf) {
|
||||
while (!empty($buf)) {
|
||||
while (strlen($buf) > 0) {
|
||||
$got = @fwrite($this->outStream_, $buf);
|
||||
if ($got === 0 || $got === FALSE) {
|
||||
throw new Exception('TPhpStream: Could not write '.strlen($buf).' bytes');
|
||||
|
@ -242,7 +242,7 @@ class TSocket extends TTransport {
|
||||
stream_set_timeout($this->handle_, 0, $this->sendTimeout_*1000);
|
||||
$this->sendTimeoutSet_ = TRUE;
|
||||
}
|
||||
while (!empty($buf)) {
|
||||
while (strlen($buf) > 0) {
|
||||
$got = @fwrite($this->handle_, $buf);
|
||||
if ($got === 0 || $got === FALSE) {
|
||||
$md = stream_get_meta_data($this->handle_);
|
||||
|
Loading…
Reference in New Issue
Block a user