@@ -14,7 +14,7 @@ discard block |
||
14 | 14 | set_time_limit(0); |
15 | 15 | |
16 | 16 | $socket_type = isset($_SERVER['RIO_SOCKET_TYPE']) ? $_SERVER['RIO_SOCKET_TYPE'] : 'AF_INET'; |
17 | -$socket_path = isset($_SERVER['RIO_SOCKET_PATH']) ? $_SERVER['RIO_SOCKET_PATH'] : sys_get_temp_dir().'/fake_agent.sock'; |
|
17 | +$socket_path = isset($_SERVER['RIO_SOCKET_PATH']) ? $_SERVER['RIO_SOCKET_PATH'] : sys_get_temp_dir() . '/fake_agent.sock'; |
|
18 | 18 | $ip = isset($_SERVER['RIO_HOST']) ? $_SERVER['RIO_HOST'] : 'localhost'; |
19 | 19 | $port = isset($_SERVER['RIO_PORT']) ? $_SERVER['RIO_PORT'] : 3100; |
20 | 20 | $timeout = 1000000; // seconds |
@@ -53,7 +53,7 @@ discard block |
||
53 | 53 | continue; |
54 | 54 | } |
55 | 55 | |
56 | - $readPart = function ($client) { |
|
56 | + $readPart = function($client) { |
|
57 | 57 | $buffer = ''; |
58 | 58 | while (true) { |
59 | 59 | if (stream_get_meta_data($client)['eof']) { |
@@ -131,7 +131,7 @@ discard block |
||
131 | 131 | } |
132 | 132 | } |
133 | 133 | |
134 | - $writed = fwrite($client, $res."\0", strlen($res) + 1); |
|
134 | + $writed = fwrite($client, $res . "\0", strlen($res) + 1); |
|
135 | 135 | |
136 | 136 | var_dump($writed); |
137 | 137 | } |
@@ -82,7 +82,7 @@ discard block |
||
82 | 82 | { |
83 | 83 | $connection = $this->getConnection(); |
84 | 84 | |
85 | - $toSend = $command->getName()."\0".$command->getRequest()."\0"; |
|
85 | + $toSend = $command->getName() . "\0" . $command->getRequest() . "\0"; |
|
86 | 86 | $sent = $this->box('doSend', false, [$connection, $toSend]); |
87 | 87 | |
88 | 88 | if (false === $sent) { |
@@ -219,7 +219,7 @@ discard block |
||
219 | 219 | |
220 | 220 | private function box($method, $defaultReturnValue = null, array $args = []) |
221 | 221 | { |
222 | - set_error_handler(__CLASS__.'::handleInternalError'); |
|
222 | + set_error_handler(__CLASS__ . '::handleInternalError'); |
|
223 | 223 | |
224 | 224 | try { |
225 | 225 | $returnValue = \call_user_func_array([$this, $method], $args); |