improve network latency by introducing stream mode

xtaci · Jul 25, 2016 · 5ee659d · 5ee659d
1 parent 1a596f5
commit 5ee659d
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 0 deletions.
diff --git a/client/main.go b/client/main.go
@@ -231,6 +231,7 @@ func main() {
 			}
 			kcpconn, err := kcp.DialWithOptions(c.String("remoteaddr"), block, c.Int("datashard"), c.Int("parityshard"))
 			checkError(err)
+			kcpconn.SetStreamMode(true)
 			kcpconn.SetNoDelay(nodelay, interval, resend, nc)
 			kcpconn.SetWindowSize(c.Int("sndwnd"), c.Int("rcvwnd"))
 			kcpconn.SetMtu(c.Int("mtu"))

diff --git a/server/main.go b/server/main.go
@@ -249,6 +249,7 @@ func main() {
 		for {
 			if conn, err := lis.Accept(); err == nil {
 				log.Println("remote address:", conn.RemoteAddr())
+				conn.SetStreamMode(true)
 				conn.SetNoDelay(nodelay, interval, resend, nc)
 				conn.SetMtu(c.Int("mtu"))
 				conn.SetWindowSize(c.Int("sndwnd"), c.Int("rcvwnd"))