diff --git a/udt/udtsocket_send.go b/udt/udtsocket_send.go index 5681503..ee55dea 100644 --- a/udt/udtsocket_send.go +++ b/udt/udtsocket_send.go @@ -178,7 +178,7 @@ func (s *udtSocketSend) reevalSendState() sendState { if cwnd > congestWindow { cwnd = congestWindow } - if cwnd >= uint(len(s.sendPktPend)) { + if uint(len(s.sendPktPend)) >= cwnd { return sendStateWaiting } }