tweet_live: comparison web/lib/Zend/Http/Client/Adapter/Socket.php

equal deleted inserted replaced

-:5e7a0fedabdf
+:877f952ae2bd
 * to license@zend.com so we can send you a copy immediately.
 *
 * @category   Zend
 * @package    Zend_Http
 * @subpackage Client_Adapter
-* @version    $Id: Socket.php 22576 2010-07-16 15:49:24Z dragonbe $
+* @version    $Id: Socket.php 24593 2012-01-05 20:35:02Z matthew $
-* @copyright  Copyright (c) 2005-2010 Zend Technologies USA Inc. (http://www.zend.com)
+* @copyright  Copyright (c) 2005-2012 Zend Technologies USA Inc. (http://www.zend.com)
 * @license    http://framework.zend.com/license/new-bsd     New BSD License
 */
 /**
 * @see Zend_Uri_Http
 * on almost every PHP environment, and does not require any special extensions.
 *
 * @category   Zend
 * @package    Zend_Http
 * @subpackage Client_Adapter
-* @copyright  Copyright (c) 2005-2010 Zend Technologies USA Inc. (http://www.zend.com)
+* @copyright  Copyright (c) 2005-2012 Zend Technologies USA Inc. (http://www.zend.com)
 * @license    http://framework.zend.com/license/new-bsd     New BSD License
 */
 class Zend_Http_Client_Adapter_Socket implements Zend_Http_Client_Adapter_Interface, Zend_Http_Client_Adapter_Stream
 {
 /**
 */
 protected $connected_to = array(null, null);
 /**
 * Stream for storing output
 *
 * @var resource
 */
 protected $out_stream = null;
 /**
 * Parameters array
 *
 * @var array
 */
 foreach ($config as $k => $v) {
 $this->config[strtolower($k)] = $v;
 }
 }
-	/**
+/**
-	 * Retrieve the array of all configuration options
+* Retrieve the array of all configuration options
-	 *
+*
-	 * @return array
+* @return array
-	 */
+*/
-	public function getConfig()
+public function getConfig()
-	{
+{
-	    return $this->config;
+return $this->config;
-	}
+}
-	/**
+/**
 * Set the stream context for the TCP connection to the server
 *
 * Can accept either a pre-existing stream context resource, or an array
 * of stream options, similar to the options array passed to the
 * stream_context_create() PHP function. In such case a new stream context
 $request .= "\r\n";
 } else {
 // Add the request body
 $request .= "\r\n" . $body;
 }
 // Send the request
 if (! @fwrite($this->socket, $request)) {
 require_once 'Zend/Http/Client/Adapter/Exception.php';
 throw new Zend_Http_Client_Adapter_Exception('Error writing request to server');
 }
 if(is_resource($body)) {
 if(stream_copy_to_stream($body, $this->socket) == 0) {
 require_once 'Zend/Http/Client/Adapter/Exception.php';
 throw new Zend_Http_Client_Adapter_Exception('Error writing request to server');
 }
 public function read()
 {
 // First, read headers only
 $response = '';
 $gotStatus = false;
-$stream = !empty($this->config['stream']);
 while (($line = @fgets($this->socket)) !== false) {
 $gotStatus = $gotStatus || (strpos($line, 'HTTP') !== false);
 if ($gotStatus) {
 $response .= $line;
 if (rtrim($line) === '') break;
 }
 }
 $this->_checkSocketReadTimeout();
 $statusCode = Zend_Http_Response::extractCode($response);
 // Handle 100 and 101 responses internally by restarting the read again
 return $response;
 }
 // If we got a 'transfer-encoding: chunked' header
 if (isset($headers['transfer-encoding'])) {
 if (strtolower($headers['transfer-encoding']) == 'chunked') {
 do {
 $line  = @fgets($this->socket);
 $this->_checkSocketReadTimeout();
 if ($current_pos >= $read_to) break;
 if($this->out_stream) {
 if(stream_copy_to_stream($this->socket, $this->out_stream, $read_to - $current_pos) == 0) {
 $this->_checkSocketReadTimeout();
 break;
 }
 } else {
 $line = @fread($this->socket, $read_to - $current_pos);
 if ($line === false || strlen($line) === 0) {
 $this->_checkSocketReadTimeout();
 $response .= $chunk;
 }
 } while ($chunksize > 0);
 } else {
 $this->close();
-		require_once 'Zend/Http/Client/Adapter/Exception.php';
+require_once 'Zend/Http/Client/Adapter/Exception.php';
 throw new Zend_Http_Client_Adapter_Exception('Cannot handle "' .
 $headers['transfer-encoding'] . '" transfer encoding');
 }
 // We automatically decode chunked-messages when writing to a stream
 // this means we have to disallow the Zend_Http_Response to do it again
 if ($this->out_stream) {
 $response = str_ireplace("Transfer-Encoding: chunked\r\n", '', $response);
 }
 } elseif (isset($headers['content-length'])) {
 // If we got more than one Content-Length header (see ZF-9404) use
 // the last value sent
 if (is_array($headers['content-length'])) {
 $contentLength = $headers['content-length'][count($headers['content-length']) - 1];
 } else {
 $contentLength = $headers['content-length'];
 }
 $current_pos = ftell($this->socket);
 $chunk = '';
 for ($read_to = $current_pos + $contentLength;
 $read_to > $current_pos;
 $current_pos = ftell($this->socket)) {
 if($this->out_stream) {
 if(@stream_copy_to_stream($this->socket, $this->out_stream, $read_to - $current_pos) == 0) {
 $this->_checkSocketReadTimeout();
 break;
 }
 } else {
 $chunk = @fread($this->socket, $read_to - $current_pos);
 if ($chunk === false || strlen($chunk) === 0) {
 $this->_checkSocketReadTimeout();
 do {
 if($this->out_stream) {
 if(@stream_copy_to_stream($this->socket, $this->out_stream) == 0) {
 $this->_checkSocketReadTimeout();
 break;
 }
 }  else {
 $buff = @fread($this->socket, 8192);
 if ($buff === false || strlen($buff) === 0) {
 $this->_checkSocketReadTimeout();
 Zend_Http_Client_Adapter_Exception::READ_TIMEOUT
 );
 }
 }
 }
 /**
 * Set output stream for the response
 *
 * @param resource $stream
 * @return Zend_Http_Client_Adapter_Socket
 */
 public function setOutputStream($stream)
 {
 $this->out_stream = $stream;
 return $this;
 }
 /**
 * Destructor: make sure the socket is disconnected
 *
 * If we are in persistent TCP mode, will not close the connection
 *

changeset 807	877f952ae2bd
parent 207	621fa6caec0c
child 1230	68c69c656a2c