RakLibServer.php

<?php
 
/*
 *
 *  ____            _        _   __  __ _                  __  __ ____
 * |  _ \ ___   ___| | _____| |_|  \/  (_)_ __   ___      |  \/  |  _ \
 * | |_) / _ \ / __| |/ / _ \ __| |\/| | | '_ \ / _ \_____| |\/| | |_) |
 * |  __/ (_) | (__|   <  __/ |_| |  | | | | | |  __/_____| |  | |  __/
 * |_|   \___/ \___|_|\_\___|\__|_|  |_|_|_| |_|\___|     |_|  |_|_|
 *
 * 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.
 *
 * @author PocketMine Team
 * @link http://www.pocketmine.net/
 *
 *
 */
 
declare(strict_types=1);
 
namespace pocketmine\network\mcpe\raklib;
 
use pmmp\thread\Thread as NativeThread;
use pmmp\thread\ThreadSafeArray;
use pocketmine\snooze\SleeperHandlerEntry;
use pocketmine\thread\log\ThreadSafeLogger;
use pocketmine\thread\NonThreadSafeValue;
use pocketmine\thread\Thread;
use pocketmine\thread\ThreadCrashException;
use raklib\generic\SocketException;
use raklib\server\ipc\RakLibToUserThreadMessageSender;
use raklib\server\ipc\UserToRakLibThreadMessageReceiver;
use raklib\server\Server;
use raklib\server\ServerSocket;
use raklib\server\SimpleProtocolAcceptor;
use raklib\utils\ExceptionTraceCleaner;
use raklib\utils\InternetAddress;
use function gc_enable;
use function ini_set;
 
class RakLibServer extends Thread{
    protected bool $ready = false;
    protected string $mainPath;
    protected NonThreadSafeValue $address;
 
    public function __construct(
        protected ThreadSafeLogger $logger,
        protected ThreadSafeArray $mainToThreadBuffer,
        protected ThreadSafeArray $threadToMainBuffer,
        InternetAddress $address,
        protected int $serverId,
        protected int $maxMtuSize,
        protected int $protocolVersion,
        protected SleeperHandlerEntry $sleeperEntry
    ){
        $this->mainPath = \pocketmine\PATH;
        $this->address = new NonThreadSafeValue($address);
    }
 
    public function startAndWait(int $options = NativeThread::INHERIT_NONE) : void{
        $this->start($options);
        $this->synchronized(function() : void{
            while(!$this->ready && $this->getCrashInfo() === null){
                $this->wait();
            }
            $crashInfo = $this->getCrashInfo();
            if($crashInfo !== null){
                if($crashInfo->getType() === SocketException::class){
                    throw new SocketException($crashInfo->getMessage());
                }
                throw new ThreadCrashException("RakLib failed to start", $crashInfo);
            }
        });
    }
 
    protected function onRun() : void{
        gc_enable();
        ini_set("display_errors", '1');
        ini_set("display_startup_errors", '1');
        \GlobalLogger::set($this->logger);
 
        $socket = new ServerSocket($this->address->deserialize());
        $manager = new Server(
            $this->serverId,
            $this->logger,
            $socket,
            $this->maxMtuSize,
            new SimpleProtocolAcceptor($this->protocolVersion),
            new UserToRakLibThreadMessageReceiver(new PthreadsChannelReader($this->mainToThreadBuffer)),
            new RakLibToUserThreadMessageSender(new SnoozeAwarePthreadsChannelWriter($this->threadToMainBuffer, $this->sleeperEntry->createNotifier())),
            new ExceptionTraceCleaner($this->mainPath),
            recvMaxSplitParts: 512
        );
        $this->synchronized(function() : void{
            $this->ready = true;
            $this->notify();
        });
        while(!$this->isKilled){
            $manager->tickProcessor();
        }
        $manager->waitShutdown();
    }
 
    public function getThreadName() : string{
        return "RakLib";
    }
}