hfw / socket

src/AbstractSocket.php

Spacing +24 added lines, -24 removed lines

@@ -41,7 +41,7 @@ 
      * @return static
      * @throws SocketError
      */
-    public static function create ($domain = AF_INET, ...$extra) {
+    public static function create($domain = AF_INET, ...$extra) {
         if (!$resource = @socket_create($domain, static::getType(), 0)) { // auto-protocol
             throw new SocketError; // reliable errno
         }
@@ -58,12 +58,12 @@ 
      * @throws SocketError (`SOCKET_EBADFD`) There was a pending error on the socket.
      * The preexisting error code is set as the exception's extra data.
      */
-    public function __construct ($resource) {
+    public function __construct($resource) {
         if (!is_resource($resource) or get_resource_type($resource) !== 'Socket') {
             throw new InvalidArgumentException('Expected an open socket resource.', SOCKET_EBADF);
         }
         elseif (socket_get_option($resource, SOL_SOCKET, SO_TYPE) !== static::getType()) {
-            throw new InvalidArgumentException('The given socket resource is of the wrong type for ' . get_class(), SOCKET_ESOCKTNOSUPPORT);
+            throw new InvalidArgumentException('The given socket resource is of the wrong type for '.get_class(), SOCKET_ESOCKTNOSUPPORT);
         }
         elseif ($errno = SocketError::getLast($resource)) {
             $error = new SocketError(SOCKET_EBADFD);
@@ -78,7 +78,7 @@ 
     /**
      * Closes the socket if it's open.
      */
-    public function __destruct () {
+    public function __destruct() {
         if ($this->isOpen()) {
             $this->close();
         }
@@ -95,7 +95,7 @@ 
      * @return $this
      * @throws SocketError
      */
-    public function await ($channel) {
+    public function await($channel) {
         $rwe = [$channel => [$this->resource]];
         if (!@socket_select($rwe[0], $rwe[1], $rwe[2], null)) {
             throw new SocketError($this->resource);
@@ -108,7 +108,7 @@ 
      *
      * @return $this
      */
-    final public function awaitOutOfBand () {
+    final public function awaitOutOfBand() {
         return $this->await(self::CH_EXCEPT);
     }
 
@@ -117,7 +117,7 @@ 
      *
      * @return $this
      */
-    final public function awaitReadable () {
+    final public function awaitReadable() {
         return $this->await(self::CH_READ);
     }
 
@@ -126,7 +126,7 @@ 
      *
      * @return $this
      */
-    final public function awaitWritable () {
+    final public function awaitWritable() {
         return $this->await(self::CH_WRITE);
     }
 
@@ -137,7 +137,7 @@ 
      *
      * @return $this
      */
-    public function close () {
+    public function close() {
         socket_close($this->resource); // never errors
         return $this;
     }
@@ -145,14 +145,14 @@ 
     /**
      * @return int
      */
-    final public function getDomain (): int {
+    final public function getDomain(): int {
         return $this->domain;
     }
 
     /**
      * @return int
      */
-    final public function getId (): int {
+    final public function getId(): int {
         return (int)$this->resource;
     }
 
@@ -165,7 +165,7 @@ 
      * @throws SocketError
      * @return mixed The option's value. This is never `false`.
      */
-    public function getOption ($option) {
+    public function getOption($option) {
         $value = @socket_get_option($this->resource, SOL_SOCKET, $option);
         if ($value === false) {
             throw new SocketError($this->resource, SOCKET_EINVAL);
@@ -176,14 +176,14 @@ 
     /**
      * @return int
      */
-    final public function getProtocol (): int {
+    final public function getProtocol(): int {
         return $this->protocol;
     }
 
     /**
      * @return resource
      */
-    final public function getResource () {
+    final public function getResource() {
         return $this->resource;
     }
 
@@ -195,7 +195,7 @@ 
      * @throws SocketError
      * @return array String address/file and integer port at indices `0` and `1`.
      */
-    public function getSockName () {
+    public function getSockName() {
         if (!@socket_getsockname($this->resource, $addr, $port)) {
             throw new SocketError($this->resource, SOCKET_EOPNOTSUPP);
         }
@@ -207,7 +207,7 @@ 
      *
      * @return bool
      */
-    public function isOpen (): bool {
+    public function isOpen(): bool {
         return is_resource($this->resource);
     }
 
@@ -219,7 +219,7 @@ 
      * @return bool
      * @throws SocketError
      */
-    public function isOutOfBand () {
+    public function isOutOfBand() {
         return $this->isReady(self::CH_EXCEPT);
     }
 
@@ -231,7 +231,7 @@ 
      * @return bool
      * @throws SocketError
      */
-    final public function isReadable () {
+    final public function isReadable() {
         return $this->isReady(self::CH_READ);
     }
 
@@ -245,7 +245,7 @@ 
      * @return bool
      * @throws SocketError
      */
-    public function isReady ($channel, $timeout = 0.0): bool {
+    public function isReady($channel, $timeout = 0.0): bool {
         $rwe = [$channel => [$this->resource]];
         // core casts non-null timeout to int.
         // usec is ignored if timeout is null.
@@ -264,7 +264,7 @@ 
      * @return bool
      * @throws SocketError
      */
-    final public function isWritable () {
+    final public function isWritable() {
         return $this->isReady(self::CH_WRITE);
     }
 
@@ -286,7 +286,7 @@ 
      * @throws SocketError
      * @return $this
      */
-    public function setBlocking ($blocking) {
+    public function setBlocking($blocking) {
         if ($blocking) {
             $success = @socket_set_block($this->resource);
         }
@@ -309,7 +309,7 @@ 
      * @throws SocketError
      * @return $this
      */
-    public function setOption ($option, $value) {
+    public function setOption($option, $value) {
         if (!@socket_set_option($this->resource, SOL_SOCKET, $option, $value)) {
             throw new SocketError($this->resource, SOCKET_EINVAL);
         }
@@ -323,7 +323,7 @@ 
      * @return $this
      * @throws SocketError
      */
-    public function setTimeout ($timeout) {
+    public function setTimeout($timeout) {
         $tv = [
             'sec' => (int)$timeout,
             'usec' => (int)(fmod($timeout, 1) * 1000000)
@@ -356,7 +356,7 @@ 
      * @throws SocketError
      * @return $this
      */
-    public function shutdown (int $channels = self::CH_READ | self::CH_WRITE) {
+    public function shutdown(int $channels = self::CH_READ | self::CH_WRITE) {
         if (!@socket_shutdown($this->resource, $channels)) {
             throw new SocketError($this->resource); // reliable errno
         }

src/StreamClient.php

Spacing +5 added lines, -5 removed lines

@@ -12,7 +12,7 @@ 
      *
      * @return int
      */
-    final public static function getType (): int {
+    final public static function getType(): int {
         return SOCK_STREAM;
     }
 
@@ -26,7 +26,7 @@ 
      * @return static[] Two instances at indices `0` and `1`.
      * @throws SocketError
      */
-    public static function newUnixPair (...$extra) {
+    public static function newUnixPair(...$extra) {
         if (!@socket_create_pair(AF_UNIX, SOCK_STREAM, 0, $fd)) {
             throw new SocketError; // reliable errno
         }
@@ -45,7 +45,7 @@ 
      * @return string
      * @throws SocketError The error's extra data is set to what was partially read.
      */
-    public function read ($length) {
+    public function read($length) {
         try {
             $data = '';
             do {
@@ -70,7 +70,7 @@ 
      * @throws SocketError
      * @return string
      */
-    public function recv ($length, $msgFlags = 0): string {
+    public function recv($length, $msgFlags = 0): string {
         if (false === @socket_recv($this->resource, $data, $length, $msgFlags)) {
             throw new SocketError($this->resource, SOCKET_EINVAL);
         }
@@ -85,7 +85,7 @@ 
      * @param int $msgFlags
      * @return string
      */
-    public function recvAll (int $msgFlags = 0): string {
+    public function recvAll(int $msgFlags = 0): string {
         $msgFlags = ($msgFlags & ~MSG_WAITALL) | MSG_DONTWAIT;
         $length = $this->getOption(SO_RCVBUF);
         try {

src/Reactor.php

Spacing +6 added lines, -6 removed lines

@@ -28,7 +28,7 @@ 
      * @return int
      * @throws SocketError
      */
-    public static function select (array &$read, array &$write, array &$except, $timeout = null) {
+    public static function select(array &$read, array &$write, array &$except, $timeout = null) {
         $rwe = [$read, $write, $except];
         array_walk_recursive($rwe, function(SocketInterface &$each) {
             $each = $each->getResource();
@@ -51,7 +51,7 @@ 
      * @param ReactiveInterface $socket
      * @return $this
      */
-    public function add (ReactiveInterface $socket) {
+    public function add(ReactiveInterface $socket) {
         $this->sockets[$socket->getId()] = $socket;
         return $this;
     }
@@ -61,14 +61,14 @@ 
      *
      * @return int
      */
-    public function count () {
+    public function count() {
         return count($this->sockets);
     }
 
     /**
      * @return SocketInterface[]
      */
-    public function getSockets () {
+    public function getSockets() {
         return $this->sockets;
     }
 
@@ -82,7 +82,7 @@ 
      * @param float|null $timeout Maximum seconds to block. `NULL` blocks forever.
      * @return int Number of sockets selected.
      */
-    public function react ($timeout = null) {
+    public function react($timeout = null) {
         /** @var ReactiveInterface[][] $rwe */
         $rwe = [$this->sockets, [], $this->sockets];
         $count = static::select($rwe[0], $rwe[1], $rwe[2], $timeout);
@@ -110,7 +110,7 @@ 
      * @param int|ReactiveInterface $id
      * @return $this
      */
-    public function remove ($id) {
+    public function remove($id) {
         unset($this->sockets[$id instanceof ReactiveInterface ? $id->getId() : $id]);
         return $this;
     }

src/SocketError.php

Spacing +4 added lines, -4 removed lines

@@ -27,7 +27,7 @@ 
      * @param resource $resource PHP socket resource, or `null` for the global error.
      * @return int If the resource is closed or not a socket, `SOCKET_EBADF` is returned.
      */
-    public static function getLast ($resource = null) {
+    public static function getLast($resource = null) {
         if (isset($resource)) {
             if (@get_resource_type($resource) !== 'Socket') {
                 return SOCKET_EBADF;
@@ -53,7 +53,7 @@ 
      *     PHP's last suppressed warning is used for the message.
      *
      */
-    public function __construct ($subject = null, $fallback = 0) {
+    public function __construct($subject = null, $fallback = 0) {
         if (is_int($subject)) {
             $errno = $subject;
         }
@@ -73,7 +73,7 @@ 
     /**
      * @return mixed
      */
-    public function getExtra () {
+    public function getExtra() {
         return $this->extra;
     }
 
@@ -81,7 +81,7 @@ 
      * @param mixed $extra
      * @return $this
      */
-    public function setExtra ($extra) {
+    public function setExtra($extra) {
         $this->extra = $extra;
         return $this;
     }

src/DatagramClient.php

Spacing +1 added lines, -1 removed lines

@@ -12,7 +12,7 @@
      *
      * @return int
      */
-    final public static function getType (): int {
+    final public static function getType(): int {
         return SOCK_DGRAM;
     }
 

src/AbstractServer.php

Spacing +2 added lines, -2 removed lines

@@ -16,7 +16,7 @@ 
      *
      * @return string
      */
-    public function __toString () {
+    public function __toString() {
         try {
             return implode(':', $this->getSockName());
         }
@@ -38,7 +38,7 @@ 
      * @throws SocketError
      * @return $this
      */
-    public function bind (string $address, int $port = 0) {
+    public function bind(string $address, int $port = 0) {
         if (!@socket_bind($this->resource, $address, $port)) {
             throw new SocketError($this->resource, SOCKET_EOPNOTSUPP);
         }

src/SocketInterface.php

Spacing +6 added lines, -6 removed lines

@@ -42,41 +42,41 @@
      *
      * @return int `SOCK_*`
      */
-    public static function getType (): int;
+    public static function getType(): int;
 
     /**
      * Returns the address family constant of the socket.
      *
      * @return int `AF_*`
      */
-    public function getDomain (): int;
+    public function getDomain(): int;
 
     /**
      * Returns the underlying socket resource as an integer.
      *
      * @return int
      */
-    public function getId (): int;
+    public function getId(): int;
 
     /**
      * Returns the protocol constant used by the socket.
      *
      * @return int
      */
-    public function getProtocol (): int;
+    public function getProtocol(): int;
 
     /**
      * Returns the underlying socket resource.
      *
      * @return resource
      */
-    public function getResource ();
+    public function getResource();
 
     /**
      * Whether the underlying resource is usable.
      *
      * @return bool
      */
-    public function isOpen (): bool;
+    public function isOpen(): bool;
 
 }
\ No newline at end of file

src/DatagramServer.php

Spacing +2 added lines, -2 removed lines

@@ -12,7 +12,7 @@ 
      *
      * @return int
      */
-    final public static function getType (): int {
+    final public static function getType(): int {
         return SOCK_DGRAM;
     }
 
@@ -28,7 +28,7 @@ 
      * @throws SocketError
      * @return string
      */
-    public function recv ($length, $flags = 0, &$name = null, &$port = 0) {
+    public function recv($length, $flags = 0, &$name = null, &$port = 0) {
         $count = @socket_recvfrom($this->resource, $data, $length, $flags, $name, $port);
         if ($count === false) {
             throw new SocketError($this->resource, SOCKET_EOPNOTSUPP);

src/StreamServer.php

Spacing +4 added lines, -4 removed lines

@@ -12,7 +12,7 @@ 
      *
      * @return int
      */
-    final public static function getType (): int {
+    final public static function getType(): int {
         return SOCK_STREAM;
     }
 
@@ -25,7 +25,7 @@ 
      * @throws SocketError
      * @return StreamClient The accepted connection, as a client instance.
      */
-    public function accept () {
+    public function accept() {
         if (!$resource = @socket_accept($this->resource)) {
             throw new SocketError($this->resource); // reliable errno
         }
@@ -42,7 +42,7 @@ 
      * @throws SocketError
      * @return $this
      */
-    public function listen ($backlog = 0) {
+    public function listen($backlog = 0) {
         if (!@socket_listen($this->resource, $backlog)) {
             throw new SocketError($this->resource); // reliable errno
         }
@@ -56,7 +56,7 @@ 
      * @return StreamClient
      * @throws SocketError
      */
-    protected function newClient ($resource) {
+    protected function newClient($resource) {
         return new StreamClient($resource);
     }