AMD-AMF エンコーダー/デコーダーの終了処理を改善する

Drain() に加えて Flush() を呼び出し、polling_thread の終了を確実にする。
polling_thread_.reset() を join() の直後に移動し、競合状態を回避する。

Author: voluntas

src/hwenc_amf/amf_video_decoder.cpp

@@ -331,12 +331,13 @@ AMF_RESULT AMFVideoDecoderImpl::InitAMF() {
 void AMFVideoDecoderImpl::ReleaseAMF() {
   if (decoder_ != nullptr) {
     decoder_->Drain();
+    decoder_->Flush();
   }
   if (polling_thread_ != nullptr) {
     polling_thread_->join();
+    polling_thread_.reset();
   }
   decoder_ = nullptr;
-  polling_thread_.reset();
 }
 
 std::unique_ptr<AMFVideoDecoder> AMFVideoDecoder::Create(

src/hwenc_amf/amf_video_encoder.cpp

@@ -418,13 +418,14 @@ AMF_RESULT AMFVideoEncoderImpl::InitAMF() {
 AMF_RESULT AMFVideoEncoderImpl::ReleaseAMF() {
   if (encoder_ != nullptr) {
     encoder_->Drain();
+    encoder_->Flush();
   }
   if (polling_thread_ != nullptr) {
     polling_thread_->join();
+    polling_thread_.reset();
   }
 
   encoder_ = nullptr;
-  polling_thread_.reset();
 
   return AMF_OK;
 }