|
|
|
@ -201,6 +201,13 @@ bool TagNXDNData::processFrame(const uint8_t* data, uint32_t len, uint32_t peerI
|
|
|
|
// repeat traffic to upstream peers
|
|
|
|
// repeat traffic to upstream peers
|
|
|
|
if (m_network->m_host->m_peerNetworks.size() > 0) {
|
|
|
|
if (m_network->m_host->m_peerNetworks.size() > 0) {
|
|
|
|
for (auto peer : m_network->m_host->m_peerNetworks) {
|
|
|
|
for (auto peer : m_network->m_host->m_peerNetworks) {
|
|
|
|
|
|
|
|
uint32_t peerId = peer.second->getPeerId();
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
// is this peer ignored?
|
|
|
|
|
|
|
|
if (!isPeerPermitted(peerId, lc, messageType, streamId)) {
|
|
|
|
|
|
|
|
continue;
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
peer.second->writeMaster({ NET_FUNC_PROTOCOL, NET_PROTOCOL_SUBFUNC_NXDN }, data, len, pktSeq, streamId);
|
|
|
|
peer.second->writeMaster({ NET_FUNC_PROTOCOL, NET_PROTOCOL_SUBFUNC_NXDN }, data, len, pktSeq, streamId);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|