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

ÂNetworkSession: ensure onResolve handler for CompressBatchPromise is covered by network send timings

Browse Source
This commit is contained in:
Dylan K. Taylor 2023-03-18 22:49:52 +00:00
parent 765aef0810
commit 9a969e21c7
No known key found for this signature in database
GPG Key ID: 8927471A91CAFD3D
1 changed files with 16 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

27
src/network/mcpe/NetworkSession.php
View File

@ -561,20 +561,25 @@ class NetworkSession{
$this->compressedQueue->enqueue($payload); $this->compressedQueue->enqueue($payload);
$payload->onResolve(function(CompressBatchPromise $payload) : void{ $payload->onResolve(function(CompressBatchPromise $payload) : void{
if($this->connected && $this->compressedQueue->bottom() === $payload){ if($this->connected && $this->compressedQueue->bottom() === $payload){
$this->compressedQueue->dequeue(); //result unused Timings::$playerNetworkSend->startTiming();
$this->sendEncoded($payload->getResult()); try{
$this->compressedQueue->dequeue(); //result unused
$this->sendEncoded($payload->getResult());
while(!$this->compressedQueue->isEmpty()){ while(!$this->compressedQueue->isEmpty()){
/** @var CompressBatchPromise $current */ /** @var CompressBatchPromise $current */
$current = $this->compressedQueue->bottom(); $current = $this->compressedQueue->bottom();
if($current->hasResult()){ if($current->hasResult()){
$this->compressedQueue->dequeue(); $this->compressedQueue->dequeue();
$this->sendEncoded($current->getResult()); $this->sendEncoded($current->getResult());
}else{ }else{
//can't send any more queued until this one is ready //can't send any more queued until this one is ready
break; break;
}
} }
}finally{
Timings::$playerNetworkSend->stopTiming();
} }
} }
}); });