SagerNet/sing-mux
1
0
Fork 0
mirror of https://github.com/SagerNet/sing-mux.git synced 2025-04-03 03:47:40 +03:00
Code Issues Projects Releases Packages Wiki Activity Actions

Fix concurrent close on h2 server conn

Browse source
This commit is contained in:
世界 2023-04-27 22:15:49 +08:00
parent b0a6ffd840
commit 9836fc9b05
No known key found for this signature in database
GPG key ID: CD109927C34A63C4
1 changed files with 4 additions and 0 deletions
Download patch file Download diff file Expand all files Collapse all files

4
h2mux.go
View file

@ -8,6 +8,7 @@ import (
"net/http"
"net/url"
"os"
"sync"
"time"
"github.com/sagernet/sing/common/atomic"
@ -106,6 +107,7 @@ type h2MuxConnWrapper struct {
N.ExtendedConn
flusher http.Flusher
done chan struct{}
access sync.Mutex
}
func newHTTP2Wrapper(conn net.Conn, flusher http.Flusher) *h2MuxConnWrapper {
@ -143,6 +145,8 @@ func (w *h2MuxConnWrapper) WriteBuffer(buffer *buf.Buffer) error {
}
func (w *h2MuxConnWrapper) Close() error {
w.access.Lock()
defer w.access.Unlock()
select {
case <-w.done:
default: