Fixed the video corruption issue that occurs during input source tran…

…sitions when using the NVIDIA encoder

src/projects/transcoder/transcoder_stream.cpp

@@ -251,6 +251,7 @@ bool TranscoderStream::UpdateInternal(const std::shared_ptr<info::Stream> &strea
 
 		RemoveDecoders();
 		RemoveFilters();
+		RemoveSpecificEncoders();
 
 		CreateDecoders();
 	}
@@ -333,6 +334,44 @@ void TranscoderStream::RemoveFilters()
 	}
 }
 
+// In a scheduled stream, when the video input changes and the decoder is reinitialized,
+//  the NVIDIA encoder must also be reinitialized. If not, video corruption may occur.
+void TranscoderStream::RemoveSpecificEncoders()
+{
+	std::unique_lock<std::shared_mutex> encoder_lock(_encoder_map_mutex);
+	auto encoders = _encoders;
+	encoder_lock.unlock();
+
+	for (auto &[id, object] : encoders)
+	{
+		auto filter = object.first;
+		auto encoder = object.second;
+
+		if (encoder->GetRefTrack()->GetMediaType() != cmn::MediaType::Video)
+		{
+			continue;
+		}
+		if (encoder->GetRefTrack()->GetCodecModuleId() != cmn::MediaCodecModuleId::NVENC)
+		{
+			continue;
+		}
+
+		_encoders.erase(id);
+
+		if (filter != nullptr)
+		{
+			filter->Stop();
+			filter.reset();
+		}
+
+		if (encoder != nullptr)
+		{
+			encoder->Stop();
+			encoder.reset();
+		}
+	}
+}
+
 void TranscoderStream::RemoveEncoders()
 {
 	std::unique_lock<std::shared_mutex> encoder_lock(_encoder_map_mutex);

src/projects/transcoder/transcoder_stream.h

@@ -239,6 +239,7 @@ class TranscoderStream : public ov::EnableSharedFromThis<TranscoderStream>,
 	std::optional<std::pair<std::shared_ptr<TranscodeFilter>, std::shared_ptr<TranscodeEncoder>>> GetEncoder(MediaTrackId encoder_id);
 	void SetEncoder(MediaTrackId encoder_id, std::shared_ptr<TranscodeFilter> filter, std::shared_ptr<TranscodeEncoder> encoder);
 	void RemoveEncoders();
+	void RemoveSpecificEncoders();
 
 	void ProcessPacket(const std::shared_ptr<MediaPacket> &packet);