From 6417c771818aa3be402a627fad85a7ed70577f2b Mon Sep 17 00:00:00 2001 From: RPRX <63339210+RPRX@users.noreply.github.com> Date: Tue, 9 Sep 2025 13:31:19 +0000 Subject: [PATCH] Add runtime.Gosched() --- proxy/vless/inbound/inbound.go | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/proxy/vless/inbound/inbound.go b/proxy/vless/inbound/inbound.go index 77f96bf3..48a8a828 100644 --- a/proxy/vless/inbound/inbound.go +++ b/proxy/vless/inbound/inbound.go @@ -7,6 +7,7 @@ import ( "encoding/base64" "io" "reflect" + "runtime" "strconv" "strings" "time" @@ -196,6 +197,7 @@ func (h *Handler) GetReverse(a *vless.MemoryAccount) (*Reverse, error) { if r == nil { picker, _ := reverse.NewStaticMuxPicker() r = &Reverse{tag: a.Reverse.Tag, picker: picker, client: &mux.ClientManager{Picker: picker}} + runtime.Gosched() // prevents this outbound from becoming the default outbound if err := h.outboundHandlerManager.AddHandler(h.ctx, r); err != nil { return nil, err } @@ -639,7 +641,7 @@ func (r *Reverse) Tag() string { return r.tag } -func (r *Reverse) NewMux(ctx context.Context, link *transport.Link) error { // XTLS? vnext? users? +func (r *Reverse) NewMux(ctx context.Context, link *transport.Link) error { muxClient, err := mux.NewClientWorker(*link, mux.ClientStrategy{}) if err != nil { return errors.New("failed to create mux client worker").Base(err).AtWarning()