anotherim/anotherim-desktop
2
0
Fork 0
Code Issues Pull requests Actions Packages Projects Releases Wiki Activity

Fix REMB calculation

Browse source
This commit is contained in:
Marvin W 2021-11-10 23:12:19 +01:00
parent cfe43de5d5
commit 1b157a20ab
No known key found for this signature in database
GPG key ID: 072E9235DB996F2A
1 changed files with 5 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

7
plugins/rtp/src/stream.vala
View file

@ -201,12 +201,15 @@ public class Dino.Plugins.Rtp.Stream : Xmpp.Xep.JingleRtp.Stream {
source_stat.get_uint64("packets-received", out packets_received); source_stat.get_uint64("packets-received", out packets_received);
source_stat.get_uint64("octets-received", out octets_received); source_stat.get_uint64("octets-received", out octets_received);
int new_lost = packets_lost - last_packets_lost; int new_lost = packets_lost - last_packets_lost;
if (new_lost < 0) new_lost = 0;
uint64 new_received = packets_received - last_packets_received; uint64 new_received = packets_received - last_packets_received;
if (packets_received < last_packets_received) new_received = 0;
uint64 new_octets = octets_received - last_octets_received; uint64 new_octets = octets_received - last_octets_received;
if (new_received == 0) continue; if (octets_received < last_octets_received) octets_received = 0;
last_packets_lost = packets_lost; last_packets_lost = packets_lost;
last_packets_received = packets_received; last_packets_received = packets_received;
last_octets_received = octets_received; last_octets_received = octets_received;
if (new_received == 0) continue;
double loss_rate = (double)new_lost / (double)(new_lost + new_received); double loss_rate = (double)new_lost / (double)(new_lost + new_received);
if (new_lost <= 0 || loss_rate < 0.02) { if (new_lost <= 0 || loss_rate < 0.02) {
remb = (uint)(1.08 * (double)remb); remb = (uint)(1.08 * (double)remb);
@ -256,7 +259,7 @@ public class Dino.Plugins.Rtp.Stream : Xmpp.Xep.JingleRtp.Stream {
uint8 br_exp = data[5] >> 2; uint8 br_exp = data[5] >> 2;
uint32 br_mant = (((uint32)data[5] & 0x3) << 16) + ((uint32)data[6] << 8) + (uint32)data[7]; uint32 br_mant = (((uint32)data[5] & 0x3) << 16) + ((uint32)data[6] << 8) + (uint32)data[7];
uint bitrate = (br_mant << br_exp) / 1000; uint bitrate = (br_mant << br_exp) / 1000;
self.input_device.update_bitrate(self.payload_type, bitrate * 8); self.input_device.update_bitrate(self.payload_type, bitrate);
} }
} }