ShaYmez/NXDNClients
1
0
Fork 0
mirror of https://github.com/ShaYmez/NXDNClients.git synced 2025-06-02 14:22:25 -04:00
Code Issues Projects Releases Wiki Activity

Validate the traffic being processed from the NXDN network.

Browse Source
This commit is contained in:
Jonathan Naylor 2018-03-15 18:49:15 +00:00
parent 2303e3e1e5
commit 50d109aefe
1 changed files with 4 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
NXDNReflector/NXDNReflector.cpp
View File

@ -205,7 +205,7 @@ void CNXDNReflector::run()
if (len > 0U) { if (len > 0U) {
CNXDNRepeater* rpt = findRepeater(address, port); CNXDNRepeater* rpt = findRepeater(address, port);
if (::memcmp(buffer, "NXDNP", 5U) == 0) { if (::memcmp(buffer, "NXDNP", 5U) == 0 && len == 15U) {
if (rpt == NULL) { if (rpt == NULL) {
rpt = new CNXDNRepeater; rpt = new CNXDNRepeater;
rpt->m_timer.start(); rpt->m_timer.start();
@ -215,14 +215,13 @@ void CNXDNReflector::run()
m_repeaters.push_back(rpt); m_repeaters.push_back(rpt);
LogMessage("Adding %s (%s:%u)", rpt->m_callsign.c_str(), ::inet_ntoa(address), port); LogMessage("Adding %s (%s:%u)", rpt->m_callsign.c_str(), ::inet_ntoa(address), port);
} } else {
else {
rpt->m_timer.start(); rpt->m_timer.start();
} }
// Return the poll // Return the poll
nxdnNetwork.write(buffer, len, address, port); nxdnNetwork.write(buffer, len, address, port);
} else if (::memcmp(buffer, "NXDNU", 5U) == 0) { } else if (::memcmp(buffer, "NXDNU", 5U) == 0 && len == 15U) {
if (rpt != NULL) { if (rpt != NULL) {
std::string callsign = std::string((char*)(buffer + 5U), 10U); std::string callsign = std::string((char*)(buffer + 5U), 10U);
LogMessage("Removing %s (%s:%u)", callsign.c_str(), ::inet_ntoa(address), port); LogMessage("Removing %s (%s:%u)", callsign.c_str(), ::inet_ntoa(address), port);
@ -236,7 +235,7 @@ void CNXDNReflector::run()
delete rpt; delete rpt;
} }
} else if (::memcmp(buffer, "NXDND", 5U) == 0) { } else if (::memcmp(buffer, "NXDND", 5U) == 0 && len == 43U) {
if (rpt != NULL) { if (rpt != NULL) {
rpt->m_timer.start(); rpt->m_timer.start();