flush

DavidAlphaFox · Oct 4, 2021 · e466eb2 · e466eb2
1 parent 50bdd0b
commit e466eb2
Showing 1 changed file with 6 additions and 1 deletion.
diff --git a/src/aiutp_pcb.erl b/src/aiutp_pcb.erl
@@ -531,6 +531,7 @@ check_timeouts_1(#aiutp_pcb{time=Now,
  max_window = MaxWindow,
  outbuf = OutBuf,
  seq_nr = SeqNR,
+ brust = Brust,
  retransmit_count = RetransmitCount} = PCB) ->
 
  NewTimeout = RetransmitTimeout * 2,
@@ -556,7 +557,11 @@ check_timeouts_1(#aiutp_pcb{time=Now,
  fast_timeout = true,
  timeout_seq_nr = SeqNR
  },
- {true,aiutp_net:send_packet(aiutp_buffer:head(OutBuf0), PCB1)};
+ PCB2 =
+ if Brust == true -> aiutp_net:flush_packets(PCB);
+ true -> aiutp_net:send_packet(aiutp_buffer:head(OutBuf0), PCB1)
+ end,
+ {true,PCB2};
  true -> {true,PCB0}
  end.
 write(_,#aiutp_pcb{state = State} = PCB)