kakserpom / phpdaemon

app-examples/ExampleComplexJob.php

Indentation +52 added lines, -52 removed lines

@@ -14,13 +14,13 @@ 
 	 * 
 	 * @return void
 	 */
-    public function onReady() {
+	public function onReady() {
 
-        // Adding listener
-        // ComplexJob - STATE_WAITING
-        $job = new ComplexJob(function($job) {
-        	// ComplexJob - STATE_DONE
-            /*array (
+		// Adding listener
+		// ComplexJob - STATE_WAITING
+		$job = new ComplexJob(function($job) {
+			// ComplexJob - STATE_DONE
+			/*array (
               'bar' =>
               array (
                     'job' => 'bar',
@@ -44,62 +44,62 @@ 
                     'line' => 94,
               ),
             )*/
-            Daemon::log($job->results);
-        });
+			Daemon::log($job->results);
+		});
 
-        // Adding listener
-        // ComplexJob - STATE_WAITING
-        $job->addListener(function($job) {
+		// Adding listener
+		// ComplexJob - STATE_WAITING
+		$job->addListener(function($job) {
 			// ComplexJob - STATE_DONE
-        });
+		});
 
-        // Incapsulate some property in job
-        $job->appInstance = $this;
+		// Incapsulate some property in job
+		$job->appInstance = $this;
 
-        // Adding async job foo
-        $job('foo', $this->foo(array('param' => 'value')));
+		// Adding async job foo
+		$job('foo', $this->foo(array('param' => 'value')));
 
-        // Adding with 1 sec delay
-        Timer::add(function($event) use ($job) {
+		// Adding with 1 sec delay
+		Timer::add(function($event) use ($job) {
 
-            // Adding async job bar
-            $job('bar', function($jobname, $job) {
-                Timer::add(function($event) use($jobname, $job) {
-                    // Job done
-                    $job->setResult($jobname, array('job' => 'bar', 'success' => false, 'line' => __LINE__));
-                    $event->finish();
-                }, 1e3 * 50);
-            });
+			// Adding async job bar
+			$job('bar', function($jobname, $job) {
+				Timer::add(function($event) use($jobname, $job) {
+					// Job done
+					$job->setResult($jobname, array('job' => 'bar', 'success' => false, 'line' => __LINE__));
+					$event->finish();
+				}, 1e3 * 50);
+			});
 
-            // Adding async job baz. Equal $job('baz', $job->appInstance->baz());
-            $job->addJob('baz', $job->appInstance->baz());
+			// Adding async job baz. Equal $job('baz', $job->appInstance->baz());
+			$job->addJob('baz', $job->appInstance->baz());
 
-            // Run jobs. All listeners will be called when the jobs done
-            // ComplexJob - STATE_RUNNING
-            $job();
+			// Run jobs. All listeners will be called when the jobs done
+			// ComplexJob - STATE_RUNNING
+			$job();
                 
-            $event->finish();
-        }, 1e6 * 1);
+			$event->finish();
+		}, 1e6 * 1);
 
-    }
+	}
 
-    final public function foo($arg) {
-        return function($jobname, $job) use ($arg) {
-            Timer::add(function($event) use($jobname, $job, $arg) {
-                // Job done
-                $job->setResult($jobname, array('job' => 'foo', 'success' => true, 'line' => __LINE__, 'arg' => $arg));
-                $event->finish();
-            }, 1e3 * 100);
-        };
-    }
+	final public function foo($arg) {
+		return function($jobname, $job) use ($arg) {
+			Timer::add(function($event) use($jobname, $job, $arg) {
+				// Job done
+				$job->setResult($jobname, array('job' => 'foo', 'success' => true, 'line' => __LINE__, 'arg' => $arg));
+				$event->finish();
+			}, 1e3 * 100);
+		};
+	}
 
-    final public function baz() {
-        return function($jobname, $job) {
-            Timer::add(function($event) use($jobname, $job) {
-                // Job done
-                $job->setResult($jobname, array('job' => 'baz', 'success' => false, 'line' => __LINE__));
-                $event->finish();
-            }, 1e3 * 300);
-        };
-    }
+	final public function baz() {
+		return function($jobname, $job) {
+			Timer::add(function($event) use($jobname, $job) {
+				// Job done
+				$job->setResult($jobname, array('job' => 'baz', 'success' => false, 'line' => __LINE__));
+				$event->finish();
+			}, 1e3 * 300);
+		};
+	}
 }

lib/MemcacheClientConnection.php

Indentation +1 added lines, -1 removed lines

