MAGETWO-80789: [Indexer] Search Indexer is scoped & multi-threaded

Author: slopukhov

app/code/Magento/CatalogSearch/Test/Unit/Model/Indexer/FulltextTest.php

@@ -54,6 +54,11 @@ class FulltextTest extends \PHPUnit\Framework\TestCase
      */
     private $indexSwitcher;
 
+    /**
+     * @var \Magento\Indexer\Model\ProcessManager
+     */
+    private $processManager;
+
     protected function setUp()
     {
         $this->fullAction = $this->getClassMock(\Magento\CatalogSearch\Model\Indexer\Fulltext\Action\Full::class);
@@ -89,6 +94,8 @@ protected function setUp()
             ->setMethods(['switchIndex'])
             ->getMock();
 
+        $this->processManager = new \Magento\Indexer\Model\ProcessManager();
+
         $objectManagerHelper = new ObjectManagerHelper($this);
         $this->model = $objectManagerHelper->getObject(
             \Magento\CatalogSearch\Model\Indexer\Fulltext::class,
@@ -101,6 +108,7 @@ protected function setUp()
                 'searchRequestConfig' => $this->searchRequestConfig,
                 'data' => [],
                 'indexSwitcher' => $this->indexSwitcher,
+                'processManager' => $this->processManager,
             ]
         );
     }

lib/internal/Magento/Framework/App/ResourceConnection.php

@@ -105,15 +105,15 @@ public function closeConnection($resourceName = self::DEFAULT_CONNECTION)
     {
         if ($resourceName === null) {
             foreach ($this->connections as $processConnection) {
-                if ($processConnection instanceof AdapterInterface) {
+                if ($processConnection !== null) {
                     $processConnection->closeConnection();
                 }
             }
             $this->connections = [];
         } else {
             $processConnectionName = $this->getProcessConnectionName($this->config->getConnectionName($resourceName));
             if (isset($this->connections[$processConnectionName])) {
-                if ($this->connections[$processConnectionName] instanceof AdapterInterface) {
+                if ($this->connections[$processConnectionName] !== null) {
                     $this->connections[$processConnectionName]->closeConnection();
                 }
                 $this->connections[$processConnectionName] = null;