github
/
Xray-core
mirror of https://github.com/XTLS/Xray-core
1
0
Fork 0
Code Issues Releases Wiki Activity

Add runtime.Gosched()

pull/5101/head
RPRX 2025-09-09 13:31:19 +00:00 committed by GitHub
parent eda8be601f
commit 6417c77181
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 3 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
proxy/vless/inbound/inbound.go
View File

@ -7,6 +7,7 @@ import (
"encoding/base64" "encoding/base64"
"io" "io"
"reflect" "reflect"
"runtime"
"strconv" "strconv"
"strings" "strings"
"time" "time"
@ -196,6 +197,7 @@ func (h *Handler) GetReverse(a *vless.MemoryAccount) (*Reverse, error) {
if r == nil { if r == nil {
picker, _ := reverse.NewStaticMuxPicker() picker, _ := reverse.NewStaticMuxPicker()
r = &Reverse{tag: a.Reverse.Tag, picker: picker, client: &mux.ClientManager{Picker: picker}} 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 { if err := h.outboundHandlerManager.AddHandler(h.ctx, r); err != nil {
return nil, err return nil, err
} }
@ -639,7 +641,7 @@ func (r *Reverse) Tag() string {
return r.tag 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{}) muxClient, err := mux.NewClientWorker(*link, mux.ClientStrategy{})
if err != nil { if err != nil {
return errors.New("failed to create mux client worker").Base(err).AtWarning() return errors.New("failed to create mux client worker").Base(err).AtWarning()