VE7UWU/sdrangel
1
0
Fork 0
mirror of https://github.com/f4exb/sdrangel.git synced 2024-12-03 21:43:24 -05:00
Code Issues Projects Releases Wiki Activity

SDRdaemonSink: lower Tx queue length target to 5 and implement quick start kick off

Browse Source
This commit is contained in:
f4exb 2017-06-05 16:47:56 +02:00
parent 1642a0d92c
commit a86819ea70
1 changed files with 11 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
plugins/samplesink/sdrdaemonsink/sdrdaemonsinkgui.cpp
View File

@ -548,21 +548,25 @@ void SDRdaemonSinkGui::tick()
ui->queueLengthText->setText(QString::fromStdString(strs[0])); ui->queueLengthText->setText(QString::fromStdString(strs[0]));
m_nbSinceLastFlowCheck++; m_nbSinceLastFlowCheck++;
int samplesCorr = 0; int samplesCorr = 0;
bool quickStart = false;
if (queueLength < 10) if (queueLength == 0)
{ {
// samplesCorr = ((10 - queueLength)*m_nbSinceLastFlowCheck)/10; samplesCorr = 127*8;
samplesCorr = ((10 - queueLength)*16)/m_nbSinceLastFlowCheck; quickStart = true;
} }
else if (queueLength > 10) else if (queueLength < 5)
{ {
// samplesCorr = ((10 - queueLength)*m_nbSinceLastFlowCheck)/10; samplesCorr = ((5 - queueLength)*16)/m_nbSinceLastFlowCheck;
samplesCorr = ((10 - queueLength)*16)/m_nbSinceLastFlowCheck; }
else if (queueLength > 5)
{
samplesCorr = ((5 - queueLength)*16)/m_nbSinceLastFlowCheck;
} }
if (samplesCorr != 0) if (samplesCorr != 0)
{ {
samplesCorr = samplesCorr < -50 ? -50 : samplesCorr > 50 ? 50 : samplesCorr; samplesCorr = quickStart ? samplesCorr : samplesCorr <= -50 ? -50 : samplesCorr >= 50 ? 50 : samplesCorr;
SDRdaemonSinkOutput::MsgConfigureSDRdaemonSinkChunkCorrection* message = SDRdaemonSinkOutput::MsgConfigureSDRdaemonSinkChunkCorrection::create(samplesCorr); SDRdaemonSinkOutput::MsgConfigureSDRdaemonSinkChunkCorrection* message = SDRdaemonSinkOutput::MsgConfigureSDRdaemonSinkChunkCorrection::create(samplesCorr);
m_deviceSampleSink->getInputMessageQueue()->push(message); m_deviceSampleSink->getInputMessageQueue()->push(message);
m_nbSinceLastFlowCheck = 0; m_nbSinceLastFlowCheck = 0;