diff --git a/NXDNReflector/NXDNReflector.cpp b/NXDNReflector/NXDNReflector.cpp index f1337de..f6d4152 100644 --- a/NXDNReflector/NXDNReflector.cpp +++ b/NXDNReflector/NXDNReflector.cpp @@ -280,11 +280,11 @@ void CNXDNReflector::run() unsigned int prt = (*it)->m_port; if (addr.s_addr != address.s_addr || prt != port) nxdnNetwork.write(buffer, len, addr, prt); - - if (m_nxCoreNetwork != NULL) - m_nxCoreNetwork->write(buffer, len); } + if (m_nxCoreNetwork != NULL) + m_nxCoreNetwork->write(buffer, len); + if ((buffer[9U] & 0x08U) == 0x08U) { LogMessage("Received end of transmission"); watchdogTimer.stop();