fixed 已知的bug

workbunny · Dec 8, 2023 · 77b79a5 · 77b79a5
1 parent 6c0e328
commit 77b79a5
Showing 1 changed file with 2 additions and 5 deletions.
diff --git a/src/Process/InstanceRegistrarProcess.php b/src/Process/InstanceRegistrarProcess.php
@@ -47,16 +47,13 @@ public function __construct()
     protected function _heartbeat(string $name): void
     {
         if (isset($this->instanceRegistrars[$name])) {
+            list($serviceName, $ip, $port, $option) = $this->instanceRegistrars[$name];
             if (isset($option['ephemeral'])) {
                 $option['ephemeral'] = (is_string($option['ephemeral']) ? filter_var($option['ephemeral'], FILTER_VALIDATE_BOOLEAN, FILTER_NULL_ON_FAILURE) : (bool) $option['ephemeral'] );
             }
             // 仅对非永久实例进行心跳
             if ($option['ephemeral'] ?? false) {
-                $this->heartbeatTimers[$name] = Timer::add($this->heartbeat, function () use ($name) {
-                    list($serviceName, $ip, $port, $option) = $this->instanceRegistrars[$name];
-                    if (isset($option['ephemeral'])) {
-                        $option['ephemeral'] = (is_string($option['ephemeral']) ? filter_var($option['ephemeral'], FILTER_VALIDATE_BOOLEAN, FILTER_NULL_ON_FAILURE) : (bool) $option['ephemeral'] );
-                    }
+                $this->heartbeatTimers[$name] = Timer::add($this->heartbeat, function () use ($name, $serviceName, $ip, $port, $option) {
                     try {
                         if(!$this->client->instance->beat(
                             $serviceName,