Disable gemCloseWorker for internal DrmCommandStreamReceivers

Change-Id: I71abdcb417342110ddc64cc9b1dacecc24c78aac
Signed-off-by: Jim Snow <[email protected]>

Author: jimsnow-intel

opencl/source/os_interface/linux/drm_command_stream.h

@@ -49,6 +49,10 @@ class DrmCommandStreamReceiver : public DeviceCommandStreamReceiver<GfxFamily> {
         return this->gemCloseWorkerOperationMode;
     }
 
+    void initializeDefaultsForInternalEngine() override {
+        gemCloseWorkerOperationMode = gemCloseWorkerMode::gemCloseWorkerInactive;
+    }
+
   protected:
     MOCKABLE_VIRTUAL void flushInternal(const BatchBuffer &batchBuffer, const ResidencyContainer &allocationsForResidency);
     MOCKABLE_VIRTUAL void exec(const BatchBuffer &batchBuffer, uint32_t vmHandleId, uint32_t drmContextId);

opencl/test/unit_test/os_interface/linux/device_command_stream_tests.cpp

@@ -71,4 +71,15 @@ HWTEST_F(DeviceCommandStreamLeaksTest, givenEnableDirectSubmissionWhenCsrIsCreat
     auto drmCsr = (DrmCommandStreamReceiver<FamilyType> *)ptr.get();
 
     EXPECT_EQ(drmCsr->peekGemCloseWorkerOperationMode(), gemCloseWorkerMode::gemCloseWorkerInactive);
-}
+}
+
+using DeviceCommandStreamSetInternalUsageTests = DeviceCommandStreamLeaksTest;
+
+HWTEST_F(DeviceCommandStreamSetInternalUsageTests, givenValidDrmCsrThenGemCloseWorkerOperationModeIsSetToInactiveWhenInternalUsageIsSet) {
+    std::unique_ptr<CommandStreamReceiver> ptr(DeviceCommandStreamReceiver<FamilyType>::create(false, *executionEnvironment, 0));
+    auto drmCsr = (DrmCommandStreamReceiver<FamilyType> *)ptr.get();
+    EXPECT_EQ(drmCsr->peekGemCloseWorkerOperationMode(), gemCloseWorkerMode::gemCloseWorkerActive);
+
+    drmCsr->initializeDefaultsForInternalEngine();
+    EXPECT_EQ(drmCsr->peekGemCloseWorkerOperationMode(), gemCloseWorkerMode::gemCloseWorkerInactive);
+}

shared/source/command_stream/command_stream_receiver.h

@@ -214,6 +214,8 @@ class CommandStreamReceiver {
 
     bool isRcs() const;
 
+    virtual void initializeDefaultsForInternalEngine(){};
+
   protected:
     void cleanupResources();
     void printDeviceIndex();

shared/source/device/device.cpp

@@ -125,6 +125,9 @@ bool Device::createEngine(uint32_t deviceCsrIndex, aub_stream::EngineType engine
     }
 
     bool internalUsage = (deviceCsrIndex == HwHelper::internalUsageEngineIndex);
+    if (internalUsage) {
+        commandStreamReceiver->initializeDefaultsForInternalEngine();
+    }
 
     if (commandStreamReceiver->needsPageTableManager(engineType)) {
         commandStreamReceiver->createPageTableManager();