@@ -84,7 +84,7 @@ discard block |
||
| 84 | 84 | |
| 85 | 85 | usleep($sleepTime); |
| 86 | 86 | } |
| 87 | - /* |
|
| 87 | + /* |
|
| 88 | 88 | do{ |
| 89 | 89 | curl_multi_exec(self::$multiHandler, $active); |
| 90 | 90 | if (curl_multi_select(self::$multiHandler) === -1) { |
@@ -94,16 +94,16 @@ discard block |
||
| 94 | 94 | }while($active); |
| 95 | 95 | */ |
| 96 | 96 | |
| 97 | - $return = array(); |
|
| 97 | + $return = array(); |
|
| 98 | 98 | foreach (self::$requestPool as $request) { |
| 99 | 99 | $response = $request->makeResponse(true); |
| 100 | - $func = $response->request->endCallback(); |
|
| 100 | + $func = $response->request->endCallback(); |
|
| 101 | 101 | if (isset($func)) { |
| 102 | 102 | $func($response); |
| 103 | 103 | } |
| 104 | 104 | $return[] = $response; |
| 105 | - curl_multi_remove_handle(self::$multiHandler, $request->curlHandle); |
|
| 106 | - curl_close($request->curlHandle); |
|
| 105 | + curl_multi_remove_handle(self::$multiHandler, $request->curlHandle); |
|
| 106 | + curl_close($request->curlHandle); |
|
| 107 | 107 | } |
| 108 | 108 | curl_multi_close(self::$multiHandler); |
| 109 | 109 | return $return; |
@@ -69,7 +69,7 @@ |
||
| 69 | 69 | * @return array(Response) |
| 70 | 70 | */ |
| 71 | 71 | public function execute() { |
| 72 | - $sleepTime = 1000;//microsecond, prevent CPU 100% |
|
| 72 | + $sleepTime = 1000; //microsecond, prevent CPU 100% |
|
| 73 | 73 | |
| 74 | 74 | while (($multiFlg = curl_multi_exec(self::$multiHandler, $active)) == CURLM_CALL_MULTI_PERFORM); |
| 75 | 75 | |