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

TaskScheduler: don't catch unexpected exceptions

Browse Source 
this means that errors in scheduled tasks which are uncaught will now cause a server crash.
This commit is contained in:
Dylan K. Taylor 2018-11-04 23:22:30 +00:00
parent 1634dd62e3
commit e26af3fa1b
1 changed files with 12 additions and 26 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

38
src/pocketmine/scheduler/TaskScheduler.php
View File

@ -30,8 +30,6 @@ namespace pocketmine\scheduler;
use pocketmine\utils\ReversePriorityQueue;
class TaskScheduler{
/** @var \Logger */
private $logger;
/** @var string|null */
private $owner;
@ -54,9 +52,11 @@ class TaskScheduler{
/** @var int */
protected $currentTick = 0;
/**
* @param \Logger $logger @deprecated
* @param null|string $owner
*/
public function __construct(\Logger $logger, ?string $owner = null){
$this->logger = $logger;
$this->owner = $owner;
$this->queue = new ReversePriorityQueue();
}
@ -108,11 +108,9 @@ class TaskScheduler{
if(isset($this->tasks[$taskId])){
try{
$this->tasks[$taskId]->cancel();
}catch(\Throwable $e){
$this->logger->critical("Task " . $this->tasks[$taskId]->getTaskName() . " threw an exception when trying to cancel: " . $e->getMessage());
$this->logger->logException($e);
}finally{
unset($this->tasks[$taskId]);
}
unset($this->tasks[$taskId]);
}
}
@ -198,26 +196,14 @@ class TaskScheduler{
unset($this->tasks[$task->getTaskId()]);
continue;
}
$crashed = false;
try{
$task->run($this->currentTick);
}catch(\Throwable $e){
$crashed = true;
$this->logger->critical("Could not execute task " . $task->getTaskName() . ": " . $e->getMessage());
$this->logger->logException($e);
}
$task->run($this->currentTick);
if($task->isRepeating()){
if($crashed){
$this->logger->debug("Dropping repeating task " . $task->getTaskName() . " due to exceptions thrown while running");
}else{
$task->setNextRun($this->currentTick + $task->getPeriod());
$this->queue->insert($task, $this->currentTick + $task->getPeriod());
continue;
}
$task->setNextRun($this->currentTick + $task->getPeriod());
$this->queue->insert($task, $this->currentTick + $task->getPeriod());
}else{
$task->remove();
unset($this->tasks[$task->getTaskId()]);
}
$task->remove();
unset($this->tasks[$task->getTaskId()]);
}
}