go-gost/x
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

fix kcp option

Browse Source
This commit is contained in:
ginuerzh 2023-12-25 22:08:41 +08:00
parent 9fa95cc8b3
commit 1117723913
2 changed files with 6 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
dialer/kcp/dialer.go
View File

@ -149,7 +149,9 @@ func (d *kcpDialer) initSession(ctx context.Context, addr net.Addr, conn net.Pac
smuxConfig.Version = config.SmuxVer
smuxConfig.MaxReceiveBuffer = config.SmuxBuf
smuxConfig.MaxStreamBuffer = config.StreamBuf
smuxConfig.KeepAliveInterval = time.Duration(config.KeepAlive) * time.Second
if config.KeepAlive > 0 {
smuxConfig.KeepAliveInterval = time.Duration(config.KeepAlive) * time.Second
}
var cc net.Conn = kcpconn
if !config.NoComp {
cc = kcp_util.CompStreamConn(kcpconn)

4
listener/kcp/listener.go
View File

@ -160,7 +160,9 @@ func (l *kcpListener) mux(conn net.Conn) {
smuxConfig.Version = l.md.config.SmuxVer
smuxConfig.MaxReceiveBuffer = l.md.config.SmuxBuf
smuxConfig.MaxStreamBuffer = l.md.config.StreamBuf
smuxConfig.KeepAliveInterval = time.Duration(l.md.config.KeepAlive) * time.Second
if l.md.config.KeepAlive > 0 {
smuxConfig.KeepAliveInterval = time.Duration(l.md.config.KeepAlive) * time.Second
}
if !l.md.config.NoComp {
conn = kcp_util.CompStreamConn(conn)