|
|
@ -185,7 +185,7 @@ func (h *Handler) Process(ctx context.Context, network net.Network, connection i
|
|
|
|
Status: log.AccessRejected,
|
|
|
|
Status: log.AccessRejected,
|
|
|
|
Reason: err,
|
|
|
|
Reason: err,
|
|
|
|
})
|
|
|
|
})
|
|
|
|
newError("invalid request from ", connection.RemoteAddr(), ": ", err).AtInfo().WriteToLog()
|
|
|
|
err = newError("invalid request from ", connection.RemoteAddr()).Base(err).AtInfo()
|
|
|
|
}
|
|
|
|
}
|
|
|
|
return err
|
|
|
|
return err
|
|
|
|
}
|
|
|
|
}
|
|
|
@ -252,7 +252,7 @@ func (h *Handler) generateCommand(ctx context.Context, request *protocol.Request
|
|
|
|
if h.inboundHandlerManager != nil {
|
|
|
|
if h.inboundHandlerManager != nil {
|
|
|
|
handler, err := h.inboundHandlerManager.GetHandler(ctx, tag)
|
|
|
|
handler, err := h.inboundHandlerManager.GetHandler(ctx, tag)
|
|
|
|
if err != nil {
|
|
|
|
if err != nil {
|
|
|
|
newError("failed to get detour handler: ", tag, err).AtWarning().WriteToLog()
|
|
|
|
newError("failed to get detour handler: ", tag).Base(err).AtWarning().WriteToLog()
|
|
|
|
return nil
|
|
|
|
return nil
|
|
|
|
}
|
|
|
|
}
|
|
|
|
proxyHandler, port, availableMin := handler.GetRandomInboundProxy()
|
|
|
|
proxyHandler, port, availableMin := handler.GetRandomInboundProxy()
|
|
|
|