@@ -24,8 +24,8 @@ StreamTranscoder::StreamTranscoder(IInputStream& inputStream, IOutputFile& outpu
24
24
, _inputStreams()
25
25
, _currentInputStream(&inputStream)
26
26
, _outputStream(NULL )
27
- , _sourceBuffers ()
28
- , _frameBuffers ()
27
+ , _decodedData ()
28
+ , _transformedData ()
29
29
, _inputDecoders()
30
30
, _generators()
31
31
, _currentDecoder(NULL )
@@ -56,8 +56,8 @@ StreamTranscoder::StreamTranscoder(IInputStream& inputStream, IOutputFile& outpu
56
56
_generators.push_back (new VideoGenerator (inputFrameDesc));
57
57
58
58
// buffers to process
59
- _sourceBuffers .push_back (new VideoFrame (inputFrameDesc));
60
- _frameBuffers .push_back (new VideoFrame (inputFrameDesc));
59
+ _decodedData .push_back (new VideoFrame (inputFrameDesc));
60
+ _transformedData .push_back (new VideoFrame (inputFrameDesc));
61
61
62
62
// transform
63
63
_transform = new VideoTransform ();
@@ -91,8 +91,8 @@ StreamTranscoder::StreamTranscoder(IInputStream& inputStream, IOutputFile& outpu
91
91
_generators.push_back (new AudioGenerator (inputFrameDesc));
92
92
93
93
// buffers to process
94
- _sourceBuffers .push_back (new AudioFrame (inputFrameDesc));
95
- _frameBuffers .push_back (new AudioFrame (inputFrameDesc));
94
+ _decodedData .push_back (new AudioFrame (inputFrameDesc));
95
+ _transformedData .push_back (new AudioFrame (inputFrameDesc));
96
96
97
97
// transform
98
98
_transform = new AudioTransform ();
@@ -129,8 +129,8 @@ StreamTranscoder::StreamTranscoder(const InputStreamDesc& inputStreamDesc, IInpu
129
129
, _inputStreams()
130
130
, _currentInputStream(&inputStream)
131
131
, _outputStream(NULL )
132
- , _sourceBuffers ()
133
- , _frameBuffers ()
132
+ , _decodedData ()
133
+ , _transformedData ()
134
134
, _inputDecoders()
135
135
, _generators()
136
136
, _currentDecoder(NULL )
@@ -169,8 +169,8 @@ StreamTranscoder::StreamTranscoder(const InputStreamDesc& inputStreamDesc, IInpu
169
169
_outputStream = &outputFile.addVideoStream (outputVideo->getVideoCodec ());
170
170
171
171
// buffers to process
172
- _sourceBuffers .push_back (new VideoFrame (_currentInputStream->getVideoCodec ().getVideoFrameDesc ()));
173
- _frameBuffers .push_back (new VideoFrame (outputVideo->getVideoCodec ().getVideoFrameDesc ()));
172
+ _decodedData .push_back (new VideoFrame (_currentInputStream->getVideoCodec ().getVideoFrameDesc ()));
173
+ _transformedData .push_back (new VideoFrame (outputVideo->getVideoCodec ().getVideoFrameDesc ()));
174
174
175
175
// transform
176
176
_transform = new VideoTransform ();
@@ -209,8 +209,8 @@ StreamTranscoder::StreamTranscoder(const InputStreamDesc& inputStreamDesc, IInpu
209
209
if (inputStreamDesc.demultiplexing ())
210
210
inputFrameDesc._nbChannels = inputStreamDesc._channelIndexArray .size ();
211
211
212
- _sourceBuffers .push_back (new AudioFrame (inputFrameDesc));
213
- _frameBuffers .push_back (new AudioFrame (outputAudio->getAudioCodec ().getAudioFrameDesc ()));
212
+ _decodedData .push_back (new AudioFrame (inputFrameDesc));
213
+ _transformedData .push_back (new AudioFrame (outputAudio->getAudioCodec ().getAudioFrameDesc ()));
214
214
215
215
// transform
216
216
_transform = new AudioTransform ();
@@ -234,8 +234,8 @@ StreamTranscoder::StreamTranscoder(IOutputFile& outputFile, const ProfileLoader:
234
234
, _inputStreams()
235
235
, _currentInputStream(NULL )
236
236
, _outputStream(NULL )
237
- , _sourceBuffers ()
238
- , _frameBuffers ()
237
+ , _decodedData ()
238
+ , _transformedData ()
239
239
, _inputDecoders()
240
240
, _generators()
241
241
, _currentDecoder(NULL )
@@ -263,8 +263,8 @@ StreamTranscoder::StreamTranscoder(IOutputFile& outputFile, const ProfileLoader:
263
263
// buffers to process
264
264
VideoFrameDesc outputFrameDesc = inputFrameDesc;
265
265
outputFrameDesc.setParameters (profile);
266
- _sourceBuffers .push_back (new VideoFrame (inputFrameDesc));
267
- _frameBuffers .push_back (new VideoFrame (outputFrameDesc));
266
+ _decodedData .push_back (new VideoFrame (inputFrameDesc));
267
+ _transformedData .push_back (new VideoFrame (outputFrameDesc));
268
268
269
269
// transform
270
270
_transform = new VideoTransform ();
@@ -295,8 +295,8 @@ StreamTranscoder::StreamTranscoder(IOutputFile& outputFile, const ProfileLoader:
295
295
// buffers to process
296
296
AudioFrameDesc outputFrameDesc = inputFrameDesc;
297
297
outputFrameDesc.setParameters (profile);
298
- _sourceBuffers .push_back (new AudioFrame (inputFrameDesc));
299
- _frameBuffers .push_back (new AudioFrame (outputFrameDesc));
298
+ _decodedData .push_back (new AudioFrame (inputFrameDesc));
299
+ _transformedData .push_back (new AudioFrame (outputFrameDesc));
300
300
301
301
// transform
302
302
_transform = new AudioTransform ();
@@ -317,11 +317,11 @@ StreamTranscoder::StreamTranscoder(IOutputFile& outputFile, const ProfileLoader:
317
317
318
318
StreamTranscoder::~StreamTranscoder ()
319
319
{
320
- for (std::vector<Frame*>::iterator it = _sourceBuffers .begin (); it != _sourceBuffers .end (); ++it)
320
+ for (std::vector<Frame*>::iterator it = _decodedData .begin (); it != _decodedData .end (); ++it)
321
321
{
322
322
delete (*it);
323
323
}
324
- for (std::vector<Frame*>::iterator it = _frameBuffers .begin (); it != _frameBuffers .end (); ++it)
324
+ for (std::vector<Frame*>::iterator it = _transformedData .begin (); it != _transformedData .end (); ++it)
325
325
{
326
326
delete (*it);
327
327
}
@@ -474,30 +474,30 @@ bool StreamTranscoder::processTranscode()
474
474
assert (_outputStream != NULL );
475
475
assert (_currentDecoder != NULL );
476
476
assert (_outputEncoder != NULL );
477
- assert (! _sourceBuffers .empty ());
478
- assert (! _frameBuffers .empty ());
477
+ assert (! _decodedData .empty ());
478
+ assert (! _transformedData .empty ());
479
479
assert (_transform != NULL );
480
480
481
481
LOG_DEBUG (" StreamTranscoder::processTranscode" )
482
482
483
483
LOG_DEBUG (" Decode next frame" )
484
484
bool decodingStatus = false ;
485
485
if (! _inputStreamDesc.empty () && _inputStreamDesc.at (0 ).demultiplexing ())
486
- decodingStatus = _currentDecoder->decodeNextFrame (*_sourceBuffers .at (0 ), _inputStreamDesc.at (0 )._channelIndexArray );
486
+ decodingStatus = _currentDecoder->decodeNextFrame (*_decodedData .at (0 ), _inputStreamDesc.at (0 )._channelIndexArray );
487
487
else
488
- decodingStatus = _currentDecoder->decodeNextFrame (*_sourceBuffers .at (0 ));
488
+ decodingStatus = _currentDecoder->decodeNextFrame (*_decodedData .at (0 ));
489
489
490
490
CodedData data;
491
491
if (decodingStatus)
492
492
{
493
493
LOG_DEBUG (" Filtering" )
494
- _filterGraph->process (_sourceBuffers , *_sourceBuffers .at (0 ));
494
+ _filterGraph->process (_decodedData , *_decodedData .at (0 ));
495
495
496
496
LOG_DEBUG (" Convert" )
497
- _transform->convert (*_sourceBuffers .at (0 ), *_frameBuffers .at (0 ));
497
+ _transform->convert (*_decodedData .at (0 ), *_transformedData .at (0 ));
498
498
499
499
LOG_DEBUG (" Encode" )
500
- _outputEncoder->encodeFrame (*_frameBuffers .at (0 ), data);
500
+ _outputEncoder->encodeFrame (*_transformedData .at (0 ), data);
501
501
}
502
502
else
503
503
{
@@ -566,7 +566,7 @@ float StreamTranscoder::getDuration() const
566
566
567
567
bool StreamTranscoder::canSwitchToGenerator ()
568
568
{
569
- if (! _sourceBuffers .empty () && ! _frameBuffers .empty () && ! _generators.empty () && _outputEncoder && _transform)
569
+ if (! _decodedData .empty () && ! _transformedData .empty () && ! _generators.empty () && _outputEncoder && _transform)
570
570
return true ;
571
571
return false ;
572
572
}
0 commit comments