@@ -33,7 +33,9 @@ discard block |
||
| 33 | 33 | $ms = microtime(); |
| 34 | 34 | do { |
| 35 | 35 | $this->curl->tick(); |
| 36 | - if ($this->concurrent >= $this->maxConcurrent) usleep(max(1, min(1000000, $this->usleep))); |
|
| 36 | + if ($this->concurrent >= $this->maxConcurrent) { |
|
| 37 | + usleep(max(1, min(1000000, $this->usleep))); |
|
| 38 | + } |
|
| 37 | 39 | } while ($this->concurrent >= $this->maxConcurrent); |
| 38 | 40 | return max(0, microtime() - $ms); |
| 39 | 41 | } |
@@ -60,7 +62,9 @@ discard block |
||
| 60 | 62 | $this->verifyCallable($fulfilled); |
| 61 | 63 | $this->verifyCallable($rejected); |
| 62 | 64 | |
| 63 | - while ($this->concurrent >= $this->maxConcurrent) $this->tick(); |
|
| 65 | + while ($this->concurrent >= $this->maxConcurrent) { |
|
| 66 | + $this->tick(); |
|
| 67 | + } |
|
| 64 | 68 | |
| 65 | 69 | $params['uri'] = $uri; |
| 66 | 70 | $params['fulfilled'] = $fulfilled; |
@@ -96,7 +100,9 @@ discard block |
||
| 96 | 100 | $redis = isset($setup['etag']) ? $setup['etag'] : null; |
| 97 | 101 | if ($redis !== null && $params['callType'] == 'GET') { |
| 98 | 102 | $etag = $redis->get("guzzler:etags:" . $params['uri']); |
| 99 | - if ($etag != "") $setup['If-None-Match'] = $etag; |
|
| 103 | + if ($etag != "") { |
|
| 104 | + $setup['If-None-Match'] = $etag; |
|
| 105 | + } |
|
| 100 | 106 | } |
| 101 | 107 | unset($setup['etag']); |
| 102 | 108 | return $redis; |