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

Use compression level 0 when batch size is below threshold

Browse Source 
This isn't free, because of the adler32 checksum... but it's much lighter on performance for small packets.
This commit is contained in:
Dylan K. Taylor 2017-06-05 22:05:46 +01:00
parent b7b7bcee4f
commit c6e800cf42
1 changed files with 9 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

22
src/pocketmine/Server.php
View File

@ -1783,17 +1783,7 @@ class Server{
public function broadcastPacket(array $players, DataPacket $packet){ public function broadcastPacket(array $players, DataPacket $packet){
$packet->encode(); $packet->encode();
$packet->isEncoded = true; $packet->isEncoded = true;
if(Network::$BATCH_THRESHOLD >= 0 and strlen($packet->buffer) >= Network::$BATCH_THRESHOLD){ $this->batchPackets($players, [$packet], false);
$this->batchPackets($players, [$packet], false);
return;
}
foreach($players as $player){
$player->dataPacket($packet);
}
if(isset($packet->__encapsulatedPacket)){
unset($packet->__encapsulatedPacket);
}
} }
/** /**
@ -1821,11 +1811,17 @@ class Server{
$pk->addPacket($p); $pk->addPacket($p);
} }
if(Network::$BATCH_THRESHOLD >= 0 and strlen($pk->payload) >= Network::$BATCH_THRESHOLD){
$compressionLevel = $this->networkCompressionLevel;
}else{
$compressionLevel = 0; //Do not compress packets under the threshold
}
if(!$forceSync and !$immediate and $this->networkCompressionAsync){ if(!$forceSync and !$immediate and $this->networkCompressionAsync){
$task = new CompressBatchedTask($pk, $targets, $this->networkCompressionLevel); $task = new CompressBatchedTask($pk, $targets, $compressionLevel);
$this->getScheduler()->scheduleAsyncTask($task); $this->getScheduler()->scheduleAsyncTask($task);
}else{ }else{
$pk->compress($this->networkCompressionLevel); $pk->compress($compressionLevel);
$this->broadcastPacketsCallback($pk, $targets, $immediate); $this->broadcastPacketsCallback($pk, $targets, $immediate);
} }
} }