kakserpom / phpdaemon

app-examples/ExampleWithMySQL.php

Doc Comments +1 added lines, -1 removed lines

@@ -23,7 +23,7 @@
 	 * Creates Request.
 	 * @param object Request.
 	 * @param object Upstream application instance.
-	 * @return object Request.
+	 * @return ExampleWithMySQLRequest Request.
 	 */
 	public function beginRequest($req, $upstream) {
 		

app-examples/ExampleWithPostgreSQL.php

Doc Comments +1 added lines, -1 removed lines

@@ -12,7 +12,7 @@
 	 * Creates Request.
 	 * @param object Request.
 	 * @param object Upstream application instance.
-	 * @return object Request.
+	 * @return ExampleWithPostgreSQLRequest Request.
 	 */
 	 public function beginRequest($req, $upstream) {
 		return new ExampleWithPostgreSQLRequest($this, $upstream, $req);

app-examples/ExampleWithRedis.php

Doc Comments +1 added lines, -1 removed lines

@@ -24,7 +24,7 @@
 	 * Creates Request.
 	 * @param object Request.
 	 * @param object Upstream application instance.
-	 * @return object Request.
+	 * @return ExampleWithRedisRequest Request.
 	 */
 	public function beginRequest($req, $upstream) {
 		return new ExampleWithRedisRequest($this, $upstream, $req);

app-web/CGI.php

Doc Comments +3 added lines, -2 removed lines

@@ -50,7 +50,7 @@ 
 	 * Creates Request.
 	 * @param object Request.
 	 * @param object Upstream application instance.
-	 * @return object Request.
+	 * @return CGIRequest Request.
 	 */
 	public function beginRequest($req, $upstream) {
 		return new CGIRequest($this, $upstream, $req);
@@ -125,7 +125,7 @@ 
 
 	/**
 	 * Called when request iterated.
-	 * @return void
+	 * @return integer
 	 */
 	public function run() {
 		if (!$this->proc) {
@@ -155,6 +155,7 @@ 
 
 	/**
 	 * Called when the request aborted.
+	 * @param AsyncProcess $process
 	 * @return void
 	 */
 	public function onWrite($process) {

app-web/FileReader.php

Doc Comments +1 added lines, -1 removed lines

@@ -36,7 +36,7 @@
 	 * Creates Request.
 	 * @param object Request.
 	 * @param object Upstream application instance.
-	 * @return object Request.
+	 * @return FileReaderRequest Request.
 	 */
 	public function beginRequest($req, $upstream) {
 		return new FileReaderRequest($this, $upstream, $req);

app-web/WebSocketOverCOMET.php

Doc Comments +9 added lines, -1 removed lines

@@ -48,7 +48,7 @@ 
 	 * Creates Request.
 	 * @param object Request.
 	 * @param object Upstream application instance.
-	 * @return object Request.
+	 * @return WebSocketOverCOMET_Request Request.
 	 */
 	public function beginRequest($req, $upstream) {
 		$req = new WebSocketOverCOMET_Request($this, $upstream, $req);
@@ -120,6 +120,11 @@ 
 	public $finished = false;
 	public $timeout = 30; // 30
 	public $server;
+
+	/**
+	 * @param WebSocketOverCOMET $appInstance
+	 * @param string $authKey
+	 */
 	public function __construct($route, $appInstance, $authKey) {
 		$this->polling = new SplStack;
 		$this->callbacks = new StackCallbacks;
@@ -166,6 +171,9 @@ 
 		}
 	}
 
+	/**
+	 * @param double $b
+	 */
 	public function compareFloats($a, $b, $precision = 3) {
 		$k = pow(10, $precision);
 		$a = round($a * $k) / $k;

lib/AppInstance.php

Doc Comments +4 added lines, -3 removed lines

@@ -87,7 +87,7 @@ 
 	/**
 	 * Function to get default config options from application
 	 * Override to set your own
-	 * @return array|false
+	 * @return boolean
 	 */
 	protected function getConfigDefaults() {
 		return false;
@@ -113,6 +113,7 @@ 
 	 * @param string Method name.
 	 * @param array Arguments.
 	 * @param mixed Callback.
+	 * @param string $method
 	 * @return boolean Success.
 	 */
 	public function broadcastCall($method, $args = array(), $cb = NULL) {
@@ -250,7 +251,7 @@ 
 	/** 
 	 * Shutdown the application instance
 	 * @param boolean Graceful?
-	 * @return void
+	 * @return boolean
 	 */
 	public function shutdown($graceful = false) {
 		return $this->onShutdown($graceful);
@@ -275,7 +276,7 @@ 
 	/**
 	 * Handle the worker status
 	 * @param int Status code @todo use constants in method
-	 * @return boolean Result
+	 * @return null|boolean Result
 	 */
 	public function handleStatus($ret) {
 		if ($ret === self::EVENT_CONFIG_UPDATED) {

lib/AsyncProcess.php

Doc Comments +6 added lines, -4 removed lines

@@ -71,7 +71,7 @@ 
 	/**
 	 * Sets an array of arguments
 	 * @param array Arguments
-	 * @return object AsyncProccess
+	 * @return AsyncProcess AsyncProccess
 	 */
 	public function setArgs($args = NULL) {
 		$this->args = $args;
@@ -82,7 +82,7 @@ 
 	/**
 	 * Set a hash of environment's variables
 	 * @param array Hash of environment's variables
-	 * @return object AsyncProccess
+	 * @return AsyncProcess AsyncProccess
 	 */
 	public function setEnv($env = NULL) {
 		$this->env = $env;
@@ -93,7 +93,8 @@ 
 	/**
 	 * Set priority.
 	 * @param integer Priority
-	 * @return object AsyncProccess
+	 * @param integer $nice
+	 * @return AsyncProcess AsyncProccess
 	 */
 	public function nice($nice = NULL) {
 		$this->nice = $nice;
@@ -106,7 +107,8 @@ 
 	 * @param string Optional. Binpath.
 	 * @param array Optional. Arguments.
 	 * @param array Optional. Hash of environment's variables.
-	 * @return object AsyncProccess
+	 * @param string $binPath
+	 * @return AsyncProcess AsyncProccess
 	 */
 	public function execute($binPath = NULL, $args = NULL, $env = NULL) {
 		if ($binPath !== NULL) {

lib/AsyncStream.php

Doc Comments +6 added lines

@@ -33,6 +33,9 @@ 
 	public $filePath;
 	public $useSockets = true;
 
+	/**
+	 * @param string $readFD
+	 */
 	public function __construct($readFD = NULL, $writeFD = NULL) {
 		$this->initStream($readFD, $writeFD);
 	}
@@ -275,6 +278,9 @@ 
 		return $this;
 	}
 
+	/**
+	 * @param Closure $cb
+	 */
 	public function onEOF($cb = NULL) {
 		$this->onEOF = $cb;