file: add log when read next packets

Clement Champetier · Clement Champetier · commit e10930fdd4d4 · 2015-09-30T12:38:29.000+02:00
diff --git a/src/AvTranscoder/file/InputFile.cpp b/src/AvTranscoder/file/InputFile.cpp
@@ -63,6 +63,7 @@ bool InputFile::readNextPacket( CodedData& data, const size_t streamIndex )
 		const int ret = av_read_frame( &_formatContext.getAVFormatContext(), &data.getAVPacket() );
 		if( ret < 0 ) // error or end of file
 		{
+			LOG_INFO( "No more data to read on file '" << _filename << "'" )
 			return false;
 		}
 
@@ -71,6 +72,7 @@ bool InputFile::readNextPacket( CodedData& data, const size_t streamIndex )
 		const int packetStreamIndex = data.getAVPacket().stream_index;
 		if( packetStreamIndex == (int)streamIndex )
 		{
+			LOG_DEBUG( "Get a packet data of the stream " << streamIndex )
 			nextPacketFound = true;
 		}
 		// else add the packet data to the stream cache
diff --git a/src/AvTranscoder/stream/InputStream.cpp b/src/AvTranscoder/stream/InputStream.cpp
@@ -58,12 +58,14 @@ bool InputStream::readNextPacket( CodedData& data )
 	// if packet is already cached
 	if( ! _streamCache.empty() )
 	{
+		LOG_DEBUG( "Get packet data of stream " << _streamIndex << " from the cache" )
 		data.copyData( _streamCache.front().getData(), _streamCache.front().getSize() );
 		_streamCache.pop();
 	}
 	// else read next packet
 	else
 	{
+		LOG_DEBUG( "Read next packet" )
 		return _inputFile->readNextPacket( data, _streamIndex ) && _streamCache.empty();
 	}
 
@@ -120,8 +122,12 @@ void InputStream::addPacket( AVPacket& packet )
 {
 	// Do not cache data if the stream is declared as unused in process
 	if( ! _isActivated )
+	{
+		LOG_DEBUG( "Do not add a packet data for the stream " << _streamIndex << " to the cache: stream not activated" )
 		return;
+	}
 
+	LOG_DEBUG( "Add a packet data for the stream " << _streamIndex << " to the cache" )
 	_streamCache.push( CodedData() );
 	_streamCache.back().copyData( packet.data, packet.size );
 }

Original file line number	Diff line number	Diff line change
`@@ -63,6 +63,7 @@ bool InputFile::readNextPacket( CodedData& data, const size_t streamIndex )`
`63`	`63`	`const int ret = av_read_frame( &_formatContext.getAVFormatContext(), &data.getAVPacket() );`
`64`	`64`	`if( ret < 0 ) // error or end of file`
`65`	`65`	`{`
	`66`	`+ LOG_INFO( "No more data to read on file '" << _filename << "'" )`
`66`	`67`	`return false;`
`67`	`68`	`}`
`68`	`69`
`@@ -71,6 +72,7 @@ bool InputFile::readNextPacket( CodedData& data, const size_t streamIndex )`
`71`	`72`	`const int packetStreamIndex = data.getAVPacket().stream_index;`
`72`	`73`	`if( packetStreamIndex == (int)streamIndex )`
`73`	`74`	`{`
	`75`	`+ LOG_DEBUG( "Get a packet data of the stream " << streamIndex )`
`74`	`76`	`nextPacketFound = true;`
`75`	`77`	`}`
`76`	`78`	`// else add the packet data to the stream cache`
Original file line number	Diff line number	Diff line change
`@@ -58,12 +58,14 @@ bool InputStream::readNextPacket( CodedData& data )`
`58`	`58`	`// if packet is already cached`
`59`	`59`	`if( ! _streamCache.empty() )`
`60`	`60`	`{`
	`61`	`+ LOG_DEBUG( "Get packet data of stream " << _streamIndex << " from the cache" )`
`61`	`62`	`data.copyData( _streamCache.front().getData(), _streamCache.front().getSize() );`
`62`	`63`	`_streamCache.pop();`
`63`	`64`	`}`
`64`	`65`	`// else read next packet`
`65`	`66`	`else`
`66`	`67`	`{`
	`68`	`+ LOG_DEBUG( "Read next packet" )`
`67`	`69`	`return _inputFile->readNextPacket( data, _streamIndex ) && _streamCache.empty();`
`68`	`70`	`}`
`69`	`71`
`@@ -120,8 +122,12 @@ void InputStream::addPacket( AVPacket& packet )`
`120`	`122`	`{`
`121`	`123`	`// Do not cache data if the stream is declared as unused in process`
`122`	`124`	`if( ! _isActivated )`
	`125`	`+ {`
	`126`	`+ LOG_DEBUG( "Do not add a packet data for the stream " << _streamIndex << " to the cache: stream not activated" )`
`123`	`127`	`return;`
	`128`	`+ }`
`124`	`129`
	`130`	`+ LOG_DEBUG( "Add a packet data for the stream " << _streamIndex << " to the cache" )`
`125`	`131`	`_streamCache.push( CodedData() );`
`126`	`132`	`_streamCache.back().copyData( packet.data, packet.size );`
`127`	`133`	`}`