From fc9401f04a3aca5abb22f87ebc210de8afe11d32 Mon Sep 17 00:00:00 2001
From: marvin-borner@live.com
Date: Tue, 10 Apr 2018 21:50:16 +0200
Subject: Initial Commit

---
 assets/php/vendor/react/socket/src/UnixServer.php | 130 ++++++++++++++++++++++
 1 file changed, 130 insertions(+)
 create mode 100644 assets/php/vendor/react/socket/src/UnixServer.php

(limited to 'assets/php/vendor/react/socket/src/UnixServer.php')

diff --git a/assets/php/vendor/react/socket/src/UnixServer.php b/assets/php/vendor/react/socket/src/UnixServer.php
new file mode 100644
index 0000000..8f1ed98
--- /dev/null
+++ b/assets/php/vendor/react/socket/src/UnixServer.php
@@ -0,0 +1,130 @@
+<?php
+
+namespace React\Socket;
+
+use Evenement\EventEmitter;
+use React\EventLoop\LoopInterface;
+use InvalidArgumentException;
+use RuntimeException;
+
+/**
+ * The `UnixServer` class implements the `ServerInterface` and
+ * is responsible for accepting plaintext connections on unix domain sockets.
+ *
+ * ```php
+ * $server = new UnixServer('unix:///tmp/app.sock', $loop);
+ * ```
+ *
+ * See also the `ServerInterface` for more details.
+ *
+ * @see ServerInterface
+ * @see ConnectionInterface
+ */
+final class UnixServer extends EventEmitter implements ServerInterface
+{
+    private $master;
+    private $loop;
+    private $listening = false;
+
+    /**
+     * Creates a plaintext socket server and starts listening on the given unix socket
+     *
+     * This starts accepting new incoming connections on the given address.
+     * See also the `connection event` documented in the `ServerInterface`
+     * for more details.
+     *
+     * ```php
+     * $server = new UnixServer('unix:///tmp/app.sock', $loop);
+     * ```
+     *
+     * @param string        $path
+     * @param LoopInterface $loop
+     * @param array         $context
+     * @throws InvalidArgumentException if the listening address is invalid
+     * @throws RuntimeException if listening on this address fails (already in use etc.)
+     */
+    public function __construct($path, LoopInterface $loop, array $context = array())
+    {
+        $this->loop = $loop;
+
+        if (strpos($path, '://') === false) {
+            $path = 'unix://' . $path;
+        } elseif (substr($path, 0, 7) !== 'unix://') {
+            throw new InvalidArgumentException('Given URI "' . $path . '" is invalid');
+        }
+
+        $this->master = @stream_socket_server(
+            $path,
+            $errno,
+            $errstr,
+            STREAM_SERVER_BIND | STREAM_SERVER_LISTEN,
+            stream_context_create(array('socket' => $context))
+        );
+        if (false === $this->master) {
+            throw new RuntimeException('Failed to listen on unix domain socket "' . $path . '": ' . $errstr, $errno);
+        }
+        stream_set_blocking($this->master, 0);
+
+        $this->resume();
+    }
+
+    public function getAddress()
+    {
+        if (!is_resource($this->master)) {
+            return null;
+        }
+
+        return 'unix://' . stream_socket_get_name($this->master, false);
+    }
+
+    public function pause()
+    {
+        if (!$this->listening) {
+            return;
+        }
+
+        $this->loop->removeReadStream($this->master);
+        $this->listening = false;
+    }
+
+    public function resume()
+    {
+        if ($this->listening || !is_resource($this->master)) {
+            return;
+        }
+
+        $that = $this;
+        $this->loop->addReadStream($this->master, function ($master) use ($that) {
+            $newSocket = @stream_socket_accept($master);
+            if (false === $newSocket) {
+                $that->emit('error', array(new RuntimeException('Error accepting new connection')));
+
+                return;
+            }
+            $that->handleConnection($newSocket);
+        });
+        $this->listening = true;
+    }
+
+    public function close()
+    {
+        if (!is_resource($this->master)) {
+            return;
+        }
+
+        $this->pause();
+        fclose($this->master);
+        $this->removeAllListeners();
+    }
+
+    /** @internal */
+    public function handleConnection($socket)
+    {
+        $connection = new Connection($socket, $this->loop);
+        $connection->unix = true;
+
+        $this->emit('connection', array(
+            $connection
+        ));
+    }
+}
-- 
cgit v1.2.3