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