Mirrors/overte-lubosz
3
0
Fork 0
mirror of https://github.com/lubosz/overte.git synced 2025-08-12 17:24:01 +02:00
Code Issues Projects Releases Packages Wiki Activity Actions

Implement Packet::setSequenceNumber

Browse source
This commit is contained in:
Atlante45 2015-07-28 14:00:59 -07:00
parent 71004ef519
commit ca99699674
3 changed files with 8 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
libraries/networking/src/udt/Packet.cpp
View file

@ -112,6 +112,11 @@ Packet& Packet::operator=(Packet&& other) {
return *this; return *this;
} }
void Packet::setSequenceNumber(SequenceNumber sequenceNumber) {
_sequenceNumber = sequenceNumber;
writeHeader();
}
static const uint32_t CONTROL_BIT_MASK = 1 << (sizeof(Packet::SequenceNumberAndBitField) - 1); static const uint32_t CONTROL_BIT_MASK = 1 << (sizeof(Packet::SequenceNumberAndBitField) - 1);
static const uint32_t RELIABILITY_BIT_MASK = 1 << (sizeof(Packet::SequenceNumberAndBitField) - 2); static const uint32_t RELIABILITY_BIT_MASK = 1 << (sizeof(Packet::SequenceNumberAndBitField) - 2);
static const uint32_t MESSAGE_BIT_MASK = 1 << (sizeof(Packet::SequenceNumberAndBitField) - 3); static const uint32_t MESSAGE_BIT_MASK = 1 << (sizeof(Packet::SequenceNumberAndBitField) - 3);
@ -130,6 +135,7 @@ void Packet::writeHeader() {
// grab pointer to current SequenceNumberAndBitField // grab pointer to current SequenceNumberAndBitField
SequenceNumberAndBitField* seqNumBitField = reinterpret_cast<SequenceNumberAndBitField*>(_packet.get()); SequenceNumberAndBitField* seqNumBitField = reinterpret_cast<SequenceNumberAndBitField*>(_packet.get());
// 0 for data packets
*seqNumBitField &= ~CONTROL_BIT_MASK; *seqNumBitField &= ~CONTROL_BIT_MASK;
if (_isPartOfMessage) { if (_isPartOfMessage) {

2
libraries/networking/src/udt/Packet.h
View file

@ -52,7 +52,7 @@ public:
bool isReliable() const { return _isReliable; } bool isReliable() const { return _isReliable; }
SequenceNumber getSequenceNumber() const { return _sequenceNumber; } SequenceNumber getSequenceNumber() const { return _sequenceNumber; }
void setSequenceNumber(); void setSequenceNumber(SequenceNumber sequenceNumber);
protected: protected:
Packet(qint64 size, bool isReliable = false, bool isPartOfMessage = false); Packet(qint64 size, bool isReliable = false, bool isPartOfMessage = false);

2
libraries/networking/src/udt/SendQueue.cpp
View file

@ -131,7 +131,7 @@ void SendQueue::sendNextPacket() {
_lastSendTimestamp = sendTime; _lastSendTimestamp = sendTime;
if (_nextPacket) { if (_nextPacket) {
_nextPacket->writeSequenceNumber(++_currentSequenceNumber); _nextPacket->setSequenceNumber(++_currentSequenceNumber);
sendPacket(*_nextPacket); sendPacket(*_nextPacket);
_atomicCurrentSequenceNumber.store((uint32_t) _currentSequenceNumber); _atomicCurrentSequenceNumber.store((uint32_t) _currentSequenceNumber);