adding processFrame on Transcoder

MarcAntoine-Arnaud · MarcAntoine-Arnaud · commit ee4c3ac2e50a · 2014-06-27T11:36:16.000-04:00
diff --git a/src/AvTranscoder/Transcoder.cpp b/src/AvTranscoder/Transcoder.cpp
@@ -110,6 +110,30 @@ void Transcoder::add( const InputStreamsDesc& streamDefs )
 		throw std::runtime_error( "_inputStreams and _streamTranscoders must have the same number of streams" );
 }
 
+
+void Transcoder::processFrame()
+{
+	for( size_t streamIndex = 0; streamIndex < _inputStreams.size(); ++streamIndex )
+	{
+		if( ( _streamTranscoders.size() > streamIndex ) &&
+			! _streamTranscoders.at( streamIndex )->processFrame() )
+		{
+			//_inputStreams.erase( _inputStreams.begin() + streamIndex );
+			_inputStreams.clear();
+		}
+	}
+
+	if( _inputStreams.size() == 0 )
+	{
+		break;
+	}
+	for( size_t i = 0; i < _streamTranscoders.size(); ++i )
+	{
+		_streamTranscoders.at( i )->processFrame();
+	}
+}
+
+
 void Transcoder::process( ProgressListener& progress )
 {
 	size_t frame = 0;
@@ -134,21 +158,7 @@ void Transcoder::process( ProgressListener& progress )
 			break;
 		}
 
-
-		for( size_t streamIndex = 0; streamIndex < _inputStreams.size(); ++streamIndex )
-		{
-			if( ( _streamTranscoders.size() > streamIndex ) &&
-				! _streamTranscoders.at( streamIndex )->processFrame() )
-			{
-				//_inputStreams.erase( _inputStreams.begin() + streamIndex );
-				_inputStreams.clear();
-			}
-		}
-
-		if( _inputStreams.size() == 0 )
-		{
-			break;
-		}
+		processFrame();
 
 		++frame;
 	}
diff --git a/src/AvTranscoder/Transcoder.hpp b/src/AvTranscoder/Transcoder.hpp
@@ -41,6 +41,8 @@ class Transcoder
 	void add( const std::string& filename, const size_t streamIndex, const std::string& profile );
 	void add( const InputStreamsDesc& streamDefs );
 
+	void processFrame();
+
 	void process( ProgressListener& progress );
 
 private:
