TickLoop thread

src/classes/PocketMinecraftServer.class.php

@@ -27,7 +27,7 @@ the Free Software Foundation, either version 3 of the License, or
 
 class PocketMinecraftServer{
 	var $invisible, $api, $tickMeasure, $preparedSQL, $seed, $gamemode, $name, $maxClients, $clients, $eidCnt, $custom, $description, $motd, $timePerSecond, $responses, $spawn, $entities, $mapDir, $mapName, $map, $level, $tileEntities;
-	private $database, $interface, $evCnt, $handCnt, $events, $handlers, $version, $serverType, $lastTick;
+	private $database, $interface, $evCnt, $handCnt, $events, $handlers, $version, $serverType, $lastTick, $ticker;
 	function __construct($name, $gamemode = 1, $seed = false, $port = 19132, $serverID = false){
 		$this->port = (int) $port; //19132 - 19135
 		$vNumber = new VersionString();
@@ -79,6 +79,10 @@ class PocketMinecraftServer{
 		console("[INFO] Protocol Version: ".CURRENT_PROTOCOL);
 		$this->stop = false;
 	}
+	
+	public function run(){
+	
+	}
 
 	public function getTPS(){
 		$v = array_values($this->tickMeasure);
@@ -157,6 +161,7 @@ class PocketMinecraftServer{
 	public function close($reason = "stop"){
 		if($this->stop !== true){
 			$this->chat(false, "Stopping server...");
+			$this->ticker->stop = true;
 			$this->save(true);
 			$this->stop = true;
 			$this->trigger("server.close", $reason);
@@ -317,6 +322,8 @@ class PocketMinecraftServer{
 		}
 		console("[INFO] Loading events...");
 		$this->loadEvents();
+		$this->ticker = new TickLoop;
+		$this->ticker->start();
 		declare(ticks=15);
 		register_tick_function(array($this, "tick"));
 		register_shutdown_function(array($this, "dumpError"));
@@ -347,12 +354,13 @@ class PocketMinecraftServer{
 	}
 
 	public function tick(){
-		$time = microtime(true);
-		if($this->lastTick <= ($time - 0.05)){
+		if($this->ticker->isWaiting() === true){
+			$time = microtime(true);
 			array_shift($this->tickMeasure);
 			$this->tickMeasure[] = $this->lastTick = $time;
 			$this->tickerFunction($time);
 			$this->trigger("server.tick", $time);
+			$this->ticker->notify();
 		}
 	}
 

src/classes/UDPSocket.class.php

@@ -27,10 +27,9 @@ the Free Software Foundation, either version 3 of the License, or
 
 
 
-class UDPSocket{
+class UDPSocket extends Thread{
 	private $encrypt;
 	var $buffer, $connected, $errors, $sock, $server;
-
 	function __construct($server, $port, $listen = false, $socket = false){
 		$this->errors = array_fill(88,(125 - 88) + 1, true);
 		$this->server = $server;
@@ -57,8 +56,12 @@ class UDPSocket{
 			}
 		}
 	}
+	
+	public function run(){
+	
+	}
 
-	function listenSocket(){
+	public function listenSocket(){
 		$sock = @socket_accept($this->sock);
 		if($sock !== false){
 			$sock = new Socket(false, false, false, $sock);

src/classes/Utils.class.php

@@ -35,7 +35,7 @@ define("BIG_ENDIAN", 0x00);
 define("LITTLE_ENDIAN", 0x01);
 define("ENDIANNESS", (pack("d", 1) === "\77\360\0\0\0\0\0\0" ? BIG_ENDIAN:LITTLE_ENDIAN));
 
-abstract class Utils{
+class Utils{
 
 	public static function getOS(){
 		$uname = strtoupper(php_uname("s"));

src/misc/utils/TickLoop.php

@@ -0,0 +1,40 @@
+<?php
+
+/*
+
+           -
+         /   \
+      /         \
+   /   PocketMine  \
+/          MP         \
+|\     @shoghicp     /|
+|.   \           /   .|
+| ..     \   /     .. |
+|    ..    |    ..    |
+|       .. | ..       |
+\          |          /
+   \       |       /
+      \    |    /
+         \ | /
+
+This program is free software: you can redistribute it and/or modify
+it under the terms of the GNU Lesser General Public License as published by
+the Free Software Foundation, either version 3 of the License, or
+(at your option) any later version.
+
+
+*/
+
+class TickLoop extends Thread{
+	var $stop = false, $lastTick = 0;
+	public function run(){
+		while($this->stop !== true){
+			$time = microtime(true);
+			if($this->lastTick <= ($time - 0.05)){
+				$this->lastTick = $time;
+				$this->wait();
+			}
+		}
+		exit(0);
+	}
+}