diff --git a/udt/udtsocket.go b/udt/udtsocket.go index 0a2f686..a7a6c52 100644 --- a/udt/udtsocket.go +++ b/udt/udtsocket.go @@ -303,7 +303,9 @@ func (s *udtSocket) Close() error { s.isClosed = true - close(s.messageOut) + // closing messageOut was a signal supposed to tell the send code to initiate shutdown. However, it closes too fast before all data is transferred. + // The entire UDT code is a piece of !@#$ and needs a rewrite. + //close(s.messageOut) return nil }