Improve the performance

Increase the number of concurrent to improve the performance.

Tracked-On: OAM-134135
Signed-off-by: chenyanxzhu <chenyanx.zhu@intel.com>
Signed-off-by: Zhang, YichiX <yichix.zhang@intel.com>

Author: zhangyichix

c2_components/src/mfx_c2_decoder_component.cpp

@@ -1140,7 +1140,7 @@ mfxU16 MfxC2DecoderComponent::GetAsyncDepth(void)
     if (MFX_CODEC_AV1 == m_mfxVideoParams.mfx.CodecId)
         asyncDepth = (MFX_IMPL_BASETYPE(m_mfxImplementation) == MFX_IMPL_SOFTWARE) ? 0 : 10;
     else
-        asyncDepth = (MFX_IMPL_BASETYPE(m_mfxImplementation) == MFX_IMPL_SOFTWARE) ? 0 : 1;
+        asyncDepth = (MFX_IMPL_BASETYPE(m_mfxImplementation) == MFX_IMPL_SOFTWARE) ? 0 : 2;
 #else
     if ((MFX_IMPL_HARDWARE == MFX_IMPL_BASETYPE(m_mfxImplementation)) &&
         ((MFX_CODEC_AVC == m_mfxVideoParams.mfx.CodecId) ||

c2_components/src/mfx_c2_encoder_component.cpp

@@ -1066,6 +1066,8 @@ mfxStatus MfxC2EncoderComponent::ResetSettings()
         m_mfxVideoParamsConfig.mfx.LowPower = MFX_CODINGOPTION_ON;
     }
 
+    m_mfxVideoParamsConfig.AsyncDepth = 2;
+
     MFX_DEBUG_TRACE__mfxStatus(mfx_res);
     return mfx_res;
 }
@@ -1649,7 +1651,13 @@ void MfxC2EncoderComponent::DoWork(std::unique_ptr<C2Work>&& work)
             }
         }
 
-        if(MFX_ERR_MORE_DATA == mfx_sts) mfx_sts = MFX_ERR_NONE;
+        if(MFX_ERR_MORE_DATA == mfx_sts) 
+        {
+            // It may get stuck at the last few frames while processing concurrently.
+            if (m_mfxVideoParamsConfig.AsyncDepth > 1)
+                m_workingQueue.Push( [this] () { Drain(nullptr); } );
+            mfx_sts = MFX_ERR_NONE;
+        }
 
     } while(false); // fake loop to have a cleanup point there