@@ -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; |