Fix #337

2016-12-24 22:04:09 +01:00 · 2016-12-24 22:04:09 +01:00 · 4e224d64c6
parent 3ddacbb9c9
commit 4e224d64c6
1 changed files with 1 additions and 1 deletions
--- a/transport/internet/kcp/connection.go
+++ b/transport/internet/kcp/connection.go
@ -315,7 +315,7 @@ func (v *Connection) Write(b []byte) (int, error) {
 		}

 		duration := time.Duration(time.Minute)
-		if !v.rd.IsZero() {
+		if !v.wd.IsZero() {
 			duration = v.wd.Sub(time.Now())
 			if duration < 0 {
 				return totalWritten, ErrIOTimeout