VE7UWU/sdrangel
1
0
Fork 0
mirror of https://github.com/f4exb/sdrangel.git synced 2025-07-13 14:25:24 -04:00
Code Issues Projects Releases Wiki Activity

Circular buffer fail.

Browse Source
This commit is contained in:
John Greb 2014-06-08 19:20:18 +01:00
parent 0fc1ac6380
commit 243f3dbf69
2 changed files with 3 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
sdrbase/dsp/dspengine.cpp
View File

@ -220,7 +220,6 @@ void DSPEngine::work()
// feed data to handlers // feed data to handlers
for(SampleSinks::const_iterator it = m_sampleSinks.begin(); it != m_sampleSinks.end(); it++) for(SampleSinks::const_iterator it = m_sampleSinks.begin(); it != m_sampleSinks.end(); it++)
(*it)->feed(part1begin, part1end, firstOfBurst); (*it)->feed(part1begin, part1end, firstOfBurst);
firstOfBurst = false;
} }
// second part of FIFO data (used when block wraps around) // second part of FIFO data (used when block wraps around)
if(part2begin != part2end) { if(part2begin != part2end) {
@ -232,8 +231,8 @@ void DSPEngine::work()
// feed data to handlers // feed data to handlers
for(SampleSinks::const_iterator it = m_sampleSinks.begin(); it != m_sampleSinks.end(); it++) for(SampleSinks::const_iterator it = m_sampleSinks.begin(); it != m_sampleSinks.end(); it++)
(*it)->feed(part2begin, part2end, firstOfBurst); (*it)->feed(part2begin, part2end, firstOfBurst);
firstOfBurst = false;
} }
firstOfBurst = false;
// adjust FIFO pointers // adjust FIFO pointers
sampleFifo->readCommit(count); sampleFifo->readCommit(count);

5
sdrbase/dsp/threadedsamplesink.cpp
View File

@ -69,15 +69,14 @@ void ThreadedSampleSink::handleData()
// handle data // handle data
if(m_sampleSink != NULL) if(m_sampleSink != NULL)
m_sampleSink->feed(part1begin, part1end, firstOfBurst); m_sampleSink->feed(part1begin, part1end, firstOfBurst);
firstOfBurst = false;
} }
// second part of FIFO data (used when block wraps around) // second part of FIFO data (used when block wraps around)
if(part2begin != part2end) { if(part2begin != part2end) {
// handle data // handle data
if(m_sampleSink != NULL) if(m_sampleSink != NULL)
m_sampleSink->feed(part1begin, part1end, firstOfBurst); m_sampleSink->feed(part2begin, part2end, firstOfBurst);
firstOfBurst = false;
} }
firstOfBurst = false;
// adjust FIFO pointers // adjust FIFO pointers
m_sampleFifo.readCommit(count); m_sampleFifo.readCommit(count);