fix: clear fd mapping on sub-co end

swoft-cloud · Jul 24, 2019 · de11ae5 · de11ae5
1 parent 553f650
commit de11ae5
Showing 1 changed file with 6 additions and 2 deletions.
diff --git a/src/framework/src/Co.php b/src/framework/src/Co.php
@@ -105,10 +105,11 @@ public static function create(callable $callable, bool $wait = true): int
 
         // return coroutine ID for created.
         return Coroutine::create(function () use ($callable, $tid, $wait) {
+            $cid = Coroutine::getCid();
+
             try {
-                $id = Coroutine::getCid();
                 // Storage fd
-                self::$mapping[$id] = $tid;
+                self::$mapping[$cid] = $tid;
 
                 if ($wait) {
                     Context::getWaitGroup()->add();
@@ -134,6 +135,9 @@ public static function create(callable $callable, bool $wait = true): int
 
                 Context::getWaitGroup()->done();
             }
+
+            // Clean fd mapping
+            unset(self::$mapping[$cid]);
         });
     }