Removed deprecated code (see last commit why)

[hub.git] / application / hub / main / listener / class_BaseListener.php

diff --git a/application/hub/main/listener/class_BaseListener.php b/application/hub/main/listener/class_BaseListener.php
index 7bbf70b00241e819b840ba65ba7949fcd476e0a1..b81ffd2027d98f28c52c1a78a443f4fb2b481cad 100644 (file)
--- a/application/hub/main/listener/class_BaseListener.php
+++ b/application/hub/main/listener/class_BaseListener.php
@@ -4,7 +4,7 @@
  *
  * @author             Roland Haeder <webmaster@ship-simu.org>
  * @version            0.0.0
- * @copyright  Copyright (c) 2007, 2008 Roland Haeder, 2009, 2010 Hub Developer Team
+ * @copyright  Copyright (c) 2007, 2008 Roland Haeder, 2009 - 2011 Hub Developer Team
  * @license            GNU GPL 3.0 or any newer version
  * @link               http://www.ship-simu.org
  *
@@ -29,7 +29,7 @@ class BaseListener extends BaseHubSystem implements Visitable {
        /**
         * Used protocol (Default: invalid, which is indeed invalid...)
         */
-       private $protcol = 'invalid';
+       private $protocol = 'invalid';
 
        /**
         * Address (IP mostly) we shall listen on
@@ -47,15 +47,10 @@ class BaseListener extends BaseHubSystem implements Visitable {
        private $blockingMode = false;
 
        /**
-        * A client pool instance
+        * A peer pool instance
         */
        private $poolInstance = null;
 
-       /**
-        * A network package handler instance
-        */
-       private $packageInstance = null;
-
        /**
         * Protected constructor
         *
@@ -80,6 +75,7 @@ class BaseListener extends BaseHubSystem implements Visitable {
                // We need to clear the error here if it is a resource
                if ($isServerSocket === true) {
                        // Clear the error
+                       //* DEBUG: */ $this->debugOutput('socketResource[]=' . gettype($socketResource));
                        socket_clear_error($socketResource);
                } // END - if
 
@@ -196,43 +192,24 @@ class BaseListener extends BaseHubSystem implements Visitable {
        }
 
        /**
-        * Setter for client pool instance
+        * Setter for peer pool instance
         *
-        * @param       $poolInstance   The client pool instance we shall set
+        * @param       $poolInstance   The peer pool instance we shall set
         * @return      void
         */
-       protected final function setPoolInstance (PoolableClient $poolInstance) {
+       protected final function setPoolInstance (PoolablePeer $poolInstance) {
                $this->poolInstance = $poolInstance;
        }
 
        /**
-        * Getter for client pool instance
+        * Getter for peer pool instance
         *
-        * @return      $poolInstance   The client pool instance we shall set
+        * @return      $poolInstance   The peer pool instance we shall set
         */
-       protected final function getPoolInstance () {
+       public final function getPoolInstance () {
                return $this->poolInstance;
        }
 
-       /**
-        * Setter for network package handler instance
-        *
-        * @param       $packageInstance        The network package handler instance we shall set
-        * @return      void
-        */
-       protected final function setPackageInstance (Networkable $packageInstance) {
-               $this->packageInstance = $packageInstance;
-       }
-
-       /**
-        * Getter for network package handler instance
-        *
-        * @return      $packageInstance        The network package handler instance we shall set
-        */
-       protected final function getPackageInstance () {
-               return $this->packageInstance;
-       }
-
        /**
         * Registeres the given socket resource for "this" listener instance. This
         * will be done in a seperate class to allow package writers to use it
@@ -301,7 +278,7 @@ class BaseListener extends BaseHubSystem implements Visitable {
         */
        public function accept (Visitor $visitorInstance) {
                // Debug message
-               //* DEBUG: */ $this->debugOutput('LISTENER: ' . $visitorInstance->__toString() . ' has visited ' . $this->__toString() . ' - START');
+               //* DEBUG: */ $this->debugOutput(strtoupper($this->getProtocol()) . '-LISTENER: ' . $visitorInstance->__toString() . ' has visited ' . $this->__toString() . ' - START');
 
                // Visit this listener
                $visitorInstance->visitListener($this);
@@ -312,7 +289,20 @@ class BaseListener extends BaseHubSystem implements Visitable {
                } // END - if
 
                // Debug message
-               //* DEBUG: */ $this->debugOutput('LISTENER: ' . $visitorInstance->__toString() . ' has visited ' . $this->__toString() . ' - FINISHED');
+               //* DEBUG: */ $this->debugOutput(strtoupper($this->getProtocol()) . '-LISTENER: ' . $visitorInstance->__toString() . ' has visited ' . $this->__toString() . ' - FINISHED');
+       }
+
+       /**
+        * Monitors incoming raw data from the handler and transfers it to the
+        * given receiver instance. This method should not be called, please call
+        * the decorator's version instead to seperator node/client traffic.
+        *
+        * @param       $receiverInstance       An instance of a Receivable class
+        * @return      void
+        * @throws      UnsupportedOperatorException    If this method is called by a mistake
+        */
+       public function monitorIncomingRawData (Receivable $receiverInstance) {
+               throw new UnsupportedOperationException(array($this, __FUNCTION__, $receiverInstance), self::EXCEPTION_UNSPPORTED_OPERATION);
        }
 }