Mirrors/overte-JulianGro
3
0
Fork 0
mirror of https://github.com/JulianGro/overte.git synced 2025-08-18 20:34:30 +02:00
Code Issues Projects Releases Packages Wiki Activity Actions

Update message handling to use insertion sort

Browse source
This commit is contained in:
Ryan Huffman 2015-08-30 20:03:15 -07:00
parent b81f996366
commit fc80745c08
1 changed files with 15 additions and 10 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

25
libraries/networking/src/udt/Connection.cpp
View file

@ -825,30 +825,35 @@ void PendingReceivedMessage::enqueuePacket(std::unique_ptr<Packet> packet) {
return;
}
auto sequenceNumber = packet->getSequenceNumber();
if (packet->getPacketPosition() == Packet::PacketPosition::FIRST) {
_hasFirstSequenceNumber = true;
_firstSequenceNumber = packet->getSequenceNumber();
_firstSequenceNumber = sequenceNumber;
} else if (packet->getPacketPosition() == Packet::PacketPosition::LAST) {
_hasLastSequenceNumber = true;
_lastSequenceNumber = packet->getSequenceNumber();
_lastSequenceNumber = sequenceNumber;
} else if (packet->getPacketPosition() == Packet::PacketPosition::ONLY) {
_hasFirstSequenceNumber = true;
_hasLastSequenceNumber = true;
_firstSequenceNumber = packet->getSequenceNumber();
_lastSequenceNumber = packet->getSequenceNumber();
_firstSequenceNumber = sequenceNumber;
_lastSequenceNumber = sequenceNumber;
}
_packets.push_back(std::move(packet));
// Insert into the packets list in sorted order. Because we generally expect to receive packets in order, begin
// searching from the end of the list.
auto it = _packets.rbegin();
for (auto rend = _packets.rend(); it != rend; ++it) {
if (sequenceNumber > (*it)->getSequenceNumber()) {
break;
}
}
_packets.insert(it.base(), std::move(packet));
if (_hasFirstSequenceNumber && _hasLastSequenceNumber) {
auto numPackets = udt::seqlen(_firstSequenceNumber, _lastSequenceNumber);
if (uint64_t(numPackets) == _packets.size()) {
_isComplete = true;
// Sort packets by sequence number
_packets.sort([](std::unique_ptr<Packet>& a, std::unique_ptr<Packet>& b) {
return a->getSequenceNumber() < b->getSequenceNumber();
});
}
}
}