mirror of https://github.com/v2ray/v2ray-core
commit
a703c30f4f
|
@ -174,7 +174,9 @@ func transferResponse(timer signal.ActivityTimer, session *encoding.ServerSessio
|
||||||
|
|
||||||
// Process implements proxy.Inbound.Process().
|
// Process implements proxy.Inbound.Process().
|
||||||
func (v *Handler) Process(ctx context.Context, network net.Network, connection internet.Connection, dispatcher dispatcher.Interface) error {
|
func (v *Handler) Process(ctx context.Context, network net.Network, connection internet.Connection, dispatcher dispatcher.Interface) error {
|
||||||
common.Must(connection.SetReadDeadline(time.Now().Add(time.Second * 8)))
|
if err := connection.SetReadDeadline(time.Now().Add(time.Second * 8)); err != nil {
|
||||||
|
return err
|
||||||
|
}
|
||||||
|
|
||||||
reader := buf.NewBufferedReader(connection)
|
reader := buf.NewBufferedReader(connection)
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue