custom change to TSocket file to work with TLS
Project: http://git-wip-us.apache.org/repos/asf/airavata-php-gateway/repo Commit: http://git-wip-us.apache.org/repos/asf/airavata-php-gateway/commit/13840224 Tree: http://git-wip-us.apache.org/repos/asf/airavata-php-gateway/tree/13840224 Diff: http://git-wip-us.apache.org/repos/asf/airavata-php-gateway/diff/13840224 Branch: refs/heads/master Commit: 13840224964e018e2e69c8d3d588343629803ba5 Parents: cfdd539 Author: scnakandala <[email protected]> Authored: Wed Jun 1 12:46:39 2016 -0400 Committer: scnakandala <[email protected]> Committed: Wed Jun 1 12:46:39 2016 -0400 ---------------------------------------------------------------------- app/libraries/Thrift/Transport/TSocket.php | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/airavata-php-gateway/blob/13840224/app/libraries/Thrift/Transport/TSocket.php ---------------------------------------------------------------------- diff --git a/app/libraries/Thrift/Transport/TSocket.php b/app/libraries/Thrift/Transport/TSocket.php index 3ad3bf7..f23a05a 100644 --- a/app/libraries/Thrift/Transport/TSocket.php +++ b/app/libraries/Thrift/Transport/TSocket.php @@ -261,7 +261,7 @@ class TSocket extends TTransport { $readable = @stream_select($read, $null, $null, $this->recvTimeoutSec_, $this->recvTimeoutUsec_); if ($readable > 0) { - $data = @stream_socket_recvfrom($this->handle_, $len); + $data = @fread($this->handle_, $len); if ($data === false) { throw new TTransportException('TSocket: Could not read '.$len.' bytes from '. $this->host_.':'.$this->port_); @@ -294,7 +294,7 @@ class TSocket extends TTransport { $writable = @stream_select($null, $write, $null, $this->sendTimeoutSec_, $this->sendTimeoutUsec_); if ($writable > 0) { // write buffer to stream - $written = @stream_socket_sendto($this->handle_, $buf); + $written = @fwrite($this->handle_, $buf); if ($written === -1 || $written === false) { throw new TTransportException('TSocket: Could not write '.TStringFuncFactory::create()->strlen($buf).' bytes '. $this->host_.':'.$this->port_);
