Mirrors/overte-HifiExperiments
3
0
Fork 0
mirror of https://github.com/HifiExperiments/overte.git synced 2025-08-04 05:04:44 +02:00
Code Issues Projects Releases Packages Wiki Activity Actions

Add packet listeners to DatagramProcessor

Browse source
This commit is contained in:
Ryan Huffman 2015-07-08 10:02:34 -07:00
parent 74940a2132
commit b1c09d71f7
2 changed files with 28 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

26
interface/src/DatagramProcessor.cpp
View file

@ -23,11 +23,20 @@
#include "DatagramProcessor.h"
DatagramProcessor::DatagramProcessor(QObject* parent) :
QObject(parent)
QObject(parent),
_packetListenerMap()
{
}
void DatagramProcessor::registerPacketListener(Packet::Type type, QObject* object, QString methodName) {
if (packetListenerMap.contains(type)) {
qDebug() << "Warning: Registering a packet listener for packet type " << type
<< " that will remove a previously registered listener";
}
packetListenerMap[type] = QPair<QObject*, QString>(object, methodName);
}
void DatagramProcessor::processDatagrams() {
PerformanceWarning warn(Menu::getInstance()->isOptionChecked(MenuOption::PipelineWarnings),
"DatagramProcessor::processDatagrams()");
@ -160,7 +169,20 @@ void DatagramProcessor::processDatagrams() {
}
break;
default:
nodeList->processNodeData(senderSockAddr, incomingPacket);
//nodeList->processNodeData(senderSockAddr, incomingPacket);
if (packetListenerMap.contains(incomingType)) {
auto& listener = packetListenerMap[incomingType];
NLPacket packet;
bool success = QMetaObject::invokeMethod(listener.first, listener.second,
Q_ARG(std::unique_ptr<NLPacket>, packet),
Q_ARG(HifiSockAddr, senderSockAddr));
if (!success) {
qDebug() << "Error sending packet " << incomingType << " to listener: " << listener.first.name() << "::" << listener.second;
}
} else {
QDebug() << "No listener found for packet type: " << incomingType;
}
break;
}
}

4
interface/src/DatagramProcessor.h
View file

@ -27,10 +27,14 @@ public:
void resetCounters() { _inPacketCount = 0; _outPacketCount = 0; _inByteCount = 0; _outByteCount = 0; }
void shutdown() { _isShuttingDown = true; }
void registerPacketListener(Packet::Type type, QObject* object, QString methodName);
public slots:
void processDatagrams();
private:
QMap<Packet::Type, QPair<QObject*, QString>> packetListenerMap;
int _inPacketCount = 0;
int _outPacketCount = 0;
int _inByteCount = 0;