nanoserv
[ class tree: nanoserv ] [ index: nanoserv ] [ all elements ]
Packages:
nanoserv

Source for file NS_Line_Input_Connection_Handler.php

Documentation is available at NS_Line_Input_Connection_Handler.php

  1. <?php
  2.  
  3. /**
  4.  *
  5.  * nanoserv handlers - Line input connection handler
  6.  * 
  7.  * Copyright (C) 2004-2010 Vincent Negrier aka. sIX <six@aegis-corp.org>
  8.  * 
  9.  * This library is free software; you can redistribute it and/or
  10.  * modify it under the terms of the GNU Lesser General Public
  11.  * License as published by the Free Software Foundation; either
  12.  * version 2.1 of the License, or (at your option) any later version.
  13.  * 
  14.  * This library is distributed in the hope that it will be useful,
  15.  * but WITHOUT ANY WARRANTY; without even the implied warranty of
  16.  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
  17.  * Lesser General Public License for more details.
  18.  * 
  19.  * You should have received a copy of the GNU Lesser General Public
  20.  * License along with this library; if not, write to the Free Software
  21.  * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA *
  22.  *
  23.  * @package nanoserv
  24.  * @subpackage Handlers
  25.  */
  26.  
  27. /**
  28.  * Require the nanoserv core
  29.  */
  30. require_once "nanoserv-compat/nanoserv.php";
  31.  
  32. /**
  33.  * Line input connection handler class
  34.  *
  35.  * @package nanoserv
  36.  * @subpackage Handlers
  37.  */
  38. abstract class NS_Line_Input_Connection_Handler extends NS_Connection_Handler {
  39.  
  40.     /**
  41.      * Maximum line length
  42.      */
  43.     const MAX_LENGTH = 16384;
  44.     
  45.     /**
  46.      * Line separator
  47.      */
  48.     const EOL_SEPARATOR = "\n";
  49.     
  50.     /**
  51.      * Line buffer
  52.      * @var string 
  53.      */
  54.     private $line_buffer = "";
  55.  
  56.     final public function on_Read($data) {
  57.  
  58.         $this->line_buffer .= $data;
  59.  
  60.         while (($p = strrpos($this->line_buffer, self::EOL_SEPARATOR)) !== false) {
  61.  
  62.             $lines = explode(self::EOL_SEPARATOR, substr($this->line_buffer, 0, $p));
  63.             $this->line_buffer = substr($this->line_buffer, $p + strlen(self::EOL_SEPARATOR));
  64.  
  65.             foreach ($lines as $line) $this->on_Read_Line(rtrim($line, "\r\n").self::EOL_SEPARATOR);
  66.         
  67.         }
  68.     
  69.         if (strlen($this->line_buffer) > self::MAX_LENGTH) {
  70.  
  71.             $this->on_Read_Line($this->line_buffer);
  72.             $this->line_buffer = "";
  73.         
  74.         }
  75.     
  76.     }
  77.  
  78.     /**
  79.      * Event called on new line of data
  80.      *
  81.      * @param string $data 
  82.      */
  83.     abstract public function on_Read_Line($data);
  84.  
  85. }
  86.  
  87. ?>
Documentation generated on Wed, 30 Nov 2011 22:03:25 +0100 by phpDocumentor 1.4.3