kakserpom / phpdaemon

lib/NetworkClientConnection.php

Spacing +1 added lines, -1 removed lines

@@ -11,7 +11,7 @@
 	public $busy = false;
 	public $timeout = 60;
 	
-	public $onResponse;  // stack of onResponse callbacks
+	public $onResponse; // stack of onResponse callbacks
 	
 	public $alive = true;
 

Braces +1 added lines, -2 removed lines

@@ -41,8 +41,7 @@
 		}
 		if ($this->busy) {
 			$this->pool->servConnFree[$this->url]->detach($this);
-		}
-		else {
+		} else {
 			$this->pool->servConnFree[$this->url]->attach($this);
 			$this->release();
 		}

lib/Daemon_ConfigEntryConfigFile.php

Spacing +2 added lines, -2 removed lines

@@ -15,12 +15,12 @@
 		if (Daemon::$process instanceof Daemon_MasterThread) {
 			if (Daemon::$config->autoreload->value > 0) {
 				if ($old) {
-					$e = explode(';',$old);
+					$e = explode(';', $old);
 					foreach ($e as $path) {
 						Daemon::$process->fileWatcher->rmWatch($path);
 					}
 				}
-				$e = explode(';',$this->value);
+				$e = explode(';', $this->value);
 				foreach ($e as $path) {
 					Daemon::$process->fileWatcher->addWatch($path, array(Daemon::$process, 'sighup'));
 				}

lib/MemcacheClient.php

Spacing +6 added lines, -6 removed lines

@@ -41,7 +41,7 @@ 
 	 * @return void
 	 */
 	public function set($key, $value, $exp = 0, $onResponse = NULL) {
-		$this->getConnectionByKey($key, function ($conn) use ($key, $value, $exp, $onResponse) {
+		$this->getConnectionByKey($key, function($conn) use ($key, $value, $exp, $onResponse) {
 			if (!$conn->connected) {
 				return;
 			}
@@ -64,7 +64,7 @@ 
 	 * @return void
 	 */
 	public function add($key, $value, $exp = 0, $onResponse = NULL) {
-		$this->getConnectionByKey($key, function ($conn) use ($key, $value, $exp, $onResponse) {
+		$this->getConnectionByKey($key, function($conn) use ($key, $value, $exp, $onResponse) {
 			if (!$conn->connected) {
 				return;
 			}
@@ -85,7 +85,7 @@ 
 	 * @return void
 	 */
 	public function delete($key, $onResponse = NULL, $time = 0) {
-		$this->getConnectionByKey($key, function ($conn) use ($key, $time, $onResponse) {
+		$this->getConnectionByKey($key, function($conn) use ($key, $time, $onResponse) {
 			if (!$conn->connected) {
 				return;
 			}
@@ -106,7 +106,7 @@ 
 	 * @return void
 	 */
 	public function replace($key, $value, $exp = 0, $onResponse = NULL) {
-		$this->getConnectionByKey($key, function ($conn) use ($key, $value, $exp, $onResponse) {
+		$this->getConnectionByKey($key, function($conn) use ($key, $value, $exp, $onResponse) {
 			if (!$conn->connected) {
 				return;
 			}
@@ -128,7 +128,7 @@ 
 	 * @return void
 	 */
 	public function append($key, $value, $exp = 0, $onResponse = NULL) {
-		$this->getConnectionByKey($key, function ($conn) use ($key, $value, $exp, $onResponse) {
+		$this->getConnectionByKey($key, function($conn) use ($key, $value, $exp, $onResponse) {
 			if (!$conn->connected) {
 				return;
 			}
@@ -150,7 +150,7 @@ 
 	 * @return void
 	 */
 	public function prepend($key, $value, $exp = 0, $onResponse = NULL) {
-		$this->getConnectionByKey($key, function ($conn) use ($key, $value, $exp, $onResponse) {
+		$this->getConnectionByKey($key, function($conn) use ($key, $value, $exp, $onResponse) {
 			if (!$conn->connected) {
 				return;
 			}

lib/Daemon_ConfigEntryTime.php

Spacing +1 added lines, -1 removed lines

@@ -25,7 +25,7 @@
 				return;
 			}
 
-			if (!empty($m[2]))  {
+			if (!empty($m[2])) {
 				$n = (float) $m[1];
 			} else {
 				$n = (int) $m[1];

Braces +3 added lines, -6 removed lines

@@ -35,14 +35,11 @@
 
 			if ($l === 's') {
 				$time += $n;
-			}
-			elseif ($l === 'm') {
+			} elseif ($l === 'm') {
 				$time += $n * 60;
-			}
-			elseif ($l === 'h') {
+			} elseif ($l === 'h') {
 				$time += $n * 60 * 60;
-			}
-			elseif ($l === 'd') {
+			} elseif ($l === 'd') {
 				$time += $n * 60 * 60 * 24;
 			}
 		}, $value);

lib/ComplexJob.php

Spacing +1 added lines, -1 removed lines

@@ -18,7 +18,7 @@
 
 	public function __construct($cb = null) {
 		$this->state = self::STATE_WAITING;
-		if($cb !== null) {
+		if ($cb !== null) {
 			$this->addListener($cb);
 		}
 	}

lib/IdentServer.php

Spacing +7 added lines, -7 removed lines

@@ -32,11 +32,11 @@ 
 	public function RPCall($method, $args) {
 		if ($method === 'registerPair') {
 			list ($local, $foreign, $user) = $args;
-			$this->pairs[$local . ':' .$foreign] = $user;
+			$this->pairs[$local . ':' . $foreign] = $user;
 		}
 		elseif ($method === 'unregisterPair') {
 			list ($local, $foreign) = $args;
-			unset($this->pairs[$local . ':' .$foreign]);
+			unset($this->pairs[$local . ':' . $foreign]);
 		}
 	}
 
@@ -48,8 +48,8 @@ 
 	}
 	public function findPair($local, $foreign) {
 		return
-			isset($this->pairs[$local . ':' .$foreign])
-		 	? $this->pairs[$local . ':' .$foreign]
+			isset($this->pairs[$local . ':' . $foreign])
+		 	? $this->pairs[$local . ':' . $foreign]
 		 	: false;
 	}
 }
@@ -71,17 +71,17 @@ 
 		while (($line = $this->gets()) !== false) {
 			$e = explode(',', str_replace("\x20", '', $line = trim($line)));
 			if ((sizeof($e) <> 2) || !ctype_digit($e[0]) || !ctype_digit($e[1])) {
-				$this->writeln($line. ' : ERROR : INVALID-PORT');
+				$this->writeln($line . ' : ERROR : INVALID-PORT');
 				$this->finish();
 				return;
 			}
 			$local = (int) $e[0];
 			$foreign = (int) $e[1];
 			if ($user = $this->pool->findPair($local, $foreign)) {
-				$this->writeln($line. ' : USERID : ' . $user);
+				$this->writeln($line . ' : USERID : ' . $user);
 
 			} else {
-				$this->writeln($line. ' : ERROR : NO-USER');	
+				$this->writeln($line . ' : ERROR : NO-USER');	
 			}
 		}
 	}

Braces +1 added lines, -2 removed lines

@@ -33,8 +33,7 @@
 		if ($method === 'registerPair') {
 			list ($local, $foreign, $user) = $args;
 			$this->pairs[$local . ':' .$foreign] = $user;
-		}
-		elseif ($method === 'unregisterPair') {
+		} elseif ($method === 'unregisterPair') {
 			list ($local, $foreign) = $args;
 			unset($this->pairs[$local . ':' .$foreign]);
 		}

lib/Pool.php

Spacing +1 added lines, -1 removed lines

@@ -27,7 +27,7 @@
 		if ($this->isEnabled()) {
 			list ($class, $name) = explode(':', $this->name . ':');
 			if (!class_exists($class)) {
-				Daemon::log($class. ' class not exists.');
+				Daemon::log($class . ' class not exists.');
 				return;
 			}
 			$this->pool = call_user_func(array($class, 'getInstance'), $name);

lib/WebSocketProtocolV0.php

Indentation +24 added lines, -24 removed lines

@@ -10,7 +10,7 @@ 
 	const STRING = 0x00;
 	const BINARY = 0x80;
 
-    public function onHandshake() {
+	public function onHandshake() {
 		if (!isset($this->connection->server['HTTP_SEC_WEBSOCKET_KEY1']) || !isset($this->connection->server['HTTP_SEC_WEBSOCKET_KEY2'])) {
 			return false;
 		}
@@ -18,13 +18,13 @@ 
 	}
 
 	/**
-     * Returns handshaked data for reply
+	 * Returns handshaked data for reply
 	 * @param string Received data (no use in this class)
-     * @return string Handshaked data
-     */
+	 * @return string Handshaked data
+	 */
 
 	public function getHandshakeReply($data) {
-        if ($this->onHandshake()) {
+		if ($this->onHandshake()) {
 			if (strlen($data) < 8) {
 				return 0; // not enough data yet;
 			}
@@ -34,27 +34,27 @@ 
 				return false;
 			}
 
-            if (!isset($this->connection->server['HTTP_SEC_WEBSOCKET_ORIGIN'])) {
-                $this->connection->server['HTTP_SEC_WEBSOCKET_ORIGIN'] = '' ;
-            }
+			if (!isset($this->connection->server['HTTP_SEC_WEBSOCKET_ORIGIN'])) {
+				$this->connection->server['HTTP_SEC_WEBSOCKET_ORIGIN'] = '' ;
+			}
 
-            $reply = "HTTP/1.1 101 Web Socket Protocol Handshake\r\n"
-                . "Upgrade: WebSocket\r\n"
-                . "Connection: Upgrade\r\n"
-                . "Sec-WebSocket-Origin: " . $this->connection->server['HTTP_ORIGIN'] . "\r\n"
-                . "Sec-WebSocket-Location: ws://" . $this->connection->server['HTTP_HOST'] . $this->connection->server['REQUEST_URI'] . "\r\n" ;
+			$reply = "HTTP/1.1 101 Web Socket Protocol Handshake\r\n"
+				. "Upgrade: WebSocket\r\n"
+				. "Connection: Upgrade\r\n"
+				. "Sec-WebSocket-Origin: " . $this->connection->server['HTTP_ORIGIN'] . "\r\n"
+				. "Sec-WebSocket-Location: ws://" . $this->connection->server['HTTP_HOST'] . $this->connection->server['REQUEST_URI'] . "\r\n" ;
 			if ($this->connection->pool->config->expose->value) {
 				$reply .= 'X-Powered-By: phpDaemon/' . Daemon::$version . "\r\n";
 			}
-            if (isset($this->connection->server['HTTP_SEC_WEBSOCKET_PROTOCOL'])) {
+			if (isset($this->connection->server['HTTP_SEC_WEBSOCKET_PROTOCOL'])) {
 				$reply .= "Sec-WebSocket-Protocol: " . $this->connection->server['HTTP_SEC_WEBSOCKET_PROTOCOL'] . "\r\n";
-            }
-            $reply .= "\r\n" . $final_key;
-            return $reply;
-        }
+			}
+			$reply .= "\r\n" . $final_key;
+			return $reply;
+		}
 
-        return FALSE ;
-    }
+		return FALSE ;
+	}
 
 	/**
 	 * Computes final key for Sec-WebSocket.
@@ -106,7 +106,7 @@ 
 		return pack('N', $result);
 	}
 
-    public function encodeFrame($data, $type) {
+	public function encodeFrame($data, $type) {
 		// Binary
 		$type = $this->getFrameType($type);
 		if (($type & self::BINARY) === self::BINARY)
@@ -139,9 +139,9 @@ 
 		{
 			return chr(self::STRING) . $data . "\xFF" ;
 		}
-    }
+	}
 
-    public function onRead() {
+	public function onRead() {
 		while ($this->connection && (($buflen = strlen($this->connection->buf)) >= 1)) {
 			$frametype = ord(binarySubstr($this->connection->buf, 0, 1)) ;
 			if (($frametype & 0x80) === 0x80) {
@@ -193,5 +193,5 @@ 
 				}
 			}
 		}
-    }
+	}
 }
\ No newline at end of file

Spacing +28 added lines, -28 removed lines

@@ -28,21 +28,21 @@ 
 			if (strlen($data) < 8) {
 				return 0; // not enough data yet;
 			}
-			$final_key = $this->_computeFinalKey($this->connection->server['HTTP_SEC_WEBSOCKET_KEY1'], $this->connection->server['HTTP_SEC_WEBSOCKET_KEY2'], $data) ;
+			$final_key = $this->_computeFinalKey($this->connection->server['HTTP_SEC_WEBSOCKET_KEY1'], $this->connection->server['HTTP_SEC_WEBSOCKET_KEY2'], $data);
 
 			if (!$final_key) {
 				return false;
 			}
 
             if (!isset($this->connection->server['HTTP_SEC_WEBSOCKET_ORIGIN'])) {
-                $this->connection->server['HTTP_SEC_WEBSOCKET_ORIGIN'] = '' ;
+                $this->connection->server['HTTP_SEC_WEBSOCKET_ORIGIN'] = '';
             }
 
             $reply = "HTTP/1.1 101 Web Socket Protocol Handshake\r\n"
                 . "Upgrade: WebSocket\r\n"
                 . "Connection: Upgrade\r\n"
                 . "Sec-WebSocket-Origin: " . $this->connection->server['HTTP_ORIGIN'] . "\r\n"
-                . "Sec-WebSocket-Location: ws://" . $this->connection->server['HTTP_HOST'] . $this->connection->server['REQUEST_URI'] . "\r\n" ;
+                . "Sec-WebSocket-Location: ws://" . $this->connection->server['HTTP_HOST'] . $this->connection->server['REQUEST_URI'] . "\r\n";
 			if ($this->connection->pool->config->expose->value) {
 				$reply .= 'X-Powered-By: phpDaemon/' . Daemon::$version . "\r\n";
 			}
@@ -53,7 +53,7 @@ 
             return $reply;
         }
 
-        return FALSE ;
+        return FALSE;
     }
 
 	/**
@@ -67,13 +67,13 @@ 
 	protected function _computeFinalKey($key1, $key2, $data) {
 		if (strlen($data) < 8)
 		{
-			Daemon::$process->log(get_class($this) . '::' . __METHOD__ . ' : Invalid handshake data for client "' . $this->connection->addr . '"') ;
-			return FALSE ;
+			Daemon::$process->log(get_class($this) . '::' . __METHOD__ . ' : Invalid handshake data for client "' . $this->connection->addr . '"');
+			return FALSE;
 		}
 
-		$bodyData = binarySubstr($data, 0, 8) ;
+		$bodyData = binarySubstr($data, 0, 8);
 			
-		return md5($this->_computeKey($key1) . $this->_computeKey($key2) . binarySubstr($data, 0, 8), TRUE) ;
+		return md5($this->_computeKey($key1) . $this->_computeKey($key2) . binarySubstr($data, 0, 8), TRUE);
 	}
 
 	/**
@@ -132,61 +132,61 @@ 
 				goto char;
 			};
 			
-			return chr(self::BINARY) . $len . $data ;
+			return chr(self::BINARY) . $len . $data;
 		}
 		// String
 		else
 		{
-			return chr(self::STRING) . $data . "\xFF" ;
+			return chr(self::STRING) . $data . "\xFF";
 		}
     }
 
     public function onRead() {
 		while ($this->connection && (($buflen = strlen($this->connection->buf)) >= 1)) {
-			$frametype = ord(binarySubstr($this->connection->buf, 0, 1)) ;
+			$frametype = ord(binarySubstr($this->connection->buf, 0, 1));
 			if (($frametype & 0x80) === 0x80) {
-				$len = 0 ;
-				$i = 0 ;
+				$len = 0;
+				$i = 0;
 
 				do {
 					$b = ord(binarySubstr($this->connection->buf, ++$i, 1));
-					$n = $b & 0x7F ;
-					$len *= 0x80 ;
-					$len += $n ;
-				} while ($b > 0x80) ;
+					$n = $b & 0x7F;
+					$len *= 0x80;
+					$len += $n;
+				} while ($b > 0x80);
 
 				if ($this->connection->pool->maxAllowedPacket <= $len) {
 					// Too big packet
 					$this->connection->finish();
-					return FALSE ;
+					return FALSE;
 				}
 
-				if ($buflen < $len + 2)	{
+				if ($buflen < $len + 2) {
 					// not enough data yet
-					return FALSE ;
+					return FALSE;
 				} 
 					
-				$decodedData = binarySubstr($this->connection->buf, 2, $len) ;
-				$this->connection->buf = binarySubstr($this->connection->buf, 2 + $len) ;
+				$decodedData = binarySubstr($this->connection->buf, 2, $len);
+				$this->connection->buf = binarySubstr($this->connection->buf, 2 + $len);
 				$this->connection->onFrame($decodedData, 'BINARY');
 			}
 			else {
 				if (($p = strpos($this->connection->buf, "\xFF")) !== FALSE) {
 					if ($this->connection->pool->maxAllowedPacket <= $p - 1) {
 						// Too big packet
-						$this->connection->finish() ;
-						return FALSE ;
+						$this->connection->finish();
+						return FALSE;
 					}
 						
-					$decodedData = binarySubstr($this->connection->buf, 1, $p - 1) ;
-					$this->connection->buf = binarySubstr($this->connection->buf, $p + 1) ;
+					$decodedData = binarySubstr($this->connection->buf, 1, $p - 1);
+					$this->connection->buf = binarySubstr($this->connection->buf, $p + 1);
 					$this->connection->onFrame($decodedData, 'STRING');
 				}
 				else {
 					if ($this->connection->pool->maxAllowedPacket <= $buflen - 1) {
 						// Too big packet
-						$this->connection->finish() ;
-						return FALSE ;
+						$this->connection->finish();
+						return FALSE;
 					}
 					// not enough data yet					
 					return;

Braces +3 added lines, -6 removed lines

@@ -91,8 +91,7 @@ 
 
 			if ($c === "\x20") {
 				++$spaces;
-			}
-			elseif (ctype_digit($c)) {
+			} elseif (ctype_digit($c)) {
 				$digits .= $c;
 			}
 		}
@@ -169,8 +168,7 @@ 
 				$decodedData = binarySubstr($this->connection->buf, 2, $len) ;
 				$this->connection->buf = binarySubstr($this->connection->buf, 2 + $len) ;
 				$this->connection->onFrame($decodedData, 'BINARY');
-			}
-			else {
+			} else {
 				if (($p = strpos($this->connection->buf, "\xFF")) !== FALSE) {
 					if ($this->connection->pool->maxAllowedPacket <= $p - 1) {
 						// Too big packet
@@ -181,8 +179,7 @@ 
 					$decodedData = binarySubstr($this->connection->buf, 1, $p - 1) ;
 					$this->connection->buf = binarySubstr($this->connection->buf, $p + 1) ;
 					$this->connection->onFrame($decodedData, 'STRING');
-				}
-				else {
+				} else {
 					if ($this->connection->pool->maxAllowedPacket <= $buflen - 1) {
 						// Too big packet
 						$this->connection->finish() ;

lib/MySQLClient.php

Spacing +47 added lines, -47 removed lines

@@ -8,54 +8,54 @@
  */
 class MySQLClient extends NetworkClient {
 
-	const CLIENT_LONG_PASSWORD     = 1;       // new more secure passwords
-	const CLIENT_FOUND_ROWS        = 2;       // Found instead of affected rows
-	const CLIENT_LONG_FLAG         = 4;       // Get all column flags
-	const CLIENT_CONNECT_WITH_DB   = 8;       // One can specify db on connect
-	const CLIENT_NO_SCHEMA         = 16;      // Don't allow database.table.column
-	const CLIENT_COMPRESS          = 32;      // Can use compression protocol
-	const CLIENT_ODBC              = 64;      // Odbc client
-	const CLIENT_LOCAL_FILES       = 128;     // Can use LOAD DATA LOCAL
-	const CLIENT_IGNORE_SPACE      = 256;     // Ignore spaces before '('
-	const CLIENT_PROTOCOL_41       = 512;     // New 4.1 protocol
-	const CLIENT_INTERACTIVE       = 1024;    // This is an interactive client
-	const CLIENT_SSL               = 2048;    // Switch to SSL after handshake
-	const CLIENT_IGNORE_SIGPIPE    = 4096;    // IGNORE sigpipes
-	const CLIENT_TRANSACTIONS      = 8192;    // Client knows about transactions
-	const CLIENT_RESERVED          = 16384;   // Old flag for 4.1 protocol
-	const CLIENT_SECURE_CONNECTION = 32768;   // New 4.1 authentication
-	const CLIENT_MULTI_STATEMENTS  = 65536;   // Enable/disable multi-stmt support
-	const CLIENT_MULTI_RESULTS     = 131072;  // Enable/disable multi-results
+	const CLIENT_LONG_PASSWORD     = 1; // new more secure passwords
+	const CLIENT_FOUND_ROWS        = 2; // Found instead of affected rows
+	const CLIENT_LONG_FLAG         = 4; // Get all column flags
+	const CLIENT_CONNECT_WITH_DB   = 8; // One can specify db on connect
+	const CLIENT_NO_SCHEMA         = 16; // Don't allow database.table.column
+	const CLIENT_COMPRESS          = 32; // Can use compression protocol
+	const CLIENT_ODBC              = 64; // Odbc client
+	const CLIENT_LOCAL_FILES       = 128; // Can use LOAD DATA LOCAL
+	const CLIENT_IGNORE_SPACE      = 256; // Ignore spaces before '('
+	const CLIENT_PROTOCOL_41       = 512; // New 4.1 protocol
+	const CLIENT_INTERACTIVE       = 1024; // This is an interactive client
+	const CLIENT_SSL               = 2048; // Switch to SSL after handshake
+	const CLIENT_IGNORE_SIGPIPE    = 4096; // IGNORE sigpipes
+	const CLIENT_TRANSACTIONS      = 8192; // Client knows about transactions
+	const CLIENT_RESERVED          = 16384; // Old flag for 4.1 protocol
+	const CLIENT_SECURE_CONNECTION = 32768; // New 4.1 authentication
+	const CLIENT_MULTI_STATEMENTS  = 65536; // Enable/disable multi-stmt support
+	const CLIENT_MULTI_RESULTS     = 131072; // Enable/disable multi-results
 
-	const COM_SLEEP               = 0x00;  // (none, this is an internal thread state)
-	const COM_QUIT                = 0x01;  // mysql_close
-	const COM_INIT_DB             = 0x02;  // mysql_select_db
-	const COM_QUERY               = 0x03;  // mysql_real_query
-	const COM_FIELD_LIST          = 0x04;  // mysql_list_fields
-	const COM_CREATE_DB           = 0x05;  // mysql_create_db (deprecated)
-	const COM_DROP_DB             = 0x06;  // mysql_drop_db (deprecated)
-	const COM_REFRESH             = 0x07;  // mysql_refresh
-	const COM_SHUTDOWN            = 0x08;  // mysql_shutdown
-	const COM_STATISTICS          = 0x09;  // mysql_stat
-	const COM_PROCESS_INFO        = 0x0a;  // mysql_list_processes
-	const COM_CONNECT             = 0x0b;  // (none, this is an internal thread state)
-	const COM_PROCESS_KILL        = 0x0c;  // mysql_kill
-	const COM_DEBUG               = 0x0d;  // mysql_dump_debug_info
-	const COM_PING                = 0x0e;  // mysql_ping
-	const COM_TIME                = 0x0f;  // (none, this is an internal thread state)
-	const COM_DELAYED_INSERT      = 0x10;  // (none, this is an internal thread state)
-	const COM_CHANGE_USER         = 0x11;  // mysql_change_user
-	const COM_BINLOG_DUMP         = 0x12;  // sent by the slave IO thread to request a binlog
-	const COM_TABLE_DUMP          = 0x13;  // LOAD TABLE ... FROM MASTER (deprecated)
-	const COM_CONNECT_OUT         = 0x14;  // (none, this is an internal thread state)
-	const COM_REGISTER_SLAVE      = 0x15;  // sent by the slave to register with the master (optional)
-	const COM_STMT_PREPARE        = 0x16;  // mysql_stmt_prepare
-	const COM_STMT_EXECUTE        = 0x17;  // mysql_stmt_execute
-	const COM_STMT_SEND_LONG_DATA = 0x18;  // mysql_stmt_send_long_data
-	const COM_STMT_CLOSE          = 0x19;  // mysql_stmt_close
-	const COM_STMT_RESET          = 0x1a;  // mysql_stmt_reset
-	const COM_SET_OPTION          = 0x1b;  // mysql_set_server_option
-	const COM_STMT_FETCH          = 0x1c;  // mysql_stmt_fetch
+	const COM_SLEEP               = 0x00; // (none, this is an internal thread state)
+	const COM_QUIT                = 0x01; // mysql_close
+	const COM_INIT_DB             = 0x02; // mysql_select_db
+	const COM_QUERY               = 0x03; // mysql_real_query
+	const COM_FIELD_LIST          = 0x04; // mysql_list_fields
+	const COM_CREATE_DB           = 0x05; // mysql_create_db (deprecated)
+	const COM_DROP_DB             = 0x06; // mysql_drop_db (deprecated)
+	const COM_REFRESH             = 0x07; // mysql_refresh
+	const COM_SHUTDOWN            = 0x08; // mysql_shutdown
+	const COM_STATISTICS          = 0x09; // mysql_stat
+	const COM_PROCESS_INFO        = 0x0a; // mysql_list_processes
+	const COM_CONNECT             = 0x0b; // (none, this is an internal thread state)
+	const COM_PROCESS_KILL        = 0x0c; // mysql_kill
+	const COM_DEBUG               = 0x0d; // mysql_dump_debug_info
+	const COM_PING                = 0x0e; // mysql_ping
+	const COM_TIME                = 0x0f; // (none, this is an internal thread state)
+	const COM_DELAYED_INSERT      = 0x10; // (none, this is an internal thread state)
+	const COM_CHANGE_USER         = 0x11; // mysql_change_user
+	const COM_BINLOG_DUMP         = 0x12; // sent by the slave IO thread to request a binlog
+	const COM_TABLE_DUMP          = 0x13; // LOAD TABLE ... FROM MASTER (deprecated)
+	const COM_CONNECT_OUT         = 0x14; // (none, this is an internal thread state)
+	const COM_REGISTER_SLAVE      = 0x15; // sent by the slave to register with the master (optional)
+	const COM_STMT_PREPARE        = 0x16; // mysql_stmt_prepare
+	const COM_STMT_EXECUTE        = 0x17; // mysql_stmt_execute
+	const COM_STMT_SEND_LONG_DATA = 0x18; // mysql_stmt_send_long_data
+	const COM_STMT_CLOSE          = 0x19; // mysql_stmt_close
+	const COM_STMT_RESET          = 0x1a; // mysql_stmt_reset
+	const COM_SET_OPTION          = 0x1b; // mysql_set_server_option
+	const COM_STMT_FETCH          = 0x1c; // mysql_stmt_fetch
 
 	const FIELD_TYPE_DECIMAL      = 0x00;
 	const FIELD_TYPE_TINY         = 0x01;