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

rename the CC and send queue updater

Browse source
This commit is contained in:
Stephen Birarda 2015-07-29 16:12:50 -07:00
parent 5fc3e7dbf1
commit 35f00f9ba1
2 changed files with 4 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

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

@ -384,7 +384,7 @@ void Connection::processACK(std::unique_ptr<ControlPacket> controlPacket) {
}
// give this ACK to the congestion control and update the send queue parameters
updateCongestionControlAndSentQueue([this, ack](){
updateCongestionControlAndSendQueue([this, ack](){
_congestionControl->onAck(ack);
});
@ -453,7 +453,7 @@ void Connection::processNAK(std::unique_ptr<ControlPacket> controlPacket) {
_sendQueue->nak(start, end);
// give the loss to the congestion control object and update the send queue parameters
updateCongestionControlAndSentQueue([this, start, end](){
updateCongestionControlAndSendQueue([this, start, end](){
_congestionControl->onLoss(start, end);
});
@ -494,7 +494,7 @@ int Connection::estimatedTimeout() const {
return _congestionControl->_userDefinedRto ? _rtt + _rttVariance * 4 : _congestionControl->_rto;
}
void Connection::updateCongestionControlAndSentQueue(std::function<void ()> congestionCallback) {
void Connection::updateCongestionControlAndSendQueue(std::function<void ()> congestionCallback) {
// update the last sent sequence number in congestion control
_congestionControl->setSendCurrentSequenceNumber(_sendQueue->getCurrentSequenceNumber());

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

@ -64,7 +64,7 @@ private:
int estimatedTimeout() const;
void updateCongestionControlAndSentQueue(std::function<void()> congestionCallback);
void updateCongestionControlAndSendQueue(std::function<void()> congestionCallback);
int _synInterval; // Periodical Rate Control Interval, in microseconds