DServerTask Class Reference

Public Member Functions
	__construct ($data, $autotimes=5)
	onRun ()
	getInfo ($ds, $time=1)
	onCompletion (Server $server)
	decode ($buffer)
Public Member Functions inherited from AsyncTask
	isGarbage ()
	setGarbage ()
	isFinished ()
	run ()
	isCrashed ()
	getResult ()
	cancelRun ()
	hasCancelledRun ()
	hasResult ()
	setResult ($result, $serialize=true)
	setTaskId ($taskId)
	getTaskId ()
	getFromThreadStore ($identifier)
	saveToThreadStore ($identifier, $value)
	onRun ()
	onCompletion (Server $server)
	cleanObject ()
Public Member Functions inherited from Threaded
	chunk ($size, bool $preserve=false)
	count ()
	isRunning ()
	isTerminated ()
	merge ($from, $overwrite=true)
	notify ()
	notifyOne ()
	offsetGet ($offset)
	offsetSet ($offset, $value)
	offsetExists ($offset)
	offsetUnset ($offset)
	pop ()
	run ()
	shift ()
	synchronized (\Closure $function, $args=null)
	wait ($timeout)
	getRefCount ()
	addRef ()
	delRef ()
	isGarbage ()

Data Fields
	$data
	$autotimes
	$re
Data Fields inherited from AsyncTask
	$worker = null

Additional Inherited Members
Static Public Member Functions inherited from Threaded
static	extend ($obj)

Constructor & Destructor Documentation

__construct()

__construct	(		$data,
			$autotimes = 5
	)

DServerTask constructor.

Parameters

	$data
int	$autotimes

                                                      {
        $this->data = $data;
        $this->autotimes = $autotimes;
    }

Member Function Documentation

decode()

decode

(

$buffer

)

Parameters

$buffer

Returns

array

                                   {
        $redata = [];
        $redata["packetType"] = ord($buffer{0});
        $redata["sessionID"] = unpack("N", substr($buffer, 1, 4))[1];
        $redata["payload"] = rtrim(substr($buffer, 5));
        return $redata;
    }

getInfo()

getInfo	(		$ds,
			$time = 1
	)

Parameters

	$ds
int	$time

Returns

array

                                           {
        $tmp = explode(":", $ds);
        $ip = $tmp[0];
        $port = $tmp[1];
        $client = stream_socket_client("udp://" . $ip . ":" . $port, $errno, $errstr);    //非阻塞Socket
        if($client){
            stream_set_timeout($client, 1);
            $Handshake_to = "\xFE\xFD" . chr(9) . pack("N", 233);
            fwrite($client, $Handshake_to);
            $Handshake_re_1 = fread($client, 65535);
            if($Handshake_re_1 != ""){
                $Handshake_re = $this->decode($Handshake_re_1);
                $Status_to = "\xFE\xFD" . chr(0) . pack("N", 233) . pack("N", $Handshake_re["payload"]);
                fwrite($client, $Status_to);
                $Status_re_1 = fread($client, 65535);
                if($Status_re_1 != ""){
                    $Status_re = $this->decode($Status_re_1);
                    $ServerData = explode("\x00", $Status_re["payload"]);
                    return [$ServerData[3], $ServerData[4]];
                }
            }
            fclose($client);
        }
        if($time < $this->autotimes){
            return $this->getInfo($ds, $time + 1);
        }elseif($time = $this->autotimes) return [0, 0];
        return [0, 0];
    }

onCompletion()

onCompletion

(

Server

$server

)

Parameters

Server

$server

                                                {
        $re = $this->re;
        if($re[0] > 0) $server->dserverPlayers = $re[0];
        if($re[1] > 0) $server->dserverAllPlayers = $re[1];
        //$server->getNetwork()->updateName();
    }

onRun()

onRun

(

)

                           {
        $re = [0, 0];
        foreach($this->data as $d){
            $data = $this->getInfo($d);
            $re[0] = $re[0] + $data[0];
            $re[1] = $re[1] + $data[1];
        }
        $this->re = (array) $re;
    }

Field Documentation

$autotimes

$autotimes

$data

$data

$re

$re

---

The documentation for this class was generated from the following file:

• src/pocketmine/scheduler/DServerTask.php