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

Fix processing of multiple UDP datagrams in one go

master
Michael Zanetti 2020-10-12 15:27:06 +02:00
parent 9f68b37e50
commit b4b1f663b9
1 changed files with 10 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

19
udpcommander/integrationpluginudpcommander.cpp
View File

@ -116,15 +116,16 @@ void IntegrationPluginUdpCommander::readPendingDatagrams()
while (socket->hasPendingDatagrams()) { while (socket->hasPendingDatagrams()) {
datagram.resize(socket->pendingDatagramSize()); datagram.resize(socket->pendingDatagramSize());
socket->readDatagram(datagram.data(), datagram.size(), &sender, &senderPort); socket->readDatagram(datagram.data(), datagram.size(), &sender, &senderPort);
qCDebug(dcUdpCommander()) << "Incoming datatram" << datagram << "on" << thing->name() << "from" << sender.toString() << senderPort;
Event ev = Event(udpReceiverTriggeredEventTypeId, thing->id());
ParamList params;
params.append(Param(udpReceiverTriggeredEventDataParamTypeId, datagram));
ev.setParams(params);
emit emitEvent(ev);
// Send response for verification
socket->writeDatagram("OK\n", sender, senderPort);
} }
qCDebug(dcUdpCommander()) << thing->name() << "got command from" << sender.toString() << senderPort;
Event ev = Event(udpReceiverTriggeredEventTypeId, thing->id());
ParamList params;
params.append(Param(udpReceiverTriggeredEventDataParamTypeId, datagram));
ev.setParams(params);
emit emitEvent(ev);
// Send response for verification
socket->writeDatagram("OK\n", sender, senderPort);
} }