Showing the changes to assignment-client/src/AssignmentClientMonitor.cpp (1 of 1 file). Show all
Unified · Split
| @@ -195,8 +195,8 @@ void AssignmentClientMonitor::checkSpares() { · 194 unmodified lines | ||
| 195 | 195 | SharedNodePointer childNode = nodeList->nodeWithUUID(aSpareId); |
| 196 | 196 | childNode->activateLocalSocket(); |
| 197 | 197 | |
| 198 | − QByteArray diePacket = nodeList->byteArrayWithPopulatedHeader(PacketTypeStopNode); | |
| 199 | − nodeList->writeUnverifiedDatagram(diePacket, childNode); | |
| 198 | + NodeListPacket diePacket = NodeListPacket::create(PacketType::StopNode); | |
| 199 | + nodeList->sendPacket(diePacket, childNode); | |
| 200 | 200 | } |
| 201 | 201 | } |
| 202 | 202 | } |
| @@ -229,8 +229,9 @@ void AssignmentClientMonitor::readPendingDatagrams() { · 26 unmodified lines | ||
| 229 | 229 | } else { |
| 230 | 230 | // tell unknown assignment-client child to exit. |
| 231 | 231 | qDebug() << "asking unknown child to exit."; |
| 232 | − QByteArray diePacket = nodeList->byteArrayWithPopulatedHeader(PacketTypeStopNode); | |
| 233 | − nodeList->writeUnverifiedDatagram(diePacket, senderSockAddr); | |
| 232 | + | |
| 233 | + NodeListPacket diePacket = NodeListPacket::create(PacketType::StopNode); | |
| 234 | + nodeList->sendPacket(diePacket, childNode); | |
| 234 | 235 | } |
| 235 | 236 | } |
| 236 | 237 | } |