ServerHandler Class Reference

Public Member Functions
	__construct (RakLibServer $server, ServerInstance $instance)
	sendEncapsulated ($identifier, EncapsulatedPacket $packet, $flags=RakLib::PRIORITY_NORMAL)
	sendRaw ($address, $port, $payload)
	closeSession ($identifier, $reason)
	sendOption ($name, $value)
	blockAddress ($address, $timeout)
	unblockAddress ($address)
	shutdown ()
	emergencyShutdown ()
	handlePacket ()

Protected Member Functions
	invalidSession ($identifier)

Protected Attributes
	$server
	$instance

Constructor & Destructor Documentation

__construct()

__construct	(	RakLibServer	$server,
		ServerInstance	$instance
	)

                                                                               {
        $this->server = $server;
        $this->instance = $instance;
    }

Member Function Documentation

blockAddress()

blockAddress	(		$address,
			$timeout
	)

                                                    {
        $buffer = chr(RakLib::PACKET_BLOCK_ADDRESS) . chr(strlen($address)) . $address . Binary::writeInt($timeout);
        $this->server->pushMainToThreadPacket($buffer);
    }

closeSession()

closeSession	(		$identifier,
			$reason
	)

                                                      {
        $buffer = chr(RakLib::PACKET_CLOSE_SESSION) . chr(strlen($identifier)) . $identifier . chr(strlen($reason)) . $reason;
        $this->server->pushMainToThreadPacket($buffer);
    }

emergencyShutdown()

emergencyShutdown

(

)

                                       {
        $this->server->shutdown();
        $this->server->pushMainToThreadPacket("\x7f"); //RakLib::PACKET_EMERGENCY_SHUTDOWN
    }

handlePacket()

handlePacket

(

)

Returns

bool

                                  {
        if(strlen($packet = $this->server->readThreadToMainPacket()) > 0){
            $id = ord($packet{0});
            $offset = 1;
            if($id === RakLib::PACKET_ENCAPSULATED){
                $len = ord($packet{$offset++});
                $identifier = substr($packet, $offset, $len);
                $offset += $len;
                $flags = ord($packet{$offset++});
                $buffer = substr($packet, $offset);
                $this->instance->handleEncapsulated($identifier, EncapsulatedPacket::fromBinary($buffer, true), $flags);
            }elseif($id === RakLib::PACKET_RAW){
                $len = ord($packet{$offset++});
                $address = substr($packet, $offset, $len);
                $offset += $len;
                $port = Binary::readShort(substr($packet, $offset, 2));
                $offset += 2;
                $payload = substr($packet, $offset);
                $this->instance->handleRaw($address, $port, $payload);
            }elseif($id === RakLib::PACKET_SET_OPTION){
                $len = ord($packet{$offset++});
                $name = substr($packet, $offset, $len);
                $offset += $len;
                $value = substr($packet, $offset);
                $this->instance->handleOption($name, $value);
            }elseif($id === RakLib::PACKET_OPEN_SESSION){
                $len = ord($packet{$offset++});
                $identifier = substr($packet, $offset, $len);
                $offset += $len;
                $len = ord($packet{$offset++});
                $address = substr($packet, $offset, $len);
                $offset += $len;
                $port = Binary::readShort(substr($packet, $offset, 2));
                $offset += 2;
                $clientID = Binary::readLong(substr($packet, $offset, 8));
                $this->instance->openSession($identifier, $address, $port, $clientID);
            }elseif($id === RakLib::PACKET_CLOSE_SESSION){
                $len = ord($packet{$offset++});
                $identifier = substr($packet, $offset, $len);
                $offset += $len;
                $len = ord($packet{$offset++});
                $reason = substr($packet, $offset, $len);
                $this->instance->closeSession($identifier, $reason);
            }elseif($id === RakLib::PACKET_INVALID_SESSION){
                $len = ord($packet{$offset++});
                $identifier = substr($packet, $offset, $len);
                $this->instance->closeSession($identifier, "Invalid session");
            }elseif($id === RakLib::PACKET_ACK_NOTIFICATION){
                $len = ord($packet{$offset++});
                $identifier = substr($packet, $offset, $len);
                $offset += $len;
                $identifierACK = Binary::readInt(substr($packet, $offset, 4));
                $this->instance->notifyACK($identifier, $identifierACK);
            }

            return true;
        }

        return false;
    }

invalidSession()

invalidSession (   $identifier )

protected

                                                  {
        $buffer = chr(RakLib::PACKET_INVALID_SESSION) . chr(strlen($identifier)) . $identifier;
        $this->server->pushMainToThreadPacket($buffer);
    }

sendEncapsulated()

sendEncapsulated	(		$identifier,
		EncapsulatedPacket	$packet,
			$flags = RakLib::PRIORITY_NORMAL
	)

                                                                                                             {
        $buffer = chr(RakLib::PACKET_ENCAPSULATED) . chr(strlen($identifier)) . $identifier . chr($flags) . $packet->toBinary(true);
        $this->server->pushMainToThreadPacket($buffer);
    }

sendOption()

sendOption	(		$name,
			$value
	)

                                             {
        $buffer = chr(RakLib::PACKET_SET_OPTION) . chr(strlen($name)) . $name . $value;
        $this->server->pushMainToThreadPacket($buffer);
    }

sendRaw()

sendRaw	(		$address,
			$port,
			$payload
	)

                                                      {
        $buffer = chr(RakLib::PACKET_RAW) . chr(strlen($address)) . $address . Binary::writeShort($port) . $payload;
        $this->server->pushMainToThreadPacket($buffer);
    }

shutdown()

shutdown

(

)

                              {
        $buffer = chr(RakLib::PACKET_SHUTDOWN);
        $this->server->pushMainToThreadPacket($buffer);
        $this->server->shutdown();
        $this->server->synchronized(function(){
            if($this->server !== null){
                $this->server->wait(20000);
            }
        });
        $this->server->join();
    }

unblockAddress()

unblockAddress

(

$address

)

                                            {
        $buffer = chr(RakLib::PACKET_UNBLOCK_ADDRESS) . chr(strlen($address)) . $address;
        $this->server->pushMainToThreadPacket($buffer);
    }

Field Documentation

$instance

$instance

protected

$server

$server

protected

---

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

• src/raklib/server/ServerHandler.php