@@ -29,7 +29,9 @@ discard block |
||
| 29 | 29 | $ms = microtime(); |
| 30 | 30 | do { |
| 31 | 31 | $this->curl->tick(); |
| 32 | - if ($this->concurrent >= $this->maxConcurrent) usleep(max(1, min(1000000, $this->usleep))); |
|
| 32 | + if ($this->concurrent >= $this->maxConcurrent) { |
|
| 33 | + usleep(max(1, min(1000000, $this->usleep))); |
|
| 34 | + } |
|
| 33 | 35 | } while ($this->concurrent >= $this->maxConcurrent); |
| 34 | 36 | return max(0, microtime() - $ms); |
| 35 | 37 | } |
@@ -56,7 +58,9 @@ discard block |
||
| 56 | 58 | $this->verifyCallable($fulfilled); |
| 57 | 59 | $this->verifyCallable($rejected); |
| 58 | 60 | |
| 59 | - while ($this->concurrent >= $this->maxConcurrent) $this->tick(); |
|
| 61 | + while ($this->concurrent >= $this->maxConcurrent) { |
|
| 62 | + $this->tick(); |
|
| 63 | + } |
|
| 60 | 64 | |
| 61 | 65 | $params['uri'] = $uri; |
| 62 | 66 | $params['fulfilled'] = $fulfilled; |
@@ -92,7 +96,9 @@ discard block |
||
| 92 | 96 | $redis = isset($setup['etag']) ? $setup['etag'] : null; |
| 93 | 97 | if ($redis !== null && $params['callType'] == 'GET') { |
| 94 | 98 | $etag = $redis->get("guzzler:etags:" . $params['uri']); |
| 95 | - if ($etag != "") $setup['If-None-Match'] = $etag; |
|
| 99 | + if ($etag != "") { |
|
| 100 | + $setup['If-None-Match'] = $etag; |
|
| 101 | + } |
|
| 96 | 102 | } |
| 97 | 103 | unset($setup['etag']); |
| 98 | 104 | return $redis; |