mirror of
https://github.com/HifiExperiments/overte.git
synced 2025-08-09 23:16:50 +02:00
Merge branch 'atp' of github.com:birarda/hifi into receive_packets
Conflicts: domain-server/src/DomainServer.cpp
This commit is contained in:
commit
d8bec3983f
2 changed files with 11 additions and 20 deletions
|
@ -726,31 +726,22 @@ void DomainServer::processConnectRequestPacket(QSharedPointer<NLPacket> packet)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
void DomainServer::processListRequestPacket(QSharedPointer<NLPacket> packet) {
|
void DomainServer::processListRequestPacket(QSharedPointer<NLPacket> packet, SharedNodePointer sendingNode) {
|
||||||
QDataStream packetStream(packet.data());
|
|
||||||
|
|
||||||
const QUuid& nodeUUID = packet->getSourceID();
|
NodeType_t throwawayNodeType;
|
||||||
|
HifiSockAddr nodePublicAddress, nodeLocalAddress;
|
||||||
|
|
||||||
auto limitedNodeList = DependencyManager::get<LimitedNodeList>();
|
QDataStream packetStream(packet.data());
|
||||||
|
|
||||||
SharedNodePointer checkInNode = limitedNodeList->nodeWithUUID(nodeUUID);
|
parseNodeData(packetStream, throwawayNodeType, nodePublicAddress, nodeLocalAddress, packet->getSenderSockAddr());
|
||||||
|
|
||||||
if (checkInNode) {
|
sendingNode->setPublicSocket(nodePublicAddress);
|
||||||
NodeType_t throwawayNodeType;
|
sendingNode->setLocalSocket(nodeLocalAddress);
|
||||||
HifiSockAddr nodePublicAddress, nodeLocalAddress;
|
|
||||||
|
|
||||||
QDataStream packetStream(packet.data());
|
QList<NodeType_t> nodeInterestList;
|
||||||
|
packetStream >> nodeInterestList;
|
||||||
|
|
||||||
parseNodeData(packetStream, throwawayNodeType, nodePublicAddress, nodeLocalAddress, packet->getSenderSockAddr());
|
sendDomainListToNode(sendingNode, packet->getSenderSockAddr(), nodeInterestList.toSet());
|
||||||
|
|
||||||
checkInNode->setPublicSocket(nodePublicAddress);
|
|
||||||
checkInNode->setLocalSocket(nodeLocalAddress);
|
|
||||||
|
|
||||||
QList<NodeType_t> nodeInterestList;
|
|
||||||
packetStream >> nodeInterestList;
|
|
||||||
|
|
||||||
sendDomainListToNode(checkInNode, packet->getSenderSockAddr(), nodeInterestList.toSet());
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
|
|
||||||
unsigned int DomainServer::countConnectedUsers() {
|
unsigned int DomainServer::countConnectedUsers() {
|
||||||
|
|
|
@ -58,7 +58,7 @@ public slots:
|
||||||
|
|
||||||
void processRequestAssignmentPacket(QSharedPointer<NLPacket> packet);
|
void processRequestAssignmentPacket(QSharedPointer<NLPacket> packet);
|
||||||
void processConnectRequestPacket(QSharedPointer<NLPacket> packet);
|
void processConnectRequestPacket(QSharedPointer<NLPacket> packet);
|
||||||
void processListRequestPacket(QSharedPointer<NLPacket> packet);
|
void processListRequestPacket(QSharedPointer<NLPacket> packet, SharedNodePointer sendingNode);
|
||||||
void processNodeJSONStatsPacket(QSharedPointer<NLPacket> packet, SharedNodePointer sendingNode);
|
void processNodeJSONStatsPacket(QSharedPointer<NLPacket> packet, SharedNodePointer sendingNode);
|
||||||
void processPathQueryPacket(QSharedPointer<NLPacket> packet);
|
void processPathQueryPacket(QSharedPointer<NLPacket> packet);
|
||||||
void processICEPingPacket(QSharedPointer<NLPacket> packet);
|
void processICEPingPacket(QSharedPointer<NLPacket> packet);
|
||||||
|
|
Loading…
Reference in a new issue