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