ETM-Schurig/etm-powersync-plugins
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

fixed udp port

Browse Source
This commit is contained in:
bernhard.trinnes 2020-08-18 13:12:07 +02:00 committed by Simon Stürz
parent 9e3cf02e3c
commit f3481b84d3
1 changed files with 7 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
sma/sunnywebboxcommunication.cpp
View File

@ -37,7 +37,7 @@
SunnyWebBoxCommunication::SunnyWebBoxCommunication(QObject *parent) : QObject(parent) SunnyWebBoxCommunication::SunnyWebBoxCommunication(QObject *parent) : QObject(parent)
{ {
m_udpSocket = new QUdpSocket(this); m_udpSocket = new QUdpSocket(this);
m_udpSocket->bind(QHostAddress::LocalHost, m_port); m_udpSocket->bind(QHostAddress::Any, m_port);
connect(m_udpSocket, &QUdpSocket::stateChanged, this, [this](QAbstractSocket::SocketState state) { connect(m_udpSocket, &QUdpSocket::stateChanged, this, [this](QAbstractSocket::SocketState state) {
emit socketConnected(state == QAbstractSocket::SocketState::ConnectedState); emit socketConnected(state == QAbstractSocket::SocketState::ConnectedState);
@ -48,12 +48,10 @@ SunnyWebBoxCommunication::SunnyWebBoxCommunication(QObject *parent) : QObject(pa
QHostAddress address; QHostAddress address;
quint16 port; quint16 port;
QByteArray data; QByteArray data;
while (m_udpSocket->hasPendingDatagrams()) { data.resize(m_udpSocket->pendingDatagramSize());
qCDebug(dcSma()) << "Received datagram"; int receivedBytes = m_udpSocket->readDatagram(data.data(), data.size(), &address, &port);
int receivedBytes = m_udpSocket->readDatagram(data.data(), 1000, &address, &port); if (receivedBytes == -1) {
if (receivedBytes == -1) { qCWarning(dcSma()) << "Error reading pending datagram";
qCWarning(dcSma()) << "Error reading pending datagram";
}
} }
datagramReceived(address, data); datagramReceived(address, data);
}); });
@ -69,6 +67,7 @@ int SunnyWebBoxCommunication::sendMessage(const QHostAddress &address, const QSt
obj["proc"] = procedure; obj["proc"] = procedure;
obj["id"] = requestId; obj["id"] = requestId;
obj["format"] = "JSON"; obj["format"] = "JSON";
doc.setObject(obj);
qCDebug(dcSma()) << "Send message" << doc.toJson() << address << m_port; qCDebug(dcSma()) << "Send message" << doc.toJson() << address << m_port;
m_udpSocket->writeDatagram(doc.toJson(), address, m_port); m_udpSocket->writeDatagram(doc.toJson(), address, m_port);
return requestId; return requestId;
@ -87,6 +86,7 @@ int SunnyWebBoxCommunication::sendMessage(const QHostAddress &address, const QSt
if (!params.isEmpty()) { if (!params.isEmpty()) {
obj.insert("params", params); obj.insert("params", params);
} }
doc.setObject(obj);
qCDebug(dcSma()) << "Send message" << doc.toJson() << address << m_port; qCDebug(dcSma()) << "Send message" << doc.toJson() << address << m_port;
m_udpSocket->writeDatagram(doc.toJson(), address, m_port); m_udpSocket->writeDatagram(doc.toJson(), address, m_port);
return requestId; return requestId;