flush

DavidAlphaFox · Oct 4, 2021 · 167efec · 167efec
1 parent f7a6bcc
commit 167efec
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 3 deletions.
diff --git a/include/aiutp.hrl b/include/aiutp.hrl
@@ -31,7 +31,7 @@
 -define(KEEPALIVE_INTERVAL,29000). %ms
 % 29 seconds determined from measuring many home NAT devices
 -define(UTP_HEADER_SIZE,20).
--define(TIMEOUT_CHECK_INTERVAL,150).
+-define(TIMEOUT_CHECK_INTERVAL,100).
 -define(SEQ_NR_MASK,16#FFFF).
 -define(ACK_NR_MASK,16#FFFF).
 -define(TIMESTAMP_MASK, 16#FFFFFFFF).

diff --git a/src/aiutp_pcb.erl b/src/aiutp_pcb.erl
@@ -432,6 +432,8 @@ check_timeouts_0(#aiutp_pcb{time =Now,
  rto_timeout = RTOTimeout,
  fin_sent = FinSent,
  cur_window_packets = CurWindowPackets,
+ cur_window = CurWindow,
+ outbuf = OutBuf,
  brust = Brust} = PCB)->
  PCB0 =
  if (MaxWindowUser == 0 ) and
@@ -440,12 +442,14 @@ check_timeouts_0(#aiutp_pcb{time =Now,
  end,
  {Continue,PCB1} =
  if (Brust == false) and
- (RTOTimeout >0) and
+  (RTOTimeout >0) and
  (Now - RTOTimeout >= 0) ->
  check_timeouts_1(PCB0);
  (Brust == true) and
  (CurWindowPackets > 0) ->
- {true,aiutp_net:flush_packets(PCB)};
+ Iter = aiutp_buffer:head(OutBuf),
+ {CurWindow0,OutBuf0} = mark_need_resend(CurWindowPackets,CurWindow,Iter,OutBuf),
+ {true,aiutp_net:flush_packets(PCB#aiutp_pcb{cur_window = CurWindow0,outbuf = OutBuf0})};
  true -> {true,PCB0}
  end,
  if Continue == true ->