@@ -70,25 +70,25 @@ |
||
70 | 70 | */ |
71 | 71 | public function execute() { |
72 | 72 | $sleepTime = 1000;//microsecond, prevent CPU 100% |
73 | - do{ |
|
74 | - curl_multi_exec(self::$multiHandler, $active); |
|
75 | - // bug in PHP 5.3.18+ where curl_multi_select can return -1 |
|
73 | + do{ |
|
74 | + curl_multi_exec(self::$multiHandler, $active); |
|
75 | + // bug in PHP 5.3.18+ where curl_multi_select can return -1 |
|
76 | 76 | // https://bugs.php.net/bug.php?id=63411 |
77 | - if (curl_multi_select(self::$multiHandler) == -1) { |
|
78 | - usleep($sleepTime); |
|
79 | - } |
|
80 | - usleep($sleepTime); |
|
81 | - }while($active); |
|
82 | - $return = array(); |
|
77 | + if (curl_multi_select(self::$multiHandler) == -1) { |
|
78 | + usleep($sleepTime); |
|
79 | + } |
|
80 | + usleep($sleepTime); |
|
81 | + }while($active); |
|
82 | + $return = array(); |
|
83 | 83 | foreach (self::$requestPool as $request) { |
84 | 84 | $response = $request->makeResponse(true); |
85 | - $func = $response->request->endCallback(); |
|
85 | + $func = $response->request->endCallback(); |
|
86 | 86 | if (isset($func)) { |
87 | 87 | $func($response); |
88 | 88 | } |
89 | 89 | $return[] = $response; |
90 | - curl_multi_remove_handle(self::$multiHandler, $request->curlHandle); |
|
91 | - curl_close($request->curlHandle); |
|
90 | + curl_multi_remove_handle(self::$multiHandler, $request->curlHandle); |
|
91 | + curl_close($request->curlHandle); |
|
92 | 92 | } |
93 | 93 | curl_multi_close(self::$multiHandler); |
94 | 94 | self::$requestPool = null; |