UdpForwarder.cc

Go to the documentation of this file.

#include "UdpForwarder.h"
 
#include <algorithm>
 
#include "QGCLoggingCategory.h"
 
QGC_LOGGING_CATEGORY(UdpForwarderLog, "Utilities.UdpForwarder")
 
UdpForwarder::UdpForwarder(QObject* parent) : QObject(parent) {}
 
bool UdpForwarder::configure(const QString& address, quint16 port)
{
    stop();
 
    const QHostAddress parsed(address);
    if (address.isEmpty() || parsed.isNull() || port == 0) {
        qCWarning(UdpForwarderLog) << "Invalid UDP forward config:" << address << port;
        return false;
    }
 
    _address = parsed;
    _port = port;
 
    qCDebug(UdpForwarderLog) << "UDP forwarding configured:" << address << ":" << port;
    return true;
}
 
qint64 UdpForwarder::forward(const QByteArray& data)
{
    if (!isEnabled()) {
        return 0;
    }
 
    // No rate limiting: RTCM runs 5-50 KB/s; writeDatagram()'s return value
    // surfaces saturation if it ever becomes a real problem.
    const qint64 sent = _socket.writeDatagram(data, _address, _port);
    if (sent < 0) {
        qCWarning(UdpForwarderLog) << "UDP forward failed:" << _socket.errorString();
    }
    return (std::max) (qint64{0}, sent);
}
 
void UdpForwarder::stop()
{
    _socket.close();
    _port = 0;
    _address.clear();
}