kakserpom / phpdaemon

app-examples/ExampleIRCBot.php

Braces +1 added lines, -2 removed lines

@@ -61,8 +61,7 @@
 				$conn->bind('disconnect', function() use ($app) {
 					$app->connect();
 				});
-			}
-			else {
+			} else {
 				Daemon::log('IRCBot: unable to connect ('.$this->config->url->value.')');
 			}
 		});

app-examples/TelnetHoneypot.php

Braces +1 added lines, -2 removed lines

@@ -41,8 +41,7 @@
 
 			if ($cmd === 'ping') {
 				$this->writeln('pong');
-			}
-			elseif (
+			} elseif (
 				($cmd === 'exit') 
 				|| ($cmd === 'quit')
 			) {

app-examples/ExampleJabberbot.php

Braces +1 added lines, -2 removed lines

@@ -57,8 +57,7 @@
 				$conn->addEventHandler('disconnect', function() use ($app) {
 					$app->connect();
 				});
-			}
-			else {
+			} else {
 				Daemon::log('Jabberbot: unable to connect ('.$this->config->url->value.')');
 			}
 		});

app-examples/ExampleLockClient.php

Braces +1 added lines, -2 removed lines

@@ -42,8 +42,7 @@
 								$req->wakeup();
 								$event->finish();
 							}, pow(10,6) * 1);
-						}
-						else {
+						} else {
 						 $req->out(':-(');
 						 $req->wakeup();
 						}

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;
 

Braces +2 added lines, -4 removed lines

@@ -38,15 +38,13 @@
 					$this->result = '';
 					$this->state = self::STATE_DATA;
 					break;
-				}
-				elseif ($e[0] == 'STAT') {
+				} elseif ($e[0] == 'STAT') {
 					if ($this->result === NULL) {
 						$this->result = array();
 					}
 
 					$this->result[$e[1]] = $e[2];
-				}
-				elseif (
+				} elseif (
 					($e[0] === 'STORED') 
 					|| ($e[0] === 'END') 
 					|| ($e[0] === 'DELETED') 

lib/NetworkClient.php

Braces +1 added lines, -2 removed lines

@@ -91,8 +91,7 @@
 				if ($this->acquireOnGet) {
 					$free->detach($conn);			
 				}
-			}
-			elseif ($storage->count() >= $this->maxConnPerServ) {
+			} elseif ($storage->count() >= $this->maxConnPerServ) {
 				if (!isset($this->pending[$url])) {
 					$this->pending[$url] = new PriorityQueueCallbacks;
 				}

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/Daemon_WorkerThread.php

Braces +4 added lines, -8 removed lines

@@ -282,8 +282,7 @@ 
 			if (posix_getuid() != 0) {
 				Daemon::log('You must have the root privileges to change root.');
 				exit(0);
-			}
-			elseif (!chroot(Daemon::$config->chroot->value)) {
+			} elseif (!chroot(Daemon::$config->chroot->value)) {
 				Daemon::log('Couldn\'t change root to \'' . Daemon::$config->chroot->value . '\'.');
 				exit(0);
 			}
@@ -293,8 +292,7 @@ 
 			if ($sg === FALSE) {
 				Daemon::log('Couldn\'t change group to \'' . Daemon::$config->group->value . '\'. You must replace config-variable \'group\' with existing group.');
 				exit(0);
-			}
-			elseif (
+			} elseif (
 				($sg['gid'] != posix_getgid())
 				&& (!posix_setgid($sg['gid']))
 			) {
@@ -307,8 +305,7 @@ 
 			if ($su === FALSE) {
 				Daemon::log('Couldn\'t change user to \'' . Daemon::$config->user->value . '\', user not found. You must replace config-variable \'user\' with existing username.');
 				exit(0);
-			}
-			elseif (
+			} elseif (
 				($su['uid'] != posix_getuid())
 				&& (!posix_setuid($su['uid']))
 			) {
@@ -476,8 +473,7 @@ 
 			}
 			if (!$self->reloadReady) {
 				$event->timeout();
-			}
-			else {
+			} else {
 				$self->eventBase->exit();
 			}
 		}, 1e6, 'checkReloadReady');