add openCloseTimeout for stream open and close

xtaci · xtaci · commit bf0d5ac63f6f · 2023-02-14T21:56:01.000+08:00
diff --git a/session.go b/session.go
@@ -14,6 +14,7 @@ import (
 const (
 	defaultAcceptBacklog = 1024
 	maxShaperSize        = 1024
+	openCloseTimeout     = 30 * time.Second // stream open/close timeout
 )
 
 var (
@@ -514,7 +515,7 @@ func (s *Session) sendLoop() {
 // writeFrame writes the frame to the underlying connection
 // and returns the number of bytes written if successful
 func (s *Session) writeFrame(f Frame) (n int, err error) {
-	return s.writeFrameInternal(f, time.After(s.config.KeepAliveTimeout), 0)
+	return s.writeFrameInternal(f, time.After(openCloseTimeout), 0)
 }
 
 // internal writeFrame version to support deadline used in keepalive

Original file line number	Diff line number	Diff line change
`@@ -14,6 +14,7 @@ import (`
`14`	`14`	`const (`
`15`	`15`	`defaultAcceptBacklog = 1024`
`16`	`16`	`maxShaperSize = 1024`
	`17`	`+ openCloseTimeout = 30 * time.Second // stream open/close timeout`
`17`	`18`	`)`
`18`	`19`
`19`	`20`	`var (`
`@@ -514,7 +515,7 @@ func (s *Session) sendLoop() {`
`514`	`515`	`// writeFrame writes the frame to the underlying connection`
`515`	`516`	`// and returns the number of bytes written if successful`
`516`	`517`	`func (s *Session) writeFrame(f Frame) (n int, err error) {`
`517`		`- return s.writeFrameInternal(f, time.After(s.config.KeepAliveTimeout), 0)`
	`518`	`+ return s.writeFrameInternal(f, time.After(openCloseTimeout), 0)`
`518`	`519`	`}`
`519`	`520`
`520`	`521`	`// internal writeFrame version to support deadline used in keepalive`