5.0.0-rc.4

walkor · Dec 6, 2024 · ed4b431 · ed4b431
1 parent e25dd32
commit ed4b431
Show file tree

Hide file tree

Showing 2 changed files with 26 additions and 2 deletions.
diff --git a/src/Connection/TcpConnection.php b/src/Connection/TcpConnection.php
@@ -19,7 +19,10 @@
 use RuntimeException;
 use stdClass;
 use Throwable;
+use Workerman\Events\Ev;
+use Workerman\Events\Event;
 use Workerman\Events\EventInterface;
+use Workerman\Events\Select;
 use Workerman\Protocols\Http\Request;
 use Workerman\Protocols\ProtocolInterface;
 use Workerman\Worker;
@@ -349,6 +352,14 @@ class TcpConnection extends ConnectionInterface implements JsonSerializable
      */
     public static array $connections = [];
 
+
+    /**
+     * Reuse request.
+     *
+     * @var bool
+     */
+    protected static bool $reuseRequest = false;
+
     /**
      * Status to string.
      *
@@ -675,7 +686,7 @@ public function baseRead($socket, bool $checkEof = true): void
                             $this->error($e);
                         }
                         $request->destroy();
-                        $requests[$buffer] = clone $request;
+                        $requests[$buffer] = static::$reuseRequest ? $request : clone $request;
                         return;
                     }
                     try {
@@ -1087,6 +1098,16 @@ public static function enableCache(bool $value = true): void
         static::$enableCache = $value;
     }
 
+    /**
+     * Init.
+     *
+     * @return void
+     */
+    public static function init(): void
+    {
+        static::$reuseRequest = in_array(get_class(Worker::$globalEvent), [Event::class, Select::class, Ev::class]);
+    }
+
     /**
      * Get the json_encode information.
      *

diff --git a/src/Worker.php b/src/Worker.php
@@ -59,7 +59,7 @@ class Worker
      *
      * @var string
      */
-    final public const VERSION = '5.0.0-rc.3';
+    final public const VERSION = '5.0.0-rc.4';
 
     /**
      * Status starting.
@@ -1709,6 +1709,9 @@ protected static function forkOneWorkerForLinux(self $worker): void
             // Init Timer.
             Timer::init(static::$globalEvent);
 
+            // Init TcpConnection.
+            TcpConnection::init();
+
             restore_error_handler();
 
             static::setProcessTitle('WorkerMan: worker process  ' . $worker->name . ' ' . $worker->getSocketName());