StreamServer::listen() - Code Metrics - hfw/socket - Measure and Improve Code Quality continuously with Scrutinizer

StreamServer::listen() A
last analyzed 2021-06-06 08:56 UTC

↳ Parent: StreamServer

Complexity

Conditions	2
Paths	2

Size

Total Lines

Duplication

Lines	0
Ratio	0 %

Importance

Changes

Metric	Value
dl	0
loc	6
rs	10
c	0
b	0
f	0
cc	2
nc	2
nop	1

<?php

namespace Helix\Socket;

/**
 * Server that accepts and wraps incoming connections as client instances.
 */
class StreamServer extends AbstractServer {

    /**
     * `SOCK_STREAM`
     *
     * @return int
     */
    final public static function getType (): int {
        return SOCK_STREAM;
    }

    /**
     * Accepts an incoming client connection.
     * This will block unless the server was selected for reading.
     *
     * @see https://php.net/socket_accept
     *
     * @return StreamClient
     * @throws SocketError
     */
    public function accept (): StreamClient {
        if (!$resource = @socket_accept($this->resource)) {
            throw new SocketError($this->resource); // reliable errno
        }
        return $this->newClient($resource);
    }

    /**
     * Enables incoming connections.
     *
     * Listening without binding first will cause the socket to bind to a random port on *all* network interfaces.
     *
     * @see https://php.net/socket_listen
     *
     * @see bind()
     *
     * @param int $backlog Connection queue size, or `0` to use the system's default.
     * @return $this
     * @throws SocketError
     */
    public function listen (int $backlog = 0) {
        if (!@socket_listen($this->resource, $backlog)) {
            throw new SocketError($this->resource); // reliable errno
        }
        return $this;
    }

    /**
     * Wraps an accepted connection.
     *
     * @param resource $resource The accepted connection.
     * @return StreamClient
     */
    protected function newClient ($resource): StreamClient {
        return new StreamClient($resource);
    }

}


1			<?php
2
3			namespace Helix\Socket;
4
5			/**
6			* Server that accepts and wraps incoming connections as client instances.
7			*/
8			class StreamServer extends AbstractServer {
9
10			/**
11			* `SOCK_STREAM`
12			*
13			* @return int
14			*/
15			final public static function getType (): int {
16			return SOCK_STREAM;
17			}
18
19			/**
20			* Accepts an incoming client connection.
21			* This will block unless the server was selected for reading.
22			*
23			* @see https://php.net/socket_accept
24			*
25			* @return StreamClient
26			* @throws SocketError
27			*/
28			public function accept (): StreamClient {
29			if (!$resource = @socket_accept($this->resource)) {
30			throw new SocketError($this->resource); // reliable errno
31			}
32			return $this->newClient($resource);
33			}
34
35			/**
36			* Enables incoming connections.
37			*
38			* Listening without binding first will cause the socket to bind to a random port on all network interfaces.
39			*
40			* @see https://php.net/socket_listen
41			*
42			* @see bind()
43			*
44			* @param int $backlog Connection queue size, or `0` to use the system's default.
45			* @return $this
46			* @throws SocketError
47			*/
48			public function listen (int $backlog = 0) {
49			if (!@socket_listen($this->resource, $backlog)) {
50			throw new SocketError($this->resource); // reliable errno
51			}
52			return $this;
53			}
54
55			/**
56			* Wraps an accepted connection.
57			*
58			* @param resource $resource The accepted connection.
59			* @return StreamClient
60			*/
61			protected function newClient ($resource): StreamClient {
62			return new StreamClient($resource);
63			}
64
65			}
66

hfw / socket

StreamServer::listen() A last analyzed 2021-06-06 08:56 UTC

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like

StreamServer::listen() A
last analyzed 2021-06-06 08:56 UTC