From 32e3d411ad1d5287433e43becb9827e07324fcb9 Mon Sep 17 00:00:00 2001
From: ffdfgdfg <heyingtingaaa@gmail.com>
Date: Sun, 24 Nov 2019 21:19:25 +0800
Subject: [PATCH] change initial window size

---
 lib/mux/conn.go | 10 +++++-----
 lib/mux/mux.go  |  2 +-
 2 files changed, 6 insertions(+), 6 deletions(-)

diff --git a/lib/mux/conn.go b/lib/mux/conn.go
index 1b7a920..f665248 100644
--- a/lib/mux/conn.go
+++ b/lib/mux/conn.go
@@ -190,7 +190,7 @@ func (Self *ReceiveWindow) New(mux *Mux) {
 	// initial a window for receive
 	Self.bufQueue.New()
 	Self.element = common.ListElementPool.Get()
-	Self.maxSize = common.MAXIMUM_SEGMENT_SIZE
+	Self.maxSize = common.MAXIMUM_SEGMENT_SIZE * 10
 	Self.mux = mux
 	Self.window.New()
 }
@@ -212,8 +212,8 @@ func (Self *ReceiveWindow) calcSize() {
 		conns := Self.mux.connMap.Size()
 		n := uint32(math.Float64frombits(atomic.LoadUint64(&Self.mux.latency)) *
 			Self.mux.bw.Get() / float64(conns))
-		if n < common.MAXIMUM_SEGMENT_SIZE*2 {
-			n = common.MAXIMUM_SEGMENT_SIZE * 2
+		if n < common.MAXIMUM_SEGMENT_SIZE*10 {
+			n = common.MAXIMUM_SEGMENT_SIZE * 10
 		}
 		bufLen := Self.bufQueue.Len()
 		if n < bufLen {
@@ -381,8 +381,8 @@ type SendWindow struct {
 
 func (Self *SendWindow) New(mux *Mux) {
 	Self.setSizeCh = make(chan struct{})
-	Self.maxSize = common.MAXIMUM_SEGMENT_SIZE
-	atomic.AddUint64(&Self.remainingWait, uint64(common.MAXIMUM_SEGMENT_SIZE)<<dequeueBits)
+	Self.maxSize = common.MAXIMUM_SEGMENT_SIZE * 10
+	atomic.AddUint64(&Self.remainingWait, uint64(common.MAXIMUM_SEGMENT_SIZE*10)<<dequeueBits)
 	Self.mux = mux
 	Self.window.New()
 }
diff --git a/lib/mux/mux.go b/lib/mux/mux.go
index b36ec4f..6c9c7fd 100644
--- a/lib/mux/mux.go
+++ b/lib/mux/mux.go
@@ -396,7 +396,7 @@ func (Self *bandwidth) StartRead() {
 	if Self.readStart.IsZero() {
 		Self.readStart = time.Now()
 	}
-	if Self.bufLength >= 3072000 {
+	if Self.bufLength >= common.MAXIMUM_SEGMENT_SIZE*300 {
 		Self.lastReadStart, Self.readStart = Self.readStart, time.Now()
 		Self.calcBandWidth()
 	}