@@ -237,7 +237,7 @@ discard block |
||
237 | 237 | */ |
238 | 238 | public function setWriteFunction($callback) |
239 | 239 | { |
240 | - $this->options[CURLOPT_WRITEFUNCTION]=$callback; |
|
240 | + $this->options[CURLOPT_WRITEFUNCTION] = $callback; |
|
241 | 241 | } |
242 | 242 | /** |
243 | 243 | * @param callable $callback |
@@ -612,7 +612,7 @@ discard block |
||
612 | 612 | */ |
613 | 613 | public function response() |
614 | 614 | { |
615 | - if (! $this->response) { |
|
615 | + if (!$this->response) { |
|
616 | 616 | throw new \ClickHouseDB\Exception\TransportException('Can`t fetch response - is empty'); |
617 | 617 | } |
618 | 618 | |
@@ -708,7 +708,7 @@ discard block |
||
708 | 708 | |
709 | 709 | if (!empty($curl_opt[CURLOPT_WRITEFUNCTION])) |
710 | 710 | { |
711 | - $curl_opt[CURLOPT_HEADER]=false; |
|
711 | + $curl_opt[CURLOPT_HEADER] = false; |
|
712 | 712 | } |
713 | 713 | |
714 | 714 | if ($this->resultFileHandle) { |
@@ -144,22 +144,22 @@ |
||
144 | 144 | public function execLoopWait() |
145 | 145 | { |
146 | 146 | $c = 0; |
147 | - $timeStart=time(); |
|
148 | - $uSleep=1000; // Timer: check response from server, and add new Task/Que to loop |
|
149 | - $PendingAllConnections=$this->countPending(); |
|
147 | + $timeStart = time(); |
|
148 | + $uSleep = 1000; // Timer: check response from server, and add new Task/Que to loop |
|
149 | + $PendingAllConnections = $this->countPending(); |
|
150 | 150 | |
151 | 151 | // Max loop check |
152 | 152 | |
153 | - $count=0; |
|
153 | + $count = 0; |
|
154 | 154 | // add all tasks |
155 | 155 | do { |
156 | 156 | $this->exec(); |
157 | - $timeWork=time()-$timeStart; |
|
157 | + $timeWork = time() - $timeStart; |
|
158 | 158 | // |
159 | 159 | $ActiveNowConnections = $this->countActive(); |
160 | 160 | $PendingNowConnections = $this->countPending(); |
161 | 161 | |
162 | - $count=$ActiveNowConnections+$PendingNowConnections; |
|
162 | + $count = $ActiveNowConnections + $PendingNowConnections; |
|
163 | 163 | $c++; |
164 | 164 | |
165 | 165 | if ($c > 20000) { |