XDRIVE transport: A bunch of optimizations for Google Drive

app/proxyman/inbound/inbound.go

@@ -51,17 +51,7 @@ func (m *Manager) AddHandler(ctx context.Context, handler inbound.Handler) error
 	}
 
 	if m.running {
-		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 handler.Start()
 	}
 
 	return nil

app/proxyman/outbound/handler.go

@@ -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 <= 128 {
-				config.Concurrency = 128
+			if config.Concurrency == 0 {
+				config.Concurrency = 8 // same as before
 			}
 			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:  1024,
+								MaxConnection:  128,
 							},
 						},
 					},
@@ -155,7 +155,7 @@ func NewHandler(ctx context.Context, config *core.OutboundHandlerConfig) (outbou
 							Dialer: h,
 							Strategy: mux.ClientStrategy{
 								MaxConcurrency: uint32(config.XudpConcurrency),
-								MaxConnection:  1024,
+								MaxConnection:  128,
 							},
 						},
 					},