mirrors/PocketMine-MP
1
0
Fork 0
mirror of https://github.com/pmmp/PocketMine-MP.git synced 2025-06-07 12:18:46 +00:00
Code Issues Projects Releases Wiki Activity

RCON: set SO_REUSEADDR to fix RCON start failure after restart (#3357)

Browse Source
This commit is contained in:
marshall 2020-03-16 20:00:45 +08:00 committed by GitHub
parent f84abcd1fe
commit 310de5a2b2
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 7 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
src/pocketmine/network/rcon/RCON.php
View File

@ -41,14 +41,17 @@ use function socket_getsockname;
use function socket_last_error; use function socket_last_error;
use function socket_listen; use function socket_listen;
use function socket_set_block; use function socket_set_block;
use function socket_set_option;
use function socket_strerror; use function socket_strerror;
use function socket_write; use function socket_write;
use function trim; use function trim;
use const AF_INET; use const AF_INET;
use const AF_UNIX; use const AF_UNIX;
use const SO_REUSEADDR;
use const SOCK_STREAM; use const SOCK_STREAM;
use const SOCKET_ENOPROTOOPT; use const SOCKET_ENOPROTOOPT;
use const SOCKET_EPROTONOSUPPORT; use const SOCKET_EPROTONOSUPPORT;
use const SOL_SOCKET;
use const SOL_TCP; use const SOL_TCP;
class RCON{ class RCON{
@ -74,6 +77,10 @@ class RCON{
$this->socket = socket_create(AF_INET, SOCK_STREAM, SOL_TCP); $this->socket = socket_create(AF_INET, SOCK_STREAM, SOL_TCP);
if(!socket_set_option($this->socket, SOL_SOCKET, SO_REUSEADDR, 1)){
throw new \RuntimeException("Unable to set option on socket: " . trim(socket_strerror(socket_last_error())));
}
if($this->socket === false or !@socket_bind($this->socket, $interface, $port) or !@socket_listen($this->socket, 5)){ if($this->socket === false or !@socket_bind($this->socket, $interface, $port) or !@socket_listen($this->socket, 5)){
throw new \RuntimeException(trim(socket_strerror(socket_last_error()))); throw new \RuntimeException(trim(socket_strerror(socket_last_error())));
} }