diff --git a/libraries/networking/src/LimitedNodeList.cpp b/libraries/networking/src/LimitedNodeList.cpp index aef732e5e1..2559c1b233 100644 --- a/libraries/networking/src/LimitedNodeList.cpp +++ b/libraries/networking/src/LimitedNodeList.cpp @@ -48,6 +48,7 @@ LimitedNodeList::LimitedNodeList(unsigned short socketListenPort, unsigned short _localSockAddr(), _publicSockAddr(), _stunSockAddr(STUN_SERVER_HOSTNAME, STUN_SERVER_PORT), + _packetReceiver(this), _numCollectedPackets(0), _numCollectedBytes(0), _packetStatTimer(), @@ -92,6 +93,8 @@ LimitedNodeList::LimitedNodeList(unsigned short socketListenPort, unsigned short // check the local socket right now updateLocalSockAddr(); + connect(_nodeSocket, &QUdpSocket::readyRead, _packetReceiver, &PacketReceiver::processDatagrams); + _packetStatTimer.start(); } diff --git a/libraries/networking/src/LimitedNodeList.h b/libraries/networking/src/LimitedNodeList.h index 7fc93b4f64..0df8f7232f 100644 --- a/libraries/networking/src/LimitedNodeList.h +++ b/libraries/networking/src/LimitedNodeList.h @@ -121,6 +121,8 @@ public: bool packetVersionAndHashMatch(const QByteArray& packet); + PacketReceiver& getPacketReceiver() { return _packetReceiver; } + // QByteArray byteArrayWithPopulatedHeader(PacketType::Value packetType) // { return byteArrayWithUUIDPopulatedHeader(packetType, _sessionUUID); } // int populatePacketHeader(QByteArray& packet, PacketType::Value packetType) @@ -305,6 +307,8 @@ protected: HifiSockAddr _publicSockAddr; HifiSockAddr _stunSockAddr; + PacketReceiver _packetReceiver; + // XXX can BandwidthRecorder be used for this? int _numCollectedPackets; int _numCollectedBytes;