This commit is contained in:
2021-03-02 14:57:33 +08:00
parent f7e1ac1c63
commit 702b204e40
2 changed files with 4 additions and 6 deletions
-2
View File
@@ -33,8 +33,6 @@ abstract class Callback extends HttpService
protected function clear($server, $worker_id, $message) protected function clear($server, $worker_id, $message)
{ {
try { try {
Timer::clearAll();
fire(Event::SYSTEM_RESOURCE_CLEAN); fire(Event::SYSTEM_RESOURCE_CLEAN);
\logger()->insert(); \logger()->insert();
+3 -3
View File
@@ -272,11 +272,11 @@ abstract class Pool extends Component
*/ */
public function clean(string $name) public function clean(string $name)
{ {
var_dump($name);
if (Timer::exists($this->creates)) {
Timer::clear($this->creates); Timer::clear($this->creates);
if (!Context::inCoroutine()) {
return;
} }
if (!isset($this->_items[$name])) { if (!Context::inCoroutine() || !isset($this->_items[$name])) {
return; return;
} }
$channel = $this->_items[$name]; $channel = $this->_items[$name];