kakserpom / phpdaemon

lib/Request.php

Doc Comments +3 added lines, -1 removed lines

@@ -50,7 +50,8 @@ 
  	/**
 	 * Output some data
 	 * @param string String to out
-	 * @return boolean Success
+	 * @param string $s
+	 * @return boolean|null Success
 	 */
 	public function out($s, $flush = true) {
 	}
@@ -222,6 +223,7 @@ 
  
 	/**
 	 * Adds new callback called before the request finished
+	 * @param Closure $callback
 	 * @return void
 	 */
 	public function registerShutdownFunction($callback) {

lib/ShmEntity.php

Doc Comments +6 added lines

@@ -6,6 +6,9 @@ 
 	public $name;
 	public $key;
 
+	/**
+	 * @param string $name
+	 */
 	public function __construct($path, $segsize, $name, $create = false) {
 		$this->path = $path;
 		$this->segsize = $segsize;
@@ -55,6 +58,9 @@ 
 		} while ($r);
 	}
 
+	/**
+	 * @param string $data
+	 */
 	public function write($data, $offset) {
 		$segno = floor($offset / $this->segsize);
 		if (!isset($this->segments[$segno])) {

lib/Thread.php

Doc Comments +12 added lines, -5 removed lines

@@ -153,7 +153,7 @@ 
 
 	/**
 	 * Starts the process
-	 * @return void
+	 * @return null|integer
 	 */
 	public function start($clearstack = true) {
 		$pid = pcntl_fork();
@@ -205,7 +205,7 @@ 
 	/**
 	 * Sends the signal to parent process
 	 * @param integer Signal's number
-	 * @return void
+	 * @return boolean
 	 */
 	private function backsig($sig) {
 		return posix_kill(posix_getppid(), $sig);
@@ -214,7 +214,7 @@ 
 	/**
 	 * Delays the process execution for the given number of seconds
 	 * @param integer Sleep time in seconds
-	 * @return void
+	 * @return boolean
 	 */
 	public function sleep($s) {
 		static $interval = 0.2;
@@ -274,7 +274,7 @@ 
 	/**
 	 * Terminates the process
 	 * @param boolean Kill?
-	 * @return void
+	 * @return boolean
 	 */
 	public function stop($kill = false) {
 		$this->shutdown = true;
@@ -328,6 +328,7 @@ 
 
 	/**
 	 * Waits until children is alive
+	 * @param boolean $check
 	 * @return void
 	 */
 	protected function waitAll($check) {
@@ -346,6 +347,7 @@ 
 	/**
 	 * Sets a title of the current process
 	 * @param string Title
+	 * @param string $title
 	 * @return void
 	 */
 	protected function setproctitle($title) {
@@ -360,7 +362,7 @@ 
 	 * Waits for signals, with a timeout
 	 * @param int Seconds
 	 * @param int Nanoseconds
-	 * @return void
+	 * @return boolean
 	 */
 	protected function sigwait($sec = 0, $nano = 0.3e9) {
 		$siginfo = NULL;
@@ -382,6 +384,11 @@ 
 
 if (!function_exists('pcntl_sigtimedwait')) {
 	// @todo $signals or Thread::$signals?
+
+	/**
+	 * @param integer $sec
+	 * @param double $nano
+	 */
 	function pcntl_sigtimedwait($signals, $siginfo, $sec, $nano) {
 		pcntl_signal_dispatch();
 

lib/Timer.php

Doc Comments +4 added lines

@@ -48,6 +48,10 @@
 		$obj = new self($cb, $timeout, $id, $priority);
 		return $obj->id;
 	}
+
+	/**
+	 * @param integer $timeout
+	 */
 	public static function setTimeout($id, $timeout = NULL) {
 		if (isset(Timer::$list[$id])) {
 			Timer::$list[$id]->timeout($timeout);

lib/ValveClient.php

Doc Comments +6 added lines

@@ -19,6 +19,9 @@ 
 	
 	public static $zombie = 0;
 
+	/**
+	 * @param string $name
+	 */
 	public function request($addr, $name, $data,  $cb) {
 		$e = explode(':', $addr);
 		$this->getConnection('valve://[udp:' . $e[0] . ']' . (isset($e[1]) ? ':'.$e[1] : '') . '/', function($conn) use ($cb, $addr, $data, $name) {
@@ -90,6 +93,9 @@ 
 		$this->request('info', null, $cb);
 	}
 
+	/**
+	 * @param string $name
+	 */
 	public function request($name, $data = null, $cb = null) {
 		$packet = "\xFF\xFF\xFF\xFF";
 		if ($name === 'ping') {

lib/WebSocketProtocol.php

Doc Comments +7 added lines, -1 removed lines

@@ -12,10 +12,16 @@ 
 	const STRING = NULL;
 	const BINARY = NULL;
 	
+	/**
+	 * @param WebSocketServerConnection $connection
+	 */
 	public function __construct($connection) {
 		$this->connection = $connection;
 	}
 
+	/**
+	 * @return integer
+	 */
 	public function getFrameType($type) {
 		if (is_int($type)) {
 			return $type;
@@ -45,7 +51,7 @@ 
     /**
      * Returns handshaked data for reply
 	 * @param string Received data (no use in this class)
-     * @return string Handshaked data
+     * @return boolean Handshaked data
      */
 
     public function getHandshakeReply($data) {

lib/WebSocketProtocolV13.php

Doc Comments +13 added lines

@@ -16,6 +16,9 @@ 
 	public $opcodes;
 	public $outgoingCompression = 0;
 		
+	/**
+	 * @param WebSocketServerConnection $connection
+	 */
 	public function __construct($connection) {
 		$this->connection = $connection;
 		$this->opcodes = array(
@@ -95,6 +98,9 @@ 
 		return $this->encodeFragment($data, $type, $fin, $rsv1, $rsv2, $rsv3);
     }
 
+	/**
+	 * @param string $type
+	 */
 	protected function encodeFragment($data, $type, $fin = 1, $rsv1 = 0, $rsv2 = 0, $rsv3 = 0) {
         $mask =	chr(rand(0, 0xFF)) .
  						chr(rand(0, 0xFF)) . 
@@ -132,6 +138,12 @@ 
 		}
 		return $packet;
 	}
+
+	/**
+	 * @param string $mask
+	 *
+	 * @return string
+	 */
 	public function mask ($data, $mask) {
    		for ($i = 0, $l = strlen($data), $ml = strlen($mask); $i < $l; $i++) {
 	     	$data[$i] = $data[$i] ^ $mask[$i % $ml] ;
@@ -142,6 +154,7 @@ 
 	 * Converts binary string to integer
 	 * @param string Binary string
 	 * @param boolean Optional. Little endian. Default value - false.
+	 * @param string $str
 	 * @return integer Resulting integer
 	 */
 	public function bytes2int($str, $l = FALSE)

lib/WebSocketServerConnection.php

Doc Comments +2 added lines

@@ -151,6 +151,7 @@ 
 
 	/**
 	 * Called when we're going to handshake.
+	 * @param string $data
 	 * @return boolean Handshake status
 	 */
 
@@ -197,6 +198,7 @@ 
 	/**
 	 * Called when new data received.
 	 * @param string New received data.
+	 * @param string $buf
 	 * @return void
 	 */
 

lib/XMLStream.php

Doc Comments +5 added lines, -3 removed lines

@@ -17,6 +17,9 @@ 
 		xml_set_character_data_handler($this->parser, 'charXML');
 	}
 
+	/**
+	 * @param string $ns
+	 */
 	public function setDefaultNS($ns) {
 		$this->default_ns = $ns;
 	}
@@ -164,8 +167,7 @@ 
 	 * Add ID Handler
 	 *
 	 * @param integer $id
-	 * @param string  $pointer
-	 * @param string  $obj
+	 * @param Closure $cb
 	 */
 	public function addIdHandler($id, $cb) {
 		if ($cb === null) {
@@ -196,8 +198,8 @@ 
 	 * Add XPath Handler
 	 *
 	 * @param string $xpath
-	 * @param string $pointer
 	 * @param
+	 * @param Closure $cb
 	 */
 	public function addXPathHandler($xpath, $cb, $obj = null) {
 		if (preg_match_all("/\(?{[^\}]+}\)?(\/?)[^\/]+/", $xpath, $regs)) {