summaryrefslogtreecommitdiff
path: root/src/lib
diff options
context:
space:
mode:
authorDimitri Staessens <dimitri@ouroboros.rocks>2022-04-09 11:33:39 +0200
committerSander Vrijders <sander@ouroboros.rocks>2022-04-13 08:54:15 +0200
commitbec8f9ac7d6ebefbce6bd4c882c0f9616f561f1c (patch)
tree7d53483be15c237f5899bde9729d289cb7860920 /src/lib
parent783d3adfdb0a074ae7a6e0dd37fe8efaf7e2b39a (diff)
downloadouroboros-bec8f9ac7d6ebefbce6bd4c882c0f9616f561f1c.tar.gz
ouroboros-bec8f9ac7d6ebefbce6bd4c882c0f9616f561f1c.zip
lib: Rename timerwheel_ack timerwheel_delayed_ack0.19.2
This makes it clear that we are scheduling a potential delayed acknowledgment instead of acknowledging a packet scheduled for retransmission. Also some small cosmetic fixes. Signed-off-by: Dimitri Staessens <dimitri@ouroboros.rocks> Signed-off-by: Sander Vrijders <sander@ouroboros.rocks>
Diffstat (limited to 'src/lib')
-rw-r--r--src/lib/frct.c6
-rw-r--r--src/lib/timerwheel.c6
2 files changed, 5 insertions, 7 deletions
diff --git a/src/lib/frct.c b/src/lib/frct.c
index c2dfbf6b..d543ccb0 100644
--- a/src/lib/frct.c
+++ b/src/lib/frct.c
@@ -925,15 +925,13 @@ static void __frcti_rcv(struct frcti * frcti,
pthread_rwlock_unlock(&frcti->lock);
if (fd != -1)
- timerwheel_ack(fd, frcti);
+ timerwheel_delayed_ack(fd, frcti);
return;
drop_packet:
pthread_rwlock_unlock(&frcti->lock);
-
- send_frct_pkt(frcti);
-
shm_rdrbuff_remove(ai.rdrb, idx);
+ send_frct_pkt(frcti);
return;
}
diff --git a/src/lib/timerwheel.c b/src/lib/timerwheel.c
index cf4e1eef..7f43210f 100644
--- a/src/lib/timerwheel.c
+++ b/src/lib/timerwheel.c
@@ -200,7 +200,7 @@ static void timerwheel_move(void)
if (r->seqno == r->frcti->rttseq) {
r->frcti->rto +=
- f->frcti->rto >> RTO_DIV;
+ r->frcti->rto >> RTO_DIV;
r->frcti->probe = false;
}
#ifdef PROC_FLOW_STATS
@@ -372,8 +372,8 @@ static int timerwheel_rxm(struct frcti * frcti,
return 0;
}
-static int timerwheel_ack(int fd,
- struct frcti * frcti)
+static int timerwheel_delayed_ack(int fd,
+ struct frcti * frcti)
{
struct timespec now;
struct ack * a;