Evolution-x/hardware_interfaces
1
0
Fork 0
mirror of https://github.com/Evolution-X/hardware_interfaces synced 2026-02-01 11:36:00 +00:00
Code Issues Packages Projects Releases Wiki Activity

Fix minor issues in dmux default impl

Browse Source 
Test: mannual
Change-Id: If74df110cd9eda2dadb87a8d659d83233ad75d88
(cherry picked from commit 9a1e5aa93a)
Merged-In: If74df110cd9eda2dadb87a8d659d83233ad75d88
This commit is contained in:
shubang
2019-10-15 22:18:11 -07:00
committed by Amy Zhang
parent f49cfb4462
commit 7ab999d0a3
1 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
tv/tuner/1.0/default/Demux.cpp
View File

@@ -479,7 +479,8 @@ Result Demux::startPesFilterHandler(uint32_t filterId) {
if (prefix == 0x000001) {
// TODO handle mulptiple Pes filters
mPesSizeLeft =
(mFilterOutputs[filterId][i + 7] << 8) | mFilterOutputs[filterId][i + 8];
(mFilterOutputs[filterId][i + 8] << 8) | mFilterOutputs[filterId][i + 9];
mPesSizeLeft += 6;
ALOGD("[Demux] pes data length %d", mPesSizeLeft);
} else {
continue;
@@ -489,7 +490,7 @@ Result Demux::startPesFilterHandler(uint32_t filterId) {
int endPoint = min(184, mPesSizeLeft);
// append data and check size
vector<uint8_t>::const_iterator first = mFilterOutputs[filterId].begin() + i + 4;
vector<uint8_t>::const_iterator last = mFilterOutputs[filterId].begin() + i + 3 + endPoint;
vector<uint8_t>::const_iterator last = mFilterOutputs[filterId].begin() + i + 4 + endPoint;
mPesOutput.insert(mPesOutput.end(), first, last);
// size does not match then continue
mPesSizeLeft -= endPoint;
@@ -800,7 +801,7 @@ void Demux::maySendInputStatusCallback() {
void Demux::maySendFilterStatusCallback(uint32_t filterId) {
std::lock_guard<std::mutex> lock(mFilterStatusLock);
int availableToRead = mFilterMQs[filterId]->availableToRead();
int availableToWrite = mInputMQ->availableToWrite();
int availableToWrite = mFilterMQs[filterId]->availableToWrite();
int fmqSize = mFilterMQs[filterId]->getQuantumCount();
DemuxFilterStatus newStatus =
@@ -885,7 +886,6 @@ void Demux::broadcastInputThreadLoop() {
byteBuffer[index] = static_cast<uint8_t>(buffer[index]);
}
startTsFilter(byteBuffer);
inputData.seekg(packetSize, inputData.cur);
}
startFilterDispatcher();
sleep(1);