mirror of https://github.com/v2ray/v2ray-core
Reduce timeout for reading VMess header
parent
bbc41c5e63
commit
58dcfd5e84
|
@ -72,7 +72,7 @@ func (handler *VMessInboundHandler) AcceptConnections(listener *net.TCPListener)
|
||||||
func (handler *VMessInboundHandler) HandleConnection(connection *net.TCPConn) error {
|
func (handler *VMessInboundHandler) HandleConnection(connection *net.TCPConn) error {
|
||||||
defer connection.Close()
|
defer connection.Close()
|
||||||
|
|
||||||
connReader := v2net.NewTimeOutReader(120, connection)
|
connReader := v2net.NewTimeOutReader(16, connection)
|
||||||
requestReader := protocol.NewVMessRequestReader(handler.clients)
|
requestReader := protocol.NewVMessRequestReader(handler.clients)
|
||||||
|
|
||||||
request, err := requestReader.Read(connReader)
|
request, err := requestReader.Read(connReader)
|
||||||
|
@ -91,6 +91,7 @@ func (handler *VMessInboundHandler) HandleConnection(connection *net.TCPConn) er
|
||||||
readFinish.Lock()
|
readFinish.Lock()
|
||||||
writeFinish.Lock()
|
writeFinish.Lock()
|
||||||
|
|
||||||
|
connReader.SetTimeOut(120)
|
||||||
go handleInput(request, connReader, input, &readFinish)
|
go handleInput(request, connReader, input, &readFinish)
|
||||||
|
|
||||||
responseKey := md5.Sum(request.RequestKey)
|
responseKey := md5.Sum(request.RequestKey)
|
||||||
|
|
Loading…
Reference in New Issue