RakLibServer Class Reference

Public Member Functions
	__construct (\ThreadedLogger $logger, \ClassLoader $loader, $port, $interface="0.0.0.0")
	isShutdown ()
	shutdown ()
	getPort ()
	getInterface ()
	getLogger ()
	getExternalQueue ()
	getInternalQueue ()
	pushMainToThreadPacket ($str)
	readMainToThreadPacket ()
	pushThreadToMainPacket ($str)
	readThreadToMainPacket ()
	shutdownHandler ()
	errorHandler ($errno, $errstr, $errfile, $errline, $context, $trace=null)
	getTrace ($start=1, $trace=null)
	cleanPath ($path)
	run ()
Public Member Functions inherited from Thread
	getCreatorId ()
	getThreadId ()
	isJoined ()
	isStarted ()
	join ()
	start (int $options=PTHREADS_INHERIT_ALL)
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
	$loadPaths

Protected Member Functions
	addDependency (array &$loadPaths, \ReflectionClass $dep)

Protected Attributes
	$port
	$interface
	$logger
	$loader
	$shutdown
	$externalQueue
	$internalQueue
	$mainPath

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

Constructor & Destructor Documentation

__construct()

__construct	(	\ThreadedLogger	$logger,
		\ClassLoader	$loader,
			$port,
			$interface = "0.0.0.0"
	)

Parameters

\ThreadedLogger	$logger
\ClassLoader	$loader
int	$port
string	$interface

Exceptions

                                                                                                             {
        $this->port = (int) $port;
        if($port < 1 or $port > 65536){
            throw new \Exception("Invalid port range");
        }

        $this->interface = $interface;
        $this->logger = $logger;
        $this->loader = $loader;
        $loadPaths = [];
        $this->addDependency($loadPaths, new \ReflectionClass($logger));
        $this->addDependency($loadPaths, new \ReflectionClass($loader));
        $this->loadPaths = array_reverse($loadPaths);
        $this->shutdown = false;

        $this->externalQueue = new \Threaded;
        $this->internalQueue = new \Threaded;

        if(\Phar::running(true) !== ""){
            $this->mainPath = \Phar::running(true);
        }else{
            $this->mainPath = \getcwd() . DIRECTORY_SEPARATOR;
        }
        $this->start();
    }

Member Function Documentation

addDependency()

addDependency ( array &  $loadPaths, \ReflectionClass  $dep  )

protected

                                                                              {
        if($dep->getFileName() !== false){
            $loadPaths[$dep->getName()] = $dep->getFileName();
        }

        if($dep->getParentClass() instanceof \ReflectionClass){
            $this->addDependency($loadPaths, $dep->getParentClass());
        }

        foreach($dep->getInterfaces() as $interface){
            $this->addDependency($loadPaths, $interface);
        }
    }

cleanPath()

cleanPath

(

$path

)

                                    {
        return rtrim(str_replace(["\\", ".php", "phar://", rtrim(str_replace(["\\", "phar://"], ["/", ""], $this->mainPath), "/")], ["/", "", "", ""], $path), "/");
    }

errorHandler()

errorHandler	(		$errno,
			$errstr,
			$errfile,
			$errline,
			$context,
			$trace = null
	)

                                                                                              {
        if(error_reporting() === 0){
            return false;
        }
        $errorConversion = [
            E_ERROR => "E_ERROR",
            E_WARNING => "E_WARNING",
            E_PARSE => "E_PARSE",
            E_NOTICE => "E_NOTICE",
            E_CORE_ERROR => "E_CORE_ERROR",
            E_CORE_WARNING => "E_CORE_WARNING",
            E_COMPILE_ERROR => "E_COMPILE_ERROR",
            E_COMPILE_WARNING => "E_COMPILE_WARNING",
            E_USER_ERROR => "E_USER_ERROR",
            E_USER_WARNING => "E_USER_WARNING",
            E_USER_NOTICE => "E_USER_NOTICE",
            E_STRICT => "E_STRICT",
            E_RECOVERABLE_ERROR => "E_RECOVERABLE_ERROR",
            E_DEPRECATED => "E_DEPRECATED",
            E_USER_DEPRECATED => "E_USER_DEPRECATED",
        ];
        $errno = isset($errorConversion[$errno]) ? $errorConversion[$errno] : $errno;
        if(($pos = strpos($errstr, "\n")) !== false){
            $errstr = substr($errstr, 0, $pos);
        }

        $errfile = $this->cleanPath($errfile);

        $this->getLogger()->debug("An $errno error happened: \"$errstr\" in \"$errfile\" at line $errline");

        foreach(($trace = $this->getTrace($trace === null ? 3 : 0, $trace)) as $i => $line){
            $this->getLogger()->debug($line);
        }

        return true;
    }

