diff --git a/interface/src/octree/OctreePacketProcessor.cpp b/interface/src/octree/OctreePacketProcessor.cpp index 4f3a4765ed..dba75b0c5f 100644 --- a/interface/src/octree/OctreePacketProcessor.cpp +++ b/interface/src/octree/OctreePacketProcessor.cpp @@ -26,32 +26,20 @@ OctreePacketProcessor::OctreePacketProcessor() { } // TODO implement packet processing in PacketType-specific methods -void OctreePacketProcessor::handleEntityDataPacket(QSharedPointer packet, HifiSockAddr senderSockAddr) { - SharedNodePointer sendingNode = DependencyManager::get()->nodeWithUUID(packet->getSourceID()); - if (sendingNode) { - processPacket(sendingNode, QByteArray::fromRawData(packet->getData(), packet->getSizeWithHeader())); - } +void OctreePacketProcessor::handleEntityDataPacket(QSharedPointer packet, SharedNodePointer senderNode, HifiSockAddr senderSockAddr) { + queueReceivedPacket(senderNode, QByteArray::fromRawData(packet->getData(), packet->getSizeWithHeader())); } -void OctreePacketProcessor::handleEntityErasePacket(QSharedPointer packet, HifiSockAddr senderSockAddr) { - SharedNodePointer sendingNode = DependencyManager::get()->nodeWithUUID(packet->getSourceID()); - if (sendingNode) { - processPacket(sendingNode, QByteArray::fromRawData(packet->getData(), packet->getSizeWithHeader())); - } +void OctreePacketProcessor::handleEntityErasePacket(QSharedPointer packet, SharedNodePointer senderNode, HifiSockAddr senderSockAddr) { + queueReceivedPacket(senderNode, QByteArray::fromRawData(packet->getData(), packet->getSizeWithHeader())); } -void OctreePacketProcessor::handleOctreeStatsPacket(QSharedPointer packet, HifiSockAddr senderSockAddr) { - SharedNodePointer sendingNode = DependencyManager::get()->nodeWithUUID(packet->getSourceID()); - if (sendingNode) { - processPacket(sendingNode, QByteArray::fromRawData(packet->getData(), packet->getSizeWithHeader())); - } +void OctreePacketProcessor::handleOctreeStatsPacket(QSharedPointer packet, SharedNodePointer senderNode, HifiSockAddr senderSockAddr) { + queueReceivedPacket(senderNode, QByteArray::fromRawData(packet->getData(), packet->getSizeWithHeader())); } -void OctreePacketProcessor::handleEnvironmentDataPacket(QSharedPointer packet, HifiSockAddr senderSockAddr) { - SharedNodePointer sendingNode = DependencyManager::get()->nodeWithUUID(packet->getSourceID()); - if (sendingNode) { - processPacket(sendingNode, QByteArray::fromRawData(packet->getData(), packet->getSizeWithHeader())); - } +void OctreePacketProcessor::handleEnvironmentDataPacket(QSharedPointer packet, SharedNodePointer senderNode, HifiSockAddr senderSockAddr) { + queueReceivedPacket(senderNode, QByteArray::fromRawData(packet->getData(), packet->getSizeWithHeader())); } void OctreePacketProcessor::processPacket(const SharedNodePointer& sendingNode, const QByteArray& packet) { diff --git a/interface/src/octree/OctreePacketProcessor.h b/interface/src/octree/OctreePacketProcessor.h index 73d9161a74..5274353b83 100644 --- a/interface/src/octree/OctreePacketProcessor.h +++ b/interface/src/octree/OctreePacketProcessor.h @@ -16,7 +16,7 @@ /// Handles processing of incoming voxel packets for the interface application. As with other ReceivedPacketProcessor classes /// the user is responsible for reading inbound packets and adding them to the processing queue by calling queueReceivedPacket() -class OctreePacketProcessor : public GenericThread { +class OctreePacketProcessor : public ReceivedPacketProcessor { Q_OBJECT public: OctreePacketProcessor(); @@ -30,9 +30,9 @@ protected: virtual void processPacket(const SharedNodePointer& sendingNode, const QByteArray& packet); private slots: - void handleEntityDataPacket(QSharedPointer packet, HifiSockAddr senderSockAddr); - void handleEntityErasePacket(QSharedPointer packet, HifiSockAddr senderSockAddr); - void handleOctreeStatsPacket(QSharedPointer packet, HifiSockAddr senderSockAddr); - void handleEnvironmentDataPacket(QSharedPointer packet, HifiSockAddr senderSockAddr); + void handleEntityDataPacket(QSharedPointer packet, SharedNodePointer senderNode, HifiSockAddr senderSockAddr); + void handleEntityErasePacket(QSharedPointer packet, SharedNodePointer senderNode, HifiSockAddr senderSockAddr); + void handleOctreeStatsPacket(QSharedPointer packet, SharedNodePointer senderNode, HifiSockAddr senderSockAddr); + void handleEnvironmentDataPacket(QSharedPointer packet, SharedNodePointer senderNode, HifiSockAddr senderSockAddr); }; #endif // hifi_OctreePacketProcessor_h