| @@ -82,13 +82,13 @@ | ||
| 82 | 82 | 'zipkin' => [ZipkinHAV2::class, ZipkinJFV2::class], | 
| 83 | 83 | 'udp' => [UDPRelays::class, ZipkinJFV2::class], | 
| 84 | 84 | ], | 
| 85 | -            function (Transport $transport = null, Protocol $protocol = null) { | |
| 85 | +            function(Transport $transport = null, Protocol $protocol = null) { | |
| 86 | 86 | $this->transport && $this->transport->disconnect(); | 
| 87 | 87 | $this->transport = $transport; | 
| 88 | 88 | $this->protocol = $protocol; | 
| 89 | 89 | $this->changed($transport); | 
| 90 | 90 | }, | 
| 91 | -            static function (Throwable $e) { | |
| 91 | +            static function(Throwable $e) { | |
| 92 | 92 |                  logger('traced')->warning('Transport initialize failed', [ | 
| 93 | 93 | 'p' => 'zipkin', | 
| 94 | 94 | 'ec' => get_class($e), | 
| @@ -58,7 +58,7 @@ discard block | ||
| 58 | 58 | PHP_SAPI === 'cli' ? SWOOLE_SOCK_ASYNC : SWOOLE_SOCK_SYNC | 
| 59 | 59 | ); | 
| 60 | 60 | $this->client->connect($this->endpoint->host(), $this->endpoint->port()); | 
| 61 | -        $this->sender = function (string $data) { | |
| 61 | +        $this->sender = function(string $data) { | |
| 62 | 62 | @$this->client->send($data); | 
| 63 | 63 | }; | 
| 64 | 64 | } | 
| @@ -72,7 +72,7 @@ discard block | ||
| 72 | 72 | SOCK_DGRAM, | 
| 73 | 73 | $this->uxdomain ? IPPROTO_IP : SOL_UDP | 
| 74 | 74 | ); | 
| 75 | -        $this->sender = function (string $data) { | |
| 75 | +        $this->sender = function(string $data) { | |
| 76 | 76 | @socket_sendto( | 
| 77 | 77 | $this->socket, | 
| 78 | 78 | $data, | 
| @@ -142,10 +142,10 @@ discard block | ||
| 142 | 142 | private function packing(string $payload) : string | 
| 143 | 143 |      { | 
| 144 | 144 | return | 
| 145 | - self::MAGIC . | |
| 146 | -            pack('N', strlen($this->identify)) . | |
| 147 | - $this->identify . | |
| 148 | -            pack('N', strlen($payload)) . | |
| 145 | + self::MAGIC. | |
| 146 | +            pack('N', strlen($this->identify)). | |
| 147 | + $this->identify. | |
| 148 | +            pack('N', strlen($payload)). | |
| 149 | 149 | $payload | 
| 150 | 150 | ; | 
| 151 | 151 | } | 
| @@ -32,7 +32,7 @@ | ||
| 32 | 32 | Closure $setter, | 
| 33 | 33 | Closure $failure = null | 
| 34 | 34 |      ) : void { | 
| 35 | -        $source->watching($conf, static function (string $dsn) use ($schemes, $setter, $failure) { | |
| 35 | +        $source->watching($conf, static function(string $dsn) use ($schemes, $setter, $failure) { | |
| 36 | 36 | // parsing dsn | 
| 37 | 37 | $parsed = parse_url($dsn) ?: []; | 
| 38 | 38 | |