wjqserver/touka
1
0
Fork 0
mirror of https://github.com/infinite-iroha/touka.git synced 2026-06-13 15:47:38 +08:00
Code Issues Projects Releases Packages Wiki Activity Actions 13

refactor: simplify reverse proxy bridged connection handling by removing unused bufio

Browse source
This commit is contained in:
wjqserver 2026-04-02 18:50:27 +08:00
parent a9c1662333
commit 50c6a23614
1 changed files with 0 additions and 6 deletions
Download patch file Download diff file Expand all files Collapse all files

6
reverseproxy.go
View file

@ -5,7 +5,6 @@
package touka package touka
import ( import (
"bufio"
"context" "context"
"crypto/rand" "crypto/rand"
"encoding/base64" "encoding/base64"
@ -1011,7 +1010,6 @@ func (p *reverseProxyHandler) handleBridgedExtendedConnectResponse(c *Context, r
} }
conn := reverseProxyH2ReadWriteCloser{ReadCloser: bridge.body, ResponseWriter: c.Writer} conn := reverseProxyH2ReadWriteCloser{ReadCloser: bridge.body, ResponseWriter: c.Writer}
brw := bufio.NewReadWriter(bufio.NewReaderSize(conn, 1), bufio.NewWriterSize(conn, 1))
backConnClosed := make(chan struct{}) backConnClosed := make(chan struct{})
go func() { go func() {
@ -1025,10 +1023,6 @@ func (p *reverseProxyHandler) handleBridgedExtendedConnectResponse(c *Context, r
defer conn.Close() defer conn.Close()
defer backConn.Close() defer backConn.Close()
if err := brw.Flush(); err != nil {
return &reverseProxyStatusError{status: http.StatusBadGateway, err: err}
}
errc := make(chan error, 2) errc := make(chan error, 2)
copyer := switchProtocolCopier{user: conn, backend: backConn} copyer := switchProtocolCopier{user: conn, backend: backConn}
go copyer.copyToBackend(errc) go copyer.copyToBackend(errc)