hfw / socket

src/Error.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/ReactiveInterface.php

Spacing +2 added lines, -2 removed lines

@@ -14,13 +14,13 @@
      *
      * @return void
      */
-    public function onExceptional ();
+    public function onExceptional();
 
     /**
      * Called by the reactor when the socket has readable data.
      *
      * @return void
      */
-    public function onReadable ();
+    public function onReadable();
 
 }
\ No newline at end of file

src/SocketInterface.php

Spacing +5 added lines, -5 removed lines

@@ -42,34 +42,34 @@
      *
      * @return int `AF_*`
      */
-    public function getDomain ();
+    public function getDomain();
 
     /**
      * Returns the underlying socket resource as an integer.
      *
      * @return int
      */
-    public function getId ();
+    public function getId();
 
     /**
      * Returns the protocol constant used by the socket.
      *
      * @return int
      */
-    public function getProtocol ();
+    public function getProtocol();
 
     /**
      * Returns the underlying socket resource.
      *
      * @return resource
      */
-    public function getResource ();
+    public function getResource();
 
     /**
      * Returns the socket type constant for the class.
      *
      * @return int `SOCK_*`
      */
-    public static function getType ();
+    public static function getType();
 
 }
\ No newline at end of file

src/AbstractServer.php

Braces +1 added lines, -2 removed lines

@@ -17,8 +17,7 @@
     public function __toString () {
         try {
             return implode(':', $this->getSockName());
-        }
-        catch (\Exception $exception) {
+        } catch (\Exception $exception) {
             return ':';
         }
     }

src/AbstractClient.php

Spacing +5 added lines, -5 removed lines

@@ -14,7 +14,7 @@ 
      *
      * @return string
      */
