Transcoder: removed unnecessary code

Clement Champetier · Clement Champetier · commit fb3c87aed916 · 2016-07-11T21:42:26.000+02:00
Never reach.
diff --git a/src/AvTranscoder/transcoder/Transcoder.cpp b/src/AvTranscoder/transcoder/Transcoder.cpp
@@ -235,14 +235,12 @@ bool Transcoder::processFrame()
         return false;
 
     // For each stream, process a frame
-    size_t nbStreamProcessStatusFailed = 0;
     for(size_t streamIndex = 0; streamIndex < _streamTranscoders.size(); ++streamIndex)
     {
         LOG_DEBUG("Process stream " << streamIndex << "/" << (_streamTranscoders.size() - 1))
         if(!_streamTranscoders.at(streamIndex)->processFrame())
         {
             LOG_WARN("Failed to process stream " << streamIndex)
-            ++nbStreamProcessStatusFailed;
 
             // if this is the end of the main stream
             if(streamIndex == _mainStreamIndex) {
@@ -251,21 +249,6 @@ bool Transcoder::processFrame()
             }
         }
     }
-
-    // Get the number of streams without the generators (they always succeed)
-    size_t nbStreamsWithoutGenerator = _streamTranscoders.size();
-    for(size_t streamIndex = 0; streamIndex < _streamTranscoders.size(); ++streamIndex)
-    {
-        if(_streamTranscoders.at(streamIndex)->getProcessCase() == StreamTranscoder::eProcessCaseGenerator)
-            --nbStreamsWithoutGenerator;
-    }
-
-    // If all streams failed to process a new frame
-    if(nbStreamsWithoutGenerator != 0 && nbStreamsWithoutGenerator == nbStreamProcessStatusFailed)
-    {
-        LOG_INFO("End of process because all streams (except generators) failed to process a new frame.")
-        return false;
-    }
     return true;
 }
 

Original file line number	Diff line number	Diff line change
`@@ -235,14 +235,12 @@ bool Transcoder::processFrame()`
`235`	`235`	`return false;`
`236`	`236`
`237`	`237`	`// For each stream, process a frame`
`238`		`- size_t nbStreamProcessStatusFailed = 0;`
`239`	`238`	`for(size_t streamIndex = 0; streamIndex < _streamTranscoders.size(); ++streamIndex)`
`240`	`239`	`{`
`241`	`240`	`LOG_DEBUG("Process stream " << streamIndex << "/" << (_streamTranscoders.size() - 1))`
`242`	`241`	`if(!_streamTranscoders.at(streamIndex)->processFrame())`
`243`	`242`	`{`
`244`	`243`	`LOG_WARN("Failed to process stream " << streamIndex)`
`245`		`- ++nbStreamProcessStatusFailed;`
`246`	`244`
`247`	`245`	`// if this is the end of the main stream`
`248`	`246`	`if(streamIndex == _mainStreamIndex) {`
`@@ -251,21 +249,6 @@ bool Transcoder::processFrame()`
`251`	`249`	`}`
`252`	`250`	`}`
`253`	`251`	`}`
`254`		`-`
`255`		`- // Get the number of streams without the generators (they always succeed)`
`256`		`- size_t nbStreamsWithoutGenerator = _streamTranscoders.size();`
`257`		`- for(size_t streamIndex = 0; streamIndex < _streamTranscoders.size(); ++streamIndex)`
`258`		`- {`
`259`		`- if(_streamTranscoders.at(streamIndex)->getProcessCase() == StreamTranscoder::eProcessCaseGenerator)`
`260`		`- --nbStreamsWithoutGenerator;`
`261`		`- }`
`262`		`-`
`263`		`- // If all streams failed to process a new frame`
`264`		`- if(nbStreamsWithoutGenerator != 0 && nbStreamsWithoutGenerator == nbStreamProcessStatusFailed)`
`265`		`- {`
`266`		`- LOG_INFO("End of process because all streams (except generators) failed to process a new frame.")`
`267`		`- return false;`
`268`		`- }`
`269`	`252`	`return true;`
`270`	`253`	`}`
`271`	`254`