diff options
author | Matthias P. Braendli <matthias.braendli@mpb.li> | 2019-06-26 10:57:58 +0200 |
---|---|---|
committer | Matthias P. Braendli <matthias.braendli@mpb.li> | 2019-06-26 10:57:58 +0200 |
commit | 8e7a15754a3fef09cc5de372f207936740459c56 (patch) | |
tree | f1c3cc289eebc9ed9b620696b24467680288cc39 /src/AVTInput.cpp | |
parent | 899dcb83ec873cb35d38583d6f48922e1312e9be (diff) | |
download | ODR-SourceCompanion-8e7a15754a3fef09cc5de372f207936740459c56.tar.gz ODR-SourceCompanion-8e7a15754a3fef09cc5de372f207936740459c56.tar.bz2 ODR-SourceCompanion-8e7a15754a3fef09cc5de372f207936740459c56.zip |
Refactor OrderedQueue a bit
Diffstat (limited to 'src/AVTInput.cpp')
-rw-r--r-- | src/AVTInput.cpp | 11 |
1 files changed, 4 insertions, 7 deletions
diff --git a/src/AVTInput.cpp b/src/AVTInput.cpp index 973ed7b..0e5b669 100644 --- a/src/AVTInput.cpp +++ b/src/AVTInput.cpp @@ -69,9 +69,7 @@ AVTInput::AVTInput(const std::string& input_uri, _input_pad_packet(2048), _ordered(5000, _jitterBufferSize), _lastInfoFrameType(_typeCantExtract) -{ - -} +{ } int AVTInput::prepare(void) { @@ -430,14 +428,13 @@ ssize_t AVTInput::getNextFrame(std::vector<uint8_t> &buf) //printf("B: _padFrameQueue size=%zu\n", _padFrameQueue.size()); // Assemble next frame - int32_t nb = 0; std::vector<uint8_t> part; - while (_nbFrames < 5 && (nb = _ordered.pop(part)) != 0) + while (_nbFrames < 5 and not (part = _ordered.pop()).empty()) { while (_checkMessage()); - memcpy(_currentFrame.data() + _currentFrameSize, part.data(), nb); - _currentFrameSize += nb; + memcpy(_currentFrame.data() + _currentFrameSize, part.data(), part.size()); + _currentFrameSize += part.size(); _nbFrames ++; } |