-    public function __toString () {
+    public function __toString() {
         try {
             return implode(':', $this->getPeerName());
         }
@@ -38,7 +38,7 @@ 
      * @throws Error
      * @return $this
      */
-    public function connect ($address, $port = 0) {
+    public function connect($address, $port = 0) {
         if (!@socket_connect($this->resource, $address, $port)) {
             // ignore expected errors for non-blocking connections
             $errno = Error::getLast($this->resource);
@@ -58,7 +58,7 @@ 
      * @throws Error
      * @return array Address and port at indices `0` and `1`.
      */
-    public function getPeerName () {
+    public function getPeerName() {
         if ($this->domain === AF_UNIX) {
             return [$this->getOption(self::SO_PEERCRED), 0];
         }
@@ -80,7 +80,7 @@ 
      * @throws Error
      * @return int Total bytes sent.
      */
-    public function send ($data, $flags = 0) {
+    public function send($data, $flags = 0) {
         $count = @socket_send($this->resource, $data, PHP_INT_MAX, $flags);
         if ($count === false) {
             $error = new Error($this->resource); // reliable errno
@@ -99,7 +99,7 @@ 
      * @throws Error Total bytes sent is set as the error's extra data.
      * @return $this
      */
-    public function write ($data) {
+    public function write($data) {
         $data = (string)$data;
         $length = strlen($data);
         $total = 0;

src/AbstractSocket.php

Spacing +25 added lines, -25 removed lines

@@ -41,7 +41,7 @@ 
      * @return static
      * @throws Error
      */
-    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 Error; // reliable errno
         }
@@ -60,7 +60,7 @@ 
      * @return int
      * @throws Error
      */
-    public static function select (array &$read, array &$write, array &$except, $timeout = null) {
+    public static function select(array &$read, array &$write, array &$except, $timeout = null) {
         $getResource = function(SocketInterface $socket) {
             return $socket->getResource();
         };
@@ -90,12 +90,12 @@ 
      * @throws Error (`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 = Error::getLast($resource)) {
             $error = new Error(SOCKET_EBADFD);
@@ -110,7 +110,7 @@ 
     /**
      * Closes the socket if it's open.
      */
-    public function __destruct () {
+    public function __destruct() {
         $this->close();
     }
 
@@ -125,7 +125,7 @@ 
      * @return $this
      * @throws Error
      */
-    public function await ($channel) {
+    public function await($channel) {
         $select = [$channel => [$this->resource]];
         $count = @socket_select($select[self::CH_READ], $select[self::CH_WRITE], $select[self::CH_EXCEPT], null);
         if (!$count) {
@@ -144,7 +144,7 @@ 
      *
      * @return $this
      */
-    public function close () {
+    public function close() {
         // socket_close() never errors, but we guard anyway to prevent
         // a redundant call to onClose(), and an incorrect call to it if
         // the constructor failed and the destructor is calling this.
@@ -158,14 +158,14 @@ 
     /**
      * @return int
      */
-    final public function getDomain () {
+    final public function getDomain() {
         return $this->domain;
     }
 
     /**
      * @return int
      */
-    final public function getId () {
+    final public function getId() {
         return (int)$this->resource;
     }
 
@@ -178,7 +178,7 @@ 
      * @throws Error
      * @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 Error($this->resource, SOCKET_EINVAL);
@@ -189,14 +189,14 @@ 
     /**
      * @return int
      */
-    final public function getProtocol () {
+    final public function getProtocol() {
         return $this->protocol;
     }
 
     /**
      * @return resource
      */
-    final public function getResource () {
+    final public function getResource() {
         return $this->resource;
     }
 
@@ -208,7 +208,7 @@ 
      * @throws Error
      * @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 Error($this->resource, SOCKET_EOPNOTSUPP);
         }
@@ -223,7 +223,7 @@ 
      * @return bool
      * @throws Error
      */
-    public function isExceptional () {
+    public function isExceptional() {
         return $this->isReady(self::CH_EXCEPT);
     }
 
@@ -232,7 +232,7 @@ 
      *
      * @return bool
      */
-    public function isOpen () {
+    public function isOpen() {
         return is_resource($this->resource);
     }
 
@@ -244,7 +244,7 @@ 
      * @return bool
      * @throws Error
      */
-    public function isReadable () {
+    public function isReadable() {
         return $this->isReady(self::CH_READ);
     }
 
@@ -258,7 +258,7 @@ 
      * @throws Error
      * @return bool
      */
-    public function isReady ($channel, $timeout = 0.0) {
+    public function isReady($channel, $timeout = 0.0) {
         $usec = (int)(fmod($timeout, 1) * 1000000); // ignored if timeout is null
         $select = [$channel => [$this->resource]];
         $count = $count = @socket_select($select[self::CH_READ], $select[self::CH_WRITE], $select[self::CH_EXCEPT], $timeout, $usec);
@@ -276,7 +276,7 @@ 
      * @return bool
      * @throws Error
      */
-    public function isWritable () {
+    public function isWritable() {
         return $this->isReady(self::CH_WRITE, 0);
     }
 
@@ -285,7 +285,7 @@ 
      *
      * @return void
      */
-    protected function onClose () { }
+    protected function onClose() { }
 
     /**
      * Stub. Called before an I/O channel is shut down.
@@ -293,14 +293,14 @@ 
      * @param int $channel `SocketInterface` channel constant.
      * @return void
      */
-    protected function onShutdown ($channel) { }
+    protected function onShutdown($channel) { }
 
     /**
      * Stub. Called when an I/O timeout has occurred, before it's thrown.
      *
      * @return void
      */
-    protected function onTimeout () { }
+    protected function onTimeout() { }
 
     /**
      * Enables or disables blocking.
@@ -320,7 +320,7 @@ 
      * @throws Error
      * @return $this
      */
-    public function setBlocking ($blocking) {
+    public function setBlocking($blocking) {
         if ($blocking) {
             $success = @socket_set_block($this->resource);
         }
@@ -343,7 +343,7 @@ 
      * @throws Error
      * @return $this
      */
-    public function setOption ($option, $value) {
+    public function setOption($option, $value) {
         if (!@socket_set_option($this->resource, SOL_SOCKET, $option, $value)) {
             throw new Error($this->resource, SOCKET_EINVAL);
         }
@@ -357,7 +357,7 @@ 
      * @throws Error
      * @return $this
      */
-    public function setTimeout ($timeout) {
+    public function setTimeout($timeout) {
         $timeval = ['sec' => (int)$timeout, 'usec' => (int)(fmod($timeout, 1) * 1000000)];
         $this->setOption(SO_RCVTIMEO, $timeval);
         $this->setOption(SO_SNDTIMEO, $timeval);
@@ -384,7 +384,7 @@ 
      * @throws Error
      * @return $this
      */
-    public function shutdown ($channel) {
+    public function shutdown($channel) {
         $this->onShutdown($channel);
         if (!@socket_shutdown($this->resource, $channel)) {
             throw new Error($this->resource); // reliable errno

src/DatagramServer.php

Spacing +2 added lines, -2 removed lines

@@ -12,7 +12,7 @@ 
      *
      * @return int
      */
-    final public static function getType () {
+    final public static function getType() {
         return SOCK_DGRAM;
     }
 
@@ -30,7 +30,7 @@ 
      * @throws Error
      * @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) {
             $error = new Error($this->resource, SOCKET_EOPNOTSUPP);

src/StreamServer.php

Spacing +5 added lines, -5 removed lines

@@ -12,7 +12,7 @@ 
      *
      * @return int
      */
-    final public static function getType () {
+    final public static function getType() {
         return SOCK_STREAM;
     }
 
@@ -27,7 +27,7 @@ 
      * @throws Error
      * @return StreamClient The accepted connection, as a client instance.
      */
-    public function accept () {
+    public function accept() {
         if (!$resource = @socket_accept($this->resource)) {
             throw new Error($this->resource); // reliable errno
         }
@@ -43,7 +43,7 @@ 
      * @return StreamClient
      * @throws Error
      */
-    protected function createClient ($resource) {
+    protected function createClient($resource) {
         return new StreamClient($resource);
     }
 
@@ -57,7 +57,7 @@ 
      * @throws Error
      * @return $this
      */
-    public function listen ($backlog = 0) {
+    public function listen($backlog = 0) {
         if (!@socket_listen($this->resource, $backlog)) {
             throw new Error($this->resource); // reliable errno
         }
@@ -70,6 +70,6 @@ 
      * @param StreamClient $client
      * @return void
      */
-    protected function onAccept (StreamClient $client) { }
+    protected function onAccept(StreamClient $client) { }
 
 }

src/StreamClient.php

Spacing +4 added lines, -4 removed lines

@@ -17,7 +17,7 @@ 
      * @return static[] Two instances at indices `0` and `1`.
      * @throws Error
      */
-    public static function createUnixPair (...$extra) {
+    public static function createUnixPair(...$extra) {
         if (!@socket_create_pair(AF_UNIX, SOCK_STREAM, 0, $fd)) {
             throw new Error; // reliable errno
         }
@@ -32,7 +32,7 @@ 
      *
      * @return int
      */
-    final public static function getType () {
+    final public static function getType() {
         return SOCK_STREAM;
     }
 
@@ -46,7 +46,7 @@ 
      * @return string
      * @throws Error The error's extra data is set to what was partially read.
      */
-    public function read ($length) {
+    public function read($length) {
         $data = '';
         while ($length > 0) {
             try {
@@ -76,7 +76,7 @@ 
      * @throws Error
      * @return string
      */
-    public function recv ($length, $flags = 0) {
+    public function recv($length, $flags = 0) {
         $count = @socket_recv($this->resource, $data, $length, $flags);
         if ($count === false) {
             $error = new Error($this->resource, SOCKET_EINVAL);