mirrors/PocketMine-MP
1
0
Fork 0
mirror of https://github.com/pmmp/PocketMine-MP.git synced 2025-10-16 19:59:11 +00:00
Code Issues Projects Releases Wiki Activity

It staaaarts!

Browse Source
This commit is contained in:
Shoghi Cervantes
2014-03-06 20:41:04 +01:00
parent 56d3b89f57
commit 331a26931f
183 changed files with 1220 additions and 1192 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
src/utils/Utils.php
View File

@@ -659,4 +659,4 @@ class Utils{
}
define('Utils\ENDIANNESS', (pack("d", 1) === "\77\360\0\0\0\0\0\0" ? Utils::BIG_ENDIAN : Utils::LITTLE_ENDIAN));
define("PocketMine\\Utils\\ENDIANNESS", (pack("d", 1) === "\77\360\0\0\0\0\0\0" ? Utils::BIG_ENDIAN : Utils::LITTLE_ENDIAN));

32
src/utils/pthreads.php
View File

@@ -74,36 +74,36 @@ class AsyncMultipleQueue extends Thread{
public function run(){
while($this->stop === false){
if(isset($this->input{5})){ //len 6 min
$rID = Utils::readInt($this->get(4));
switch(Utils::readShort($this->get(2), false)){
$rID = \PocketMine\Utils\Utils::readInt($this->get(4));
switch(\PocketMine\Utils\Utils::readShort($this->get(2), false)){
case ASYNC_CURL_GET:
$url = $this->get(Utils::readShort($this->get(2), false));
$timeout = Utils::readShort($this->get(2));
$url = $this->get(\PocketMine\Utils\Utils::readShort($this->get(2), false));
$timeout = \PocketMine\Utils\Utils::readShort($this->get(2));
$res = (string) Utils::curl_get($url, $timeout);
$res = (string) \PocketMine\Utils\Utils::curl_get($url, $timeout);
$this->lock();
$this->output .= Utils::writeInt($rID) . Utils::writeShort(ASYNC_CURL_GET) . Utils::writeInt(strlen($res)) . $res;
$this->output .= \PocketMine\Utils\Utils::writeInt($rID) . \PocketMine\Utils\Utils::writeShort(ASYNC_CURL_GET) . \PocketMine\Utils\Utils::writeInt(strlen($res)) . $res;
$this->unlock();
break;
case ASYNC_CURL_POST:
$url = $this->get(Utils::readShort($this->get(2), false));
$timeout = Utils::readShort($this->get(2));
$cnt = Utils::readShort($this->get(2), false);
$url = $this->get(\PocketMine\Utils\Utils::readShort($this->get(2), false));
$timeout = \PocketMine\Utils\Utils::readShort($this->get(2));
$cnt = \PocketMine\Utils\Utils::readShort($this->get(2), false);
$d = array();
for($c = 0; $c < $cnt; ++$c){
$key = $this->get(Utils::readShort($this->get(2), false));
$d[$key] = $this->get(Utils::readInt($this->get(4)));
$key = $this->get(\PocketMine\Utils\Utils::readShort($this->get(2), false));
$d[$key] = $this->get(\PocketMine\Utils\Utils::readInt($this->get(4)));
}
$res = (string) Utils::curl_post($url, $d, $timeout);
$res = (string) \PocketMine\Utils\Utils::curl_post($url, $d, $timeout);
$this->lock();
$this->output .= Utils::writeInt($rID) . Utils::writeShort(ASYNC_CURL_POST) . Utils::writeInt(strlen($res)) . $res;
$this->output .= \PocketMine\Utils\Utils::writeInt($rID) . \PocketMine\Utils\Utils::writeShort(ASYNC_CURL_POST) . \PocketMine\Utils\Utils::writeInt(strlen($res)) . $res;
$this->unlock();
break;
case ASYNC_FUNCTION:
$function = $this->get(Utils::readShort($this->get(2), false));
$params = unserialize($this->get(Utils::readInt($this->get(4))));
$function = $this->get(\PocketMine\Utils\Utils::readShort($this->get(2), false));
$params = unserialize($this->get(\PocketMine\Utils\Utils::readInt($this->get(4))));
$res = serialize(@call_user_func_array($function, $params));
$this->output .= Utils::writeInt($rID) . Utils::writeShort(ASYNC_FUNCTION) . Utils::writeInt(strlen($res)) . $res;
$this->output .= \PocketMine\Utils\Utils::writeInt($rID) . \PocketMine\Utils\Utils::writeShort(ASYNC_FUNCTION) . \PocketMine\Utils\Utils::writeInt(strlen($res)) . $res;
break;
}
}