MAGETWO-93998: [Forwardport] Run Product Price reindex in multithread mode with Redis

Author: slopukhov

lib/internal/Magento/Framework/Session/SaveHandler/Redis.php

@@ -14,13 +14,28 @@
 use Magento\Framework\Filesystem;
 use Magento\Framework\App\Filesystem\DirectoryList;
 
-class Redis extends \Cm\RedisSession\Handler
+class Redis implements \SessionHandlerInterface
 {
+    /**
+     * @var ConfigInterface
+     */
+    private $config;
+
+    /**
+     * @var LoggerInterface
+     */
+    private $logger;
+
     /**
      * @var Filesystem
      */
     private $filesystem;
 
+    /**
+     * @var \Cm\RedisSession\Handler[]
+     */
+    private $connection;
+
     /**
      * @param ConfigInterface $config
      * @param LoggerInterface $logger
@@ -29,23 +44,116 @@ class Redis extends \Cm\RedisSession\Handler
      */
     public function __construct(ConfigInterface $config, LoggerInterface $logger, Filesystem $filesystem)
     {
+        $this->config = $config;
+        $this->logger = $logger;
         $this->filesystem = $filesystem;
-        try {
-            parent::__construct($config, $logger);
-        } catch (ConnectionFailedException $e) {
-            throw new SessionException(new Phrase($e->getMessage()));
+    }
+
+    /**
+     * Get connection
+     *
+     * @return \Cm\RedisSession\Handler
+     * @throws SessionException
+     */
+    private function getConnection()
+    {
+        $pid = getmypid();
+        if (!isset($this->connection[$pid])) {
+            try {
+                $this->connection[$pid] = new \Cm\RedisSession\Handler($this->config, $this->logger);
+            } catch (ConnectionFailedException $e) {
+                throw new SessionException(new Phrase($e->getMessage()));
+            }
         }
+        return $this->connection[$pid];
     }
 
     /**
-     * {@inheritdoc}
+     * Open session
+     *
+     * @param string $savePath ignored
+     * @param string $sessionName ignored
+     * @return bool
+     * @throws SessionException
+     */
+    public function open($savePath, $sessionName)
+    {
+        return $this->getConnection()->open($savePath, $sessionName);
+    }
+
+    /**
+     * Fetch session data
+     *
+     * @param string $sessionId
+     * @return string
+     * @throws ConcurrentConnectionsExceededException
+     * @throws SessionException
      */
     public function read($sessionId)
     {
         try {
-            return parent::read($sessionId);
+            return $this->getConnection()->read($sessionId);
         } catch (ConcurrentConnectionsExceededException $e) {
             require $this->filesystem->getDirectoryRead(DirectoryList::PUB)->getAbsolutePath('errors/503.php');
         }
     }
+
+    /**
+     * Update session
+     *
+     * @param string $sessionId
+     * @param string $sessionData
+     * @return boolean
+     * @throws SessionException
+     */
+    public function write($sessionId, $sessionData)
+    {
+        return $this->getConnection()->write($sessionId, $sessionData);
+    }
+
+    /**
+     * Destroy session
+     *
+     * @param string $sessionId
+     * @return boolean
+     * @throws SessionException
+     */
+    public function destroy($sessionId)
+    {
+        return $this->getConnection()->destroy($sessionId);
+    }
+
+    /**
+     * Overridden to prevent calling getLifeTime at shutdown
+     *
+     * @return bool
+     * @throws SessionException
+     */
+    public function close()
+    {
+        return $this->getConnection()->close();
+    }
+
+    /**
+     * Garbage collection
+     *
+     * @param int $maxLifeTime ignored
+     * @return boolean
+     * @throws SessionException
+     */
+    public function gc($maxLifeTime)
+    {
+        return $this->getConnection()->gc($maxLifeTime);
+    }
+
+    /**
+     * Get the number of failed lock attempts
+     *
+     * @return int
+     * @throws SessionException
+     */
+    public function getFailedLockAttempts()
+    {
+        return $this->getConnection()->getFailedLockAttempts();
+    }
 }