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

Fix http proxy server

Browse source
This commit is contained in:
世界 2022-07-14 18:20:52 +08:00
parent 029ab1ce4f
commit 51de48ed21
No known key found for this signature in database
GPG key ID: CD109927C34A63C4
1 changed files with 15 additions and 15 deletions
Download patch file Download diff file Expand all files Collapse all files

30
protocol/http/handshake.go
View file

@ -45,21 +45,6 @@ func HandleConnection(ctx context.Context, conn net.Conn, reader *std_bufio.Read
} }
} }
var requestConn net.Conn
if reader.Buffered() > 0 {
_buffer := buf.StackNewSize(reader.Buffered())
defer common.KeepAlive(_buffer)
buffer := common.Dup(_buffer)
defer buffer.Release()
_, err = buffer.ReadFullFrom(reader, reader.Buffered())
if err != nil {
return err
}
requestConn = bufio.NewCachedConn(conn, buffer)
} else {
requestConn = conn
}
if request.Method == "CONNECT" { if request.Method == "CONNECT" {
portStr := request.URL.Port() portStr := request.URL.Port()
if portStr == "" { if portStr == "" {
@ -72,6 +57,21 @@ func HandleConnection(ctx context.Context, conn net.Conn, reader *std_bufio.Read
} }
metadata.Protocol = "http" metadata.Protocol = "http"
metadata.Destination = destination metadata.Destination = destination
var requestConn net.Conn
if reader.Buffered() > 0 {
_buffer := buf.StackNewSize(reader.Buffered())
defer common.KeepAlive(_buffer)
buffer := common.Dup(_buffer)
defer buffer.Release()
_, err = buffer.ReadFullFrom(reader, reader.Buffered())
if err != nil {
return err
}
requestConn = bufio.NewCachedConn(conn, buffer)
} else {
requestConn = conn
}
return handler.NewConnection(ctx, requestConn, metadata) return handler.NewConnection(ctx, requestConn, metadata)
} }