@@ -62,7 +62,7 @@ discard block |
||
62 | 62 | { |
63 | 63 | $this->curl = $curl; |
64 | 64 | $this->kvPrefix = $kvPrefix; |
65 | - $this->sessionTTL = (int)$sessionTTL; |
|
65 | + $this->sessionTTL = (int) $sessionTTL; |
|
66 | 66 | //If we cannot connect to Consul on start, we have a problem. |
67 | 67 | $this->createSession(); |
68 | 68 | $this->lastSuccessfullCheck = time(); |
@@ -99,7 +99,7 @@ discard block |
||
99 | 99 | public function heartbeat() |
100 | 100 | { |
101 | 101 | //If we have last successfull check recently new, we don't have to do anything |
102 | - if ($this->lastSuccessfullCheck !== null && time() - $this->lastSuccessfullCheck < $this->sessionTTL / 2 ) { |
|
102 | + if ($this->lastSuccessfullCheck !== null && time()-$this->lastSuccessfullCheck < $this->sessionTTL / 2) { |
|
103 | 103 | return false; |
104 | 104 | } |
105 | 105 | //If session reneval succeedes, update last successfull check. |
@@ -116,7 +116,7 @@ discard block |
||
116 | 116 | } catch (RuntimeException $e) { |
117 | 117 | //We could not create new session. We can work for some time in 'detached' mode, |
118 | 118 | //but if our TTL time runs out, we have to throw an exception. |
119 | - if ($this->lastSuccessfullCheck === null || time() - $this->lastSuccessfullCheck >= $this->sessionTTL) { |
|
119 | + if ($this->lastSuccessfullCheck === null || time()-$this->lastSuccessfullCheck >= $this->sessionTTL) { |
|
120 | 120 | throw $e; |
121 | 121 | } |
122 | 122 | return false; |
@@ -134,7 +134,7 @@ discard block |
||
134 | 134 | //Check, if we don't have existing value for the session |
135 | 135 | $currentValue = $this->curl->performGetRequest('/kv/'.$this->kvPrefix.$this->sessionId); |
136 | 136 | if (!empty($currentValue['Value'])) { |
137 | - return (int)base64_decode($currentValue['Value']); |
|
137 | + return (int) base64_decode($currentValue['Value']); |
|
138 | 138 | } |
139 | 139 | //Lock main key to block concurrent checks |
140 | 140 | $this->lockKey(); |
@@ -149,7 +149,7 @@ discard block |
||
149 | 149 | } |
150 | 150 | //Release the lock on the main key and return machine ID. |
151 | 151 | $this->releaseKey(); |
152 | - return (int)$machineId; |
|
152 | + return (int) $machineId; |
|
153 | 153 | } |
154 | 154 | |
155 | 155 | /** |
@@ -198,12 +198,12 @@ discard block |
||
198 | 198 | |
199 | 199 | private function createSession() |
200 | 200 | { |
201 | - $url ='/session/create'; |
|
201 | + $url = '/session/create'; |
|
202 | 202 | //We create new session with given TTL and with lock delay equal to half of TTL. |
203 | 203 | $payload = array( |
204 | 204 | 'TTL' => $this->sessionTTL.'s', |
205 | 205 | "Behavior" => "delete", |
206 | - 'LockDelay' => floor($this->sessionTTL/2).'s', |
|
206 | + 'LockDelay' => floor($this->sessionTTL / 2).'s', |
|
207 | 207 | ); |
208 | 208 | $returnData = $this->curl->performPutRequest($url, json_encode($payload)); |
209 | 209 | if (empty($returnData['ID'])) { |