Method loadPipeSink

src/core/PipeWireAudioBridge.cpp:295–342

}

bool PipeWireAudioBridge::loadPipeSink()
{
    // FIFO lives in the per-user XDG runtime directory with mode 0600.
    // See GHSA-x8xf-4g5v-ppf9.
    const QString fifoDir = daxFifoDir();
    if (fifoDir.isEmpty()) return false;
    auto pipePath = QStringLiteral("%1/tx.pipe").arg(fifoDir);
    auto sinkName = QStringLiteral("aethersdr-tx");
    auto sinkDesc = QStringLiteral("AetherSDR TX");

    if (!makeOwnedFifo(pipePath)) return false;

    // Use a small pipe buffer (2048 bytes ~ 42ms at 24kHz mono s16le)
    // to keep latency low for digital modes like FT8/FT4.
    uint32_t modIdx = runPactl({
        "load-module", "module-pipe-sink",
        QStringLiteral("file=%1").arg(pipePath),
        QStringLiteral("sink_name=%1").arg(sinkName),
        // Single-quoted — see loadPipeSource(): unquoted, the space in
        // "AetherSDR TX" truncates device.description to "AetherSDR".
        QStringLiteral("sink_properties='device.description=\"%1\"'").arg(sinkDesc),
        QStringLiteral("format=s16le"),
        QStringLiteral("rate=%1").arg(TX_RATE),
        QStringLiteral("channels=%1").arg(TX_CHANNELS),
        QStringLiteral("pipe_size=2048"),
    });

    if (modIdx == 0) {
        ::unlink(pipePath.toUtf8().constData());
        return false;
    }

    // Open the pipe for reading (non-blocking)
    int fd = ::open(pipePath.toUtf8().constData(), O_RDONLY | O_NONBLOCK);
    if (fd < 0) {
        qCWarning(lcDax) << "PipeWireAudioBridge: open TX pipe failed:" << strerror(errno);
        runPactl({"unload-module", QString::number(modIdx)});
        ::unlink(pipePath.toUtf8().constData());
        return false;
    }

    m_tx.fd = fd;
    m_tx.moduleIndex = modIdx;
    m_tx.pipePath = pipePath;

    qCDebug(lcDax) << "PipeWireAudioBridge: TX pipe sink loaded, module" << modIdx;
    return true;
}

void PipeWireAudioBridge::unloadModules()
{