Inbound: Close and remove the handler when it fails to start (#7223 )

https://github.com/XTLS/Xray-core/pull/7223#pullrequestreview-5722817769 --------- Co-authored-by: 风扇滑翔翼 <Fangliding.fshxy@outlook.com>
VLESS Multiplex (mux.cool): Increase default maxConcurrency to 128, maxReuseTimes to 1024, mainly for XDRIVE, XDNS, XMC, XICMP
2026-11-06 18:22:37 +00:00 · 2026-11-06 17:57:42 +00:00 · 2026-11-06 08:43:07 +00:00 · 2026-11-06 05:50:58 +00:00
2 changed files with 15 additions and 5 deletions
@@ -51,7 +51,17 @@ func (m *Manager) AddHandler(ctx context.Context, handler inbound.Handler) error
 	}

 	if m.running {
-		return handler.Start()
+		if err := handler.Start(); err != nil {
+			if len(tag) > 0 {
+				delete(m.taggedHandlers, tag)
+			} else {
+				m.untaggedHandlers = m.untaggedHandlers[:len(m.untaggedHandlers)-1]
+			}
+			if err := handler.Close(); err != nil {
+				errors.LogWarningInner(ctx, err, "failed to close handler ", tag)
+			}
+			return err
+		}
 	}

 	return nil
@@ -122,8 +122,8 @@ func NewHandler(ctx context.Context, config *core.OutboundHandlerConfig) (outbou
 			if config.Concurrency < 0 {
 				h.mux = &mux.ClientManager{Enabled: false}
 			}
-			if config.Concurrency == 0 {
-				config.Concurrency = 8 // same as before
+			if config.Concurrency >= 0 && config.Concurrency <= 128 {
+				config.Concurrency = 128
 			}
 			if config.Concurrency > 0 {
 				h.mux = &mux.ClientManager{
@@ -134,7 +134,7 @@ func NewHandler(ctx context.Context, config *core.OutboundHandlerConfig) (outbou
 							Dialer: h,
 							Strategy: mux.ClientStrategy{
 								MaxConcurrency: uint32(config.Concurrency),
-								MaxConnection:  128,
+								MaxConnection:  1024,
 							},
 						},
 					},
@@ -155,7 +155,7 @@ func NewHandler(ctx context.Context, config *core.OutboundHandlerConfig) (outbou
 							Dialer: h,
 							Strategy: mux.ClientStrategy{
 								MaxConcurrency: uint32(config.XudpConcurrency),
-								MaxConnection:  128,
+								MaxConnection:  1024,
 							},
 						},
 					},