diff --git a/socket.php b/socket.php index 1c2475c0..fd349ea2 100644 --- a/socket.php +++ b/socket.php @@ -1,4 +1,3 @@ settings = $settings; } - public function start() { + + public function start() + { pcntl_signal(SIGTERM, [$this, 'sig_handler']); pcntl_signal(SIGINT, [$this, 'sig_handler']); pcntl_signal(SIGCHLD, [$this, 'sig_handler']); @@ -36,26 +40,30 @@ class Server $this->handle($this->sock->accept()); } } - private function handle($socket) { + + private function handle($socket) + { $pid = pcntl_fork(); if ($pid == -1) { - die('could not fork'); - } else if ($pid) { + die('could not fork'); + } elseif ($pid) { return $this->pids[] = $pid; } $handler = new \danog\MadelineProto\Server\Handler($socket); $handler->loop(); die; } - public function __destruct() { + + public function __destruct() + { foreach ($this->pid as $pid) { pcntl_wait($pid); } } + public function sig_handler($sig) { - switch($sig) - { + switch ($sig) { case SIGTERM: case SIGINT: exit(); diff --git a/src/danog/MadelineProto/Server/Handler.php b/src/danog/MadelineProto/Server/Handler.php index 57b55970..49dc20a7 100644 --- a/src/danog/MadelineProto/Server/Handler.php +++ b/src/danog/MadelineProto/Server/Handler.php @@ -19,16 +19,21 @@ namespace danog\MadelineProto\Server; class Handler { private $socket; - public function __construct($socket) { + + public function __construct($socket) + { $this->socket = $socket; } - public function loop() { + public function loop() + { } - public function read_payload() { - + + public function read_payload() + { } - public function write_payload($payload) { - + + public function write_payload($payload) + { } -} \ No newline at end of file +}