Mirrors/overte
3
0
Fork 0
mirror of https://github.com/overte-org/overte.git synced 2025-08-06 16:36:54 +02:00
Code Issues Projects Releases Packages Wiki Activity Actions

Move sequence number updating to PacketReceiver

Browse source
This commit is contained in:
Ryan Huffman 2015-07-14 14:40:39 -07:00
parent 10c5589629
commit 027d131b2a
2 changed files with 6 additions and 6 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
libraries/networking/src/LimitedNodeList.cpp
View file

@ -234,12 +234,6 @@ PacketSequenceNumber LimitedNodeList::getNextSequenceNumberForPacket(const QUuid
int LimitedNodeList::updateNodeWithDataFromPacket(QSharedPointer<NLPacket> packet, SharedNodePointer sendingNode) { int LimitedNodeList::updateNodeWithDataFromPacket(QSharedPointer<NLPacket> packet, SharedNodePointer sendingNode) {
QMutexLocker locker(&sendingNode->getMutex()); QMutexLocker locker(&sendingNode->getMutex());
// if this was a sequence numbered packet we should store the last seq number for
// a packet of this type for this node
if (SEQUENCE_NUMBERED_PACKETS.contains(packet->getType())) {
sendingNode->setLastSequenceNumberForPacketType(packet->readSequenceNumber(), packet->getType());
}
NodeData* linkedData = sendingNode->getLinkedData(); NodeData* linkedData = sendingNode->getLinkedData();
if (!linkedData && linkedDataCreateCallback) { if (!linkedData && linkedDataCreateCallback) {
linkedDataCreateCallback(sendingNode.data()); linkedDataCreateCallback(sendingNode.data());

6
libraries/networking/src/PacketReceiver.cpp
View file

@ -194,6 +194,12 @@ void PacketReceiver::processDatagrams() {
emit dataReceived(NodeType::Unassigned, packet->getSizeWithHeader()); emit dataReceived(NodeType::Unassigned, packet->getSizeWithHeader());
} }
// if this was a sequence numbered packet we should store the last seq number for
// a packet of this type for this node
if (SEQUENCE_NUMBERED_PACKETS.contains(packet->getType())) {
matchingNode->setLastSequenceNumberForPacketType(packet->readSequenceNumber(), packet->getType());
}
bool success = false; bool success = false;
if (matchingNode) { if (matchingNode) {