Method createPipe

src/models/DaxIqModel.cpp:314–377

}

void DaxIqWorker::createPipe(int channel, int sampleRate)
{
#ifndef Q_OS_WIN
    int idx = channel - 1;
    if (idx < 0 || idx >= DaxIqModel::NUM_CHANNELS) return;
    if (m_pipeFds[idx] >= 0) destroyPipe(channel);

    const QString pipePath = iqPipePath(channel);
    if (pipePath.isEmpty()) {
        qCWarning(lcAudio) << "DaxIqWorker: cannot resolve IQ FIFO dir for ch" << channel;
        return;
    }

    // Create the owner-only FIFO ourselves first, THEN load the pipe-source.
    // (1) mkfifo-first removes the create-race: the old code fire-and-forgot
    //     `pactl` and raced a 200ms sleep to open a FIFO module-pipe-source had
    //     not created yet -> ENOENT "cannot open IQ pipe", no node ever appeared.
    // (2) 0600 under $XDG_RUNTIME_DIR/aethersdr (not /tmp/aethersdr-iq-N.pipe,
    //     which was prw-rw-rw-) closes the world-writable-FIFO IQ-injection
    //     vector, mirroring the DAX-audio hardening (GHSA-x8xf-4g5v-ppf9).
    if (!makeOwnedFifo(pipePath)) {
        qCWarning(lcAudio) << "DaxIqWorker: mkfifo failed for" << pipePath;
        return;
    }

    // Load module-pipe-source SYNCHRONOUSLY so we know it succeeded and capture
    // the module index for a clean unload. source_properties is single-quoted so
    // the spaced device.description survives pipewire-pulse's module-arg parser
    // (mirrors the DAX RX/TX naming fix); node.description drives the label shown
    // in qpwgraph / JACK / WSJT-X.
    const quint32 modIdx = runPactlSync({
        "load-module", "module-pipe-source",
        QStringLiteral("source_name=aethersdr-iq-%1").arg(channel),
        QStringLiteral("file=%1").arg(pipePath),
        QStringLiteral("format=float32le"),
        QStringLiteral("rate=%1").arg(sampleRate),
        QStringLiteral("channels=2"),
        QStringLiteral("source_properties='device.description=\"AetherSDR DAX IQ %1\"'").arg(channel),
    });
    if (modIdx == 0) {
        ::unlink(pipePath.toLocal8Bit().constData());
        qCWarning(lcAudio) << "DaxIqWorker: pactl load-module failed for IQ ch" << channel;
        return;
    }
    m_pipeModuleIdx[idx] = modIdx;

    // Open the write end. O_RDWR (not O_WRONLY) never ENXIOs even if the module's
    // read side has not attached yet; we only ever write this fd.
    int fd = ::open(pipePath.toLocal8Bit().constData(), O_RDWR | O_NONBLOCK);
    if (fd < 0) {
        qCWarning(lcAudio) << "DaxIqWorker: cannot open IQ pipe" << pipePath
                           << strerror(errno);
        runPactlSync({"unload-module", QString::number(modIdx)});
        ::unlink(pipePath.toLocal8Bit().constData());
        m_pipeModuleIdx[idx] = 0;
        return;
    }
    m_pipeFds[idx] = fd;