Merge pull request #13 from thekid/libevent-server

Libevent server

Author: thekid

src/main/php/peer/server/EventServer.class.php

@@ -0,0 +1,48 @@
+<?php namespace peer\server;
+
+/**
+ * Basic TCP/IP Server using libevent
+ *
+ * @ext   event
+ * @see   http://pecl.php.net/package/event
+ */
+class EventServer extends Server {
+  
+  /**
+   * Service
+   */
+  public function service() {
+    if (!$this->socket->isConnected()) return false;
+
+    $base= new \EventBase();
+    $listener= new \EventListener(
+      $base,
+      function($listener, $fd, $address, $base) {
+        $event= new \EventBufferEvent($base, $fd, \EventBufferEvent::OPT_CLOSE_ON_FREE);
+        $event->setCallbacks(
+          function($event) {
+            $this->protocol->handleData(new EventSocket($event));
+          },
+          function($event) {
+            if (0 === $event->output->length) {
+              $event->free();
+            }
+          },
+          function($event, $events) {
+            if ($events & (\EventBufferEvent::EOF | \EventBufferEvent::ERROR)) {
+              $event->free();
+            }
+          },
+          null
+        );
+        $event->enable(\Event::READ);
+      },
+      $base,
+      \EventListener::OPT_CLOSE_ON_FREE | \EventListener::OPT_REUSEABLE,
+      -1,
+      $this->socket->getHandle()
+    );
+
+    $base->dispatch();
+  }
+}

src/main/php/peer/server/EventSocket.class.php

@@ -0,0 +1,85 @@
+<?php namespace peer\server;
+
+use peer\Socket;
+
+/**
+ * Wrapper socket aroud EventBufferEvent
+ *
+ * @ext   event
+ * @see   http://pecl.php.net/package/event
+ */
+class EventSocket extends \peer\Socket {
+  protected $event= null;
+
+  /**
+   * Constructor
+   *
+   * @param  php.EventBufferEvent event
+   */
+  public function __construct(\EventBufferEvent $event) {
+    $this->event= $event;
+  }
+
+  /**
+   * Checks if EOF was reached
+   *
+   * @return  bool
+   */
+  public function eof() {
+    return 0 === $this->event->input->length;
+  }
+
+  /**
+   * Read data from a socket (binary-safe)
+   *
+   * @param   int maxLen maximum bytes to read
+   * @return  string data
+   * @throws  peer.SocketException
+   */
+  public function readBinary($maxLen= 4096) {
+    return $this->event->input->read($maxLen);
+  }
+
+  /**
+   * Read line from a socket
+   *
+   * @param   int maxLen maximum bytes to read
+   * @return  string data
+   * @throws  peer.SocketException
+   */
+  public function readLine($maxLen= 4096) {
+    return $this->event->input->readLine(\EventBuffer::EOL_ANY);
+  }
+
+  /**
+   * Read data from a socket
+   *
+   * @param   int maxLen maximum bytes to read
+   * @return  string data
+   * @throws  peer.SocketException
+   */
+  public function read($maxLen= 4096) {
+    return $this->event->input->read($maxLen);
+  }
+
+  /**
+   * Write a string to the socket
+   *
+   * @param   string str
+   * @return  int bytes written
+   * @throws  peer.SocketException in case of an error
+   */
+  public function write($data) {
+    $this->event->output->add($data);
+    return strlen($data);
+  }
+
+  /**
+   * Close socket
+   *
+   * @return  bool success
+   */
+  public function close() {
+    return false;
+  }
+}