[DEBUG] DO NOT MERGE: fix reclaim logic to be more aggressive

Signed-off-by: Fabio M. Di Nitto <fdinitto@redhat.com>
kronosnet · Oct 15, 2019 · ad71d9d · ad71d9d
1 parent 37913bc
commit ad71d9d
Showing 1 changed file with 4 additions and 4 deletions.
diff --git a/libknet/host.c b/libknet/host.c
@@ -567,8 +567,8 @@ static void _reclaim_old_defrag_buf(struct knet_host *host, seq_num_t seq_num)
 	seq_num_t head, tail; /* circular buffer indexes */
 	int i;
 
-	head = seq_num + (KNET_MAX_LINK * 2);
-	tail = seq_num + 1;
+	head = seq_num + 1;
+	tail = seq_num - (KNET_MAX_LINK + 1);
 
 	/*
 	 * expire old defrag buffers
@@ -579,12 +579,12 @@ static void _reclaim_old_defrag_buf(struct knet_host *host, seq_num_t seq_num)
 			 * head has done a rollover to 0+
 			 */
 			if (tail > head) {
-				if ((host->defrag_buf[i].pckt_seq <= head) || (host->defrag_buf[i].pckt_seq >= tail)) {
+				if ((host->defrag_buf[i].pckt_seq >= head) && (host->defrag_buf[i].pckt_seq <= tail)) {
 					printf("BLA1: seq: %u head: %u tail: %u wipe: %u\n", seq_num, head, tail, host->defrag_buf[i].pckt_seq);
 					host->defrag_buf[i].in_use = 0;
 				}
 			} else {
-				if ((host->defrag_buf[i].pckt_seq <= head) && (host->defrag_buf[i].pckt_seq >= tail)){
+				if ((host->defrag_buf[i].pckt_seq >= head) || (host->defrag_buf[i].pckt_seq <= tail)){
 					printf("BLA2: seq: %u head: %u tail: %u wipe: %u\n", seq_num, head, tail, host->defrag_buf[i].pckt_seq);
 					host->defrag_buf[i].in_use = 0;
 				}