sinacms / MultiHttp

src/MultiRequest.php

Indentation +83 added lines, -83 removed lines

@@ -15,95 +15,95 @@
  */
 class MultiRequest
 {
-    protected static $requestPool = array();
-    protected static $multiHandler;
-    private static $instance;
+	protected static $requestPool = array();
+	protected static $multiHandler;
+	private static $instance;
 
-    protected function __construct()
-    {
-    }
+	protected function __construct()
+	{
+	}
 
-    public static function create()
-    {
-        if (!(self::$instance instanceof self)) {
-            self::$instance = new self;
-        }
-        self::prepare();
-        return self::$instance;
-    }
+	public static function create()
+	{
+		if (!(self::$instance instanceof self)) {
+			self::$instance = new self;
+		}
+		self::prepare();
+		return self::$instance;
+	}
 
-    protected static function prepare()
-    {
-        self::$multiHandler = curl_multi_init();
-    }
+	protected static function prepare()
+	{
+		self::$multiHandler = curl_multi_init();
+	}
 
-    public function add($method, $uri, $payload, array $options = array())
-    {
-        $options = array(
-                'method' => $method,
-                'url' => $uri,
-                'data' => $payload,
-            ) + $options;
-        $this->addOptions(array($options));
-        return $this;
-    }
+	public function add($method, $uri, $payload, array $options = array())
+	{
+		$options = array(
+				'method' => $method,
+				'url' => $uri,
+				'data' => $payload,
+			) + $options;
+		$this->addOptions(array($options));
+		return $this;
+	}
 
-    /**
-     * @param array $URLOptions
-     * example: array(array('url'=>'http://localhost:9999/','timeout'=>1, 'method'=>'POST', 'data'=>'aa=bb&c=d'))
-     * @return $this
-     */
-    public function addOptions(array $URLOptions)
-    {
-        foreach ($URLOptions as $options) {
-            $request = Request::create()->addOptions($options)->applyOptions();
-            if (isset($options['callback'])) {
-                $request->onEnd($options['callback']);
-            }
-            $this->import($request);
-        }
-        return $this;
-    }
+	/**
+	 * @param array $URLOptions
+	 * example: array(array('url'=>'http://localhost:9999/','timeout'=>1, 'method'=>'POST', 'data'=>'aa=bb&c=d'))
+	 * @return $this
+	 */
+	public function addOptions(array $URLOptions)
+	{
+		foreach ($URLOptions as $options) {
+			$request = Request::create()->addOptions($options)->applyOptions();
+			if (isset($options['callback'])) {
+				$request->onEnd($options['callback']);
+			}
+			$this->import($request);
+		}
+		return $this;
+	}
 
-    public function import(Request $request)
-    {
-        if (!is_resource($request->curlHandle)) {
-            throw new InvalidArgumentException('Request curl handle is not initialized');
-        }
-        curl_multi_add_handle(self::$multiHandler, $request->curlHandle);
-        self::$requestPool[] = $request;
-        return $this;
-    }
+	public function import(Request $request)
+	{
+		if (!is_resource($request->curlHandle)) {
+			throw new InvalidArgumentException('Request curl handle is not initialized');
+		}
+		curl_multi_add_handle(self::$multiHandler, $request->curlHandle);
+		self::$requestPool[] = $request;
+		return $this;
+	}
 
-    /**
-     * @return array(Response)
-     */
-    public function execute()
-    {
-        $sleepTime = 1000;//microsecond, prevent  CPU 100%
-        do {
-            curl_multi_exec(self::$multiHandler, $active);
-            // bug in PHP 5.3.18+ where curl_multi_select can return -1
-            // https://bugs.php.net/bug.php?id=63411
-            if (curl_multi_select(self::$multiHandler) == -1) {
-                usleep($sleepTime);
-            }
-            usleep($sleepTime);
-        } while ($active);
-        $return = array();
-        foreach (self::$requestPool as $request) {
-            $response = $request->makeResponse(true);
-            $func = $response->request->endCallback();
-            if (isset($func)) {
-                $func($response);
-            }
-            $return[] = $response;
-            curl_multi_remove_handle(self::$multiHandler, $request->curlHandle);
-            curl_close($request->curlHandle);
-        }
-        curl_multi_close(self::$multiHandler);
-        self::$requestPool = array();
-        return $return;
-    }
+	/**
+	 * @return array(Response)
+	 */
+	public function execute()
+	{
+		$sleepTime = 1000;//microsecond, prevent  CPU 100%
+		do {
+			curl_multi_exec(self::$multiHandler, $active);
+			// bug in PHP 5.3.18+ where curl_multi_select can return -1
+			// https://bugs.php.net/bug.php?id=63411
+			if (curl_multi_select(self::$multiHandler) == -1) {
+				usleep($sleepTime);
+			}
+			usleep($sleepTime);
+		} while ($active);
+		$return = array();
+		foreach (self::$requestPool as $request) {
+			$response = $request->makeResponse(true);
+			$func = $response->request->endCallback();
+			if (isset($func)) {
+				$func($response);
+			}
+			$return[] = $response;
+			curl_multi_remove_handle(self::$multiHandler, $request->curlHandle);
+			curl_close($request->curlHandle);
+		}
+		curl_multi_close(self::$multiHandler);
+		self::$requestPool = array();
+		return $return;
+	}
 
 }