miegl/mud
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

Compute rttvar for the next voip scheduler

Browse Source 
Signed-off-by: Adrien Gallouët <adrien@gallouet.fr>
This commit is contained in:
Adrien Gallouët
2018-04-06 16:24:24 +00:00
parent 7fde67f3d3
commit 1f25f12e4a
2 changed files with 13 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

17
mud.c
View File

@@ -1177,10 +1177,17 @@ mud_packet_check(struct mud *mud, unsigned char *data, size_t size)
return mud_decrypt_opt(&mud->crypto.private, &opt); return mud_decrypt_opt(&mud->crypto.private, &opt);
} }
static uint64_t static void
mud_compute_rtt(const uint64_t rtt, const uint64_t new_rtt) mud_compute_rtt(struct mud_path *path, const uint64_t rtt)
{ {
return rtt ? (new_rtt + UINT64_C(7) * rtt) >> 3 : new_rtt; if (path->rtt) {
path->rttvar = ((path->rttvar << 1) + path->rttvar
+ mud_abs_diff(path->rtt, rtt)) >> 2;
path->rtt = ((path->rtt << 3) - path->rtt + rtt) >> 3;
} else {
path->rttvar = rtt >> 1;
path->rtt = rtt;
}
} }
static void static void
@@ -1216,8 +1223,8 @@ mud_packet_recv(struct mud *mud, struct mud_path *path,
const uint64_t peer_sent = mud_read48(packet->hdr.sent); const uint64_t peer_sent = mud_read48(packet->hdr.sent);
if (peer_sent) if (peer_sent && now > peer_sent)
path->rtt = mud_compute_rtt(path->rtt, now - peer_sent); mud_compute_rtt(path, now - peer_sent);
switch (packet->hdr.code) { switch (packet->hdr.code) {
case mud_conf: case mud_conf:

1
mud.h
View File

@@ -28,6 +28,7 @@ struct mud_path {
uint64_t recv_max; uint64_t recv_max;
uint64_t recv_max_time; uint64_t recv_max_time;
uint64_t rtt; uint64_t rtt;
uint64_t rttvar;
uint64_t rst; uint64_t rst;
uint64_t r_rst; uint64_t r_rst;
uint64_t r_rms; uint64_t r_rms;