Method runSingleCH

src/sdr/SDRPostThread.cpp:248–299

Run without any processing; each demod gets the full SDR bandwidth to handle on it's own

// Run without any processing; each demod gets the full SDR bandwidth to handle on it's own
void SDRPostThread::runSingleCH(SDRThreadIQData *data_in) {
    bool refreshed = false;
    
    if (sampleRate != data_in->sampleRate || doRefresh.load()) {
        sampleRate = data_in->sampleRate;
        numChannels = 1;
        refreshed = true;
    }

    if (refreshed || frequency != data_in->frequency) {
        frequency = data_in->frequency;
        updateActiveDemodulators();
    }
    
    size_t outSize = data_in->data.size();
    
    if (outSize > dataOut.capacity()) {
        dataOut.reserve(outSize);
    }
    if (outSize != dataOut.size()) {
        dataOut.resize(outSize);
    }
    
    DemodulatorThreadIQDataPtr demodDataOut = buffers.getBuffer();

    demodDataOut->frequency = frequency;
    demodDataOut->sampleRate = sampleRate;
    
    if (demodDataOut->data.size() != outSize) {
        if (demodDataOut->data.capacity() < outSize) {
            demodDataOut->data.reserve(outSize);
        }
        demodDataOut->data.resize(outSize);
    }
    
    //Only 1 channel, apply DC blocker.
    iirfilt_crcf_execute_block(dcFilter, &data_in->data[0], data_in->data.size(), &demodDataOut->data[0]);

    //push the DC-corrected data as Main Spactrum + Waterfall data.
    pushVisualData(demodDataOut);

    if (!runDemods.empty() && iqActiveDemodVisualQueue != nullptr) {
        //non-blocking push here, we can afford to loose some samples for a ever-changing visual display.
        iqActiveDemodVisualQueue->try_push(demodDataOut);
    }
    
    for (auto & runDemod : runDemods) {
        // try-push() : we do our best to only stimulate active demods, but some could happen to be dead, full, or indeed non-active.
        //so in short never block here no matter what.
        runDemod->getIQInputDataPipe()->try_push(demodDataOut);
    }
}


// Handle active channels, channel 0 offset correction, de-interlacing and push data to demodulators