@@ -21,7 +21,7 @@
 	 * Called when new data received
 	 * @param string New data
 	 * @return void
-	*/
+	 */
 	public function stdin($buf) {
 		$this->buf .= $buf;
 

lib/XMPPRoster.php

Indentation +9 added lines, -9 removed lines

@@ -101,14 +101,14 @@ 
 	}
 
 		/**
-	 *
-	 * Add given contact to roster
-	 *
-	 * @param string $jid
-	 * @param string $subscription
-	 * @param string $name
-	 * @param array $groups
-	 */
+		 *
+		 * Add given contact to roster
+		 *
+		 * @param string $jid
+		 * @param string $subscription
+		 * @param string $name
+		 * @param array $groups
+		 */
 	public function _addContact($jid, $subscription, $name='', $groups=array()) {
 		$contact = array('jid' => $jid, 'subscription' => $subscription, 'name' => $name, 'groups' => $groups);
 		if ($this->isContact($jid)) {
@@ -148,7 +148,7 @@ 
 	 * @param integer $priority
 	 * @param string $show
 	 * @param string $status
-	*/
+	 */
 	public function setPresence($presence, $priority, $show, $status) {
 		list($jid, $resource) = explode('/', $presence . '/');
 		if ($show != 'unavailable') {

lib/HTTPClient.php

Indentation +2 added lines, -2 removed lines

@@ -140,8 +140,8 @@
 		foreach ($headers as $key => $item) {
 			if (is_numeric($key)) {
 				if (is_string($item)) {
-                    $this->writeln($item);
-                }
+					$this->writeln($item);
+				}
 				elseif (is_array($item)) {
 					$this->writeln($item[0].': '.$item[1]); // @TODO: prevent injections?
 				}

lib/ValveClient.php

Indentation +6 added lines, -6 removed lines

@@ -198,11 +198,11 @@ 
 			$info['secure'] = Binary::getByte($st); 
    		}
    		elseif ($type === ValveClient::S2A_INFO_SOURCE) {
-    		$info['srvaddress'] = Binary::getString($st);
-    		$info['hostname'] = Binary::getString($st);
-    		$info['map'] = Binary::getString($st);
-    		$info['gamedir'] = Binary::getString($st);
-    		$info['gamedescr'] = Binary::getString($st);
+			$info['srvaddress'] = Binary::getString($st);
+			$info['hostname'] = Binary::getString($st);
+			$info['map'] = Binary::getString($st);
+			$info['gamedir'] = Binary::getString($st);
+			$info['gamedescr'] = Binary::getString($st);
 			$info['playersnum'] = Binary::getByte($st);
 			$info['playersmax'] = Binary::getByte($st); 
 			$info['proto'] = Binary::getByte($st);
@@ -218,7 +218,7 @@ 
 				$info['mod_size'] = Binary::getDWord($st);
 				$info['mod_serverside'] = Binary::getByte($st);
 				$info['mod_customdll'] = Binary::getByte($st);
-    		}
+			}
 			$info['secure'] = Binary::getByte($st);
 			$info['botsnum'] = Binary::getByte($st);
 		}

lib/HTTPServer.php

Indentation +1 added lines, -1 removed lines

@@ -62,7 +62,7 @@
 	/**
 	 * Called when the worker is ready to go.
 	 * @return void
-	*/
+	 */
 	public function onReady() {
 		parent::onReady();
 		$this->WS = WebSocketServer::getInstance();

lib/MongoClientAsync.php

Indentation +3 added lines, -3 removed lines

@@ -859,9 +859,9 @@
 		if (strpos($col, '.') === false) {
 			$col = $this->dbname . '.' . $col;
 		} else {
-            $collName = explode('.', $col);
-            $this->dbname = $collName[0];
-        }
+			$collName = explode('.', $col);
+			$this->dbname = $collName[0];
+		}
 
 		if (isset($this->collections[$col])) {
 			return $this->collections[$col];

lib/RedisClientConnection.php

Indentation +1 added lines, -1 removed lines

@@ -24,7 +24,7 @@
 	 * Called when new data received
 	 * @param string New data
 	 * @return void
-	*/
+	 */
 	public function stdin($buf) {
 		$this->buf .= $buf;
 		start:

lib/IOStream.php

Indentation +1 added lines, -1 removed lines

@@ -35,7 +35,7 @@
 
 	/**
 	 * IOStream constructor
- 	 * @param resource File descriptor.
+	 * @param resource File descriptor.
 	 * @param object AppInstance
 	 * @return void
 	 */