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

Add buffering for non-immediate priority packets to reduce compression overhead

Browse Source
This commit is contained in:
Dylan K. Taylor 2017-09-27 14:06:42 +01:00
parent 8f63117dac
commit 2162675b64
1 changed files with 10 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
src/pocketmine/Player.php
View File

@ -1067,6 +1067,10 @@ class Player extends Human implements CommandSender, ChunkLoader, IPlayer{
return false; return false;
} }
if(!$packet->canBeBatched()){
throw new \InvalidArgumentException(get_class($packet) . " cannot be added to batch buffer");
}
$timings = Timings::getSendDataPacketTimings($packet); $timings = Timings::getSendDataPacketTimings($packet);
$timings->startTiming(); $timings->startTiming();
$this->server->getPluginManager()->callEvent($ev = new DataPacketSendEvent($this, $packet)); $this->server->getPluginManager()->callEvent($ev = new DataPacketSendEvent($this, $packet));
@ -1125,6 +1129,12 @@ class Player extends Human implements CommandSender, ChunkLoader, IPlayer{
return false; return false;
} }
if(!$needACK and !$immediate and $packet->canBeBatched()){
$this->batchedPackets[] = clone $packet;
return true;
}
$identifier = $this->interface->putPacket($this, $packet, $needACK, $immediate); $identifier = $this->interface->putPacket($this, $packet, $needACK, $immediate);
if($needACK and $identifier !== null){ if($needACK and $identifier !== null){