getExternalQueue()

getExternalQueue

(

)

Returns

                                      {
        return $this->externalQueue;
    }

getInterface()

getInterface

(

)

                                  {
        return $this->interface;
    }

getInternalQueue()

getInternalQueue

(

)

Returns

                                      {
        return $this->internalQueue;
    }

getLogger()

getLogger

(

)

Returns

                               {
        return $this->logger;
    }

getPort()

getPort

(

)

                             {
        return $this->port;
    }

getTrace()

getTrace	(		$start = 1,
			$trace = null
	)

                                                       {
        if($trace === null){
            if(function_exists("xdebug_get_function_stack")){
                $trace = array_reverse(xdebug_get_function_stack());
            }else{
                $e = new \Exception();
                $trace = $e->getTrace();
            }
        }

        $messages = [];
        $j = 0;
        for($i = (int) $start; isset($trace[$i]); ++$i, ++$j){
            $params = "";
            if(isset($trace[$i]["args"]) or isset($trace[$i]["params"])){
                if(isset($trace[$i]["args"])){
                    $args = $trace[$i]["args"];
                }else{
                    $args = $trace[$i]["params"];
                }
                foreach($args as $name => $value){
                    $params .= (is_object($value) ? get_class($value) . " " . (method_exists($value, "__toString") ? $value->__toString() : "object") : gettype($value) . " " . @strval($value)) . ", ";
                }
            }
            $messages[] = "#$j " . (isset($trace[$i]["file"]) ? $this->cleanPath($trace[$i]["file"]) : "") . "(" . (isset($trace[$i]["line"]) ? $trace[$i]["line"] : "") . "): " . (isset($trace[$i]["class"]) ? $trace[$i]["class"] . (($trace[$i]["type"] === "dynamic" or $trace[$i]["type"] === "->") ? "->" : "::") : "") . $trace[$i]["function"] . "(" . substr($params, 0, -2) . ")";
        }

        return $messages;
    }

isShutdown()

isShutdown

(

)

                                {
        return $this->shutdown === true;
    }

pushMainToThreadPacket()

pushMainToThreadPacket

(

$str

)

                                                {
        $this->internalQueue[] = $str;
    }

pushThreadToMainPacket()

pushThreadToMainPacket

(

$str

)

                                                {
        $this->externalQueue[] = $str;
    }

readMainToThreadPacket()

readMainToThreadPacket

(

)

                                            {
        return $this->internalQueue->shift();
    }

readThreadToMainPacket()

readThreadToMainPacket

(

)

                                            {
        return $this->externalQueue->shift();
    }

run()

run

(

)

                         {
        try{
            //Load removed dependencies, can't use require_once()
            foreach($this->loadPaths as $name => $path){
                if(!class_exists($name, false) and !interface_exists($name, false)){
                    require($path);
                }
            }
            $this->loader->register(true);

            gc_enable();
            error_reporting(-1);
            ini_set("display_errors", 1);
            ini_set("display_startup_errors", 1);

            set_error_handler([$this, "errorHandler"], E_ALL);
            register_shutdown_function([$this, "shutdownHandler"]);


            $socket = new UDPServerSocket($this->getLogger(), $this->port, $this->interface);
            new SessionManager($this, $socket);
        }catch(\Throwable $e){
            $this->logger->logException($e);
        }
    }

shutdown()

shutdown

(

)

                              {
        $this->shutdown = true;
    }

shutdownHandler()

shutdownHandler

(

)

                                     {
        if($this->shutdown !== true){
            $this->getLogger()->emergency("RakLib crashed!");
        }
    }

Field Documentation

$externalQueue

$externalQueue

protected

$interface

$interface

protected

$internalQueue

$internalQueue

protected

$loader

$loader

protected

$loadPaths

$loadPaths

$logger

$logger

protected

$mainPath

$mainPath

protected

$port

$port

protected

$shutdown

$shutdown

protected

---

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

• src/raklib/server/RakLibServer.php