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

Added more timings

Browse Source
This commit is contained in:
Dylan K. Taylor 2023-11-09 14:55:26 +00:00
parent ff47da6675
commit 94023b48e5
No known key found for this signature in database
GPG Key ID: 8927471A91CAFD3D
2 changed files with 8 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/Server.php
View File

@ -1386,13 +1386,17 @@ class Server{
}
if(!$sync && $this->networkCompressionThreads > 0){
Timings::$playerNetworkSendCompressAsync->startTiming();
$workerPool = $this->getNetworkCompressionWorkerPool($compressor);
//TODO: we really want to be submitting all sessions' buffers in one go to maximize performance
$promise = $workerPool->submit($buffer);
Timings::$playerNetworkSendCompressAsync->stopTiming();
}else{
Timings::$playerNetworkSendCompressSync->startTiming();
$promise = new CompressBatchPromise();
$promise->resolve($compressor->compress($buffer));
Timings::$playerNetworkSendCompressSync->stopTiming();
}
return $promise;

4
src/timings/Timings.php
View File

@ -49,6 +49,8 @@ abstract class Timings{
public static TimingsHandler $playerNetworkSendCompress;
public static TimingsHandler $playerNetworkSendCompressBroadcast;
public static TimingsHandler $playerNetworkSendCompressSessionBuffer;
public static TimingsHandler $playerNetworkSendCompressSync;
public static TimingsHandler $playerNetworkSendCompressAsync;
public static TimingsHandler $playerNetworkSendEncrypt;
public static TimingsHandler $playerNetworkSendInventorySync;
public static TimingsHandler $playerNetworkSendPreSpawnGameData;
@ -146,6 +148,8 @@ abstract class Timings{
self::$playerNetworkSendCompress = new TimingsHandler("Player Network Send - Compression", self::$playerNetworkSend, group: self::GROUP_BREAKDOWN);
self::$playerNetworkSendCompressBroadcast = new TimingsHandler("Player Network Send - Compression (Broadcast)", self::$playerNetworkSendCompress, group: self::GROUP_BREAKDOWN);
self::$playerNetworkSendCompressSessionBuffer = new TimingsHandler("Player Network Send - Compression (Session Buffer)", self::$playerNetworkSendCompress, group: self::GROUP_BREAKDOWN);
self::$playerNetworkSendCompressSync = new TimingsHandler("Player Network Send - Compression (Main Thread)", self::$playerNetworkSendCompress, group: self::GROUP_BREAKDOWN);
self::$playerNetworkSendCompressAsync = new TimingsHandler("Player Network Send - Compression (Handoff to Worker Thread)", self::$playerNetworkSendCompress, group: self::GROUP_BREAKDOWN);
self::$playerNetworkSendEncrypt = new TimingsHandler("Player Network Send - Encryption", self::$playerNetworkSend, group: self::GROUP_BREAKDOWN);
self::$playerNetworkSendInventorySync = new TimingsHandler("Player Network Send - Inventory Sync", self::$playerNetworkSend, group: self::GROUP_BREAKDOWN);
self::$playerNetworkSendPreSpawnGameData = new TimingsHandler("Player Network Send - Pre-Spawn Game Data", self::$playerNetworkSend, group: self::GROUP_BREAKDOWN);