Optimization

walkor · Dec 18, 2024 · cf97712 · cf97712
1 parent 3dbb235
commit cf97712
Showing 1 changed file with 2 additions and 19 deletions.
diff --git a/src/Connection/TcpConnection.php b/src/Connection/TcpConnection.php
@@ -282,13 +282,6 @@ class TcpConnection extends ConnectionInterface implements JsonSerializable
      */
     protected static int $idRecorder = 1;
 
-    /**
-     * Cache.
-     *
-     * @var bool
-     */
-    protected static bool $enableCache = true;
-
     /**
      * Socket
      *
@@ -674,7 +667,7 @@ public function baseRead($socket, bool $checkEof = true): void
         } else {
             $this->bytesRead += strlen($buffer);
             if ($this->recvBuffer === '') {
-                if (static::$enableCache && isset($requests[$buffer])) {
+                if (!isset($buffer[static::MAX_CACHE_STRING_LENGTH]) && isset($requests[$buffer])) {
                     ++self::$statistics['total_request'];
                     $request = $requests[$buffer];
                     if ($request instanceof Request) {
@@ -752,7 +745,7 @@ public function baseRead($socket, bool $checkEof = true): void
                 try {
                     // Decode request buffer before Emitting onMessage callback.
                     $request = $this->protocol::decode($oneRequestBuffer, $this);
-                    if (static::$enableCache && (!is_object($request) || $request instanceof Request) && $one && !isset($oneRequestBuffer[static::MAX_CACHE_STRING_LENGTH])) {
+                    if ((!is_object($request) || $request instanceof Request) && $one && !isset($oneRequestBuffer[static::MAX_CACHE_STRING_LENGTH])) {
                         ($this->onMessage)($this, $request);
                         if ($request instanceof Request) {
                             $request->destroy();
@@ -1088,16 +1081,6 @@ public function destroy(): void
         }
     }
 
-    /**
-     * Enable or disable Cache.
-     *
-     * @param bool $value
-     */
-    public static function enableCache(bool $value = true): void
-    {
-        static::$enableCache = $value;
-    }
-
     /**
      * Init.
      *