SplitHTTP client: Add xmux (multiplex controller) for H3 & H2

infra/conf/transport_internet.go

@@ -234,6 +234,14 @@ type SplitHTTPConfig struct {
 	ScMinPostsIntervalMs *Int32Range       `json:"scMinPostsIntervalMs"`
 	NoSSEHeader          bool              `json:"noSSEHeader"`
 	XPaddingBytes        *Int32Range       `json:"xPaddingBytes"`
+	HttpMux              SplitHTTPMux      `json:"httpMux"`
+}
+
+type SplitHTTPMux struct {
+	RequestsPerConnection *Int32Range `json:"requestsPerConnection"`
+	ConnectionLifetimeMs  *Int32Range `json:"connectionLifetimeMs"`
+	Connections           *Int32Range `json:"connections"`
+	Concurrency           *Int32Range `json:"concurrency"`
 }
 
 func splithttpNewRandRangeConfig(input *Int32Range) *splithttp.RandRangeConfig {
@@ -257,6 +265,15 @@ func (c *SplitHTTPConfig) Build() (proto.Message, error) {
 	} else if c.Host == "" && c.Headers["Host"] != "" {
 		c.Host = c.Headers["Host"]
 	}
+
+	// Multiplexing config
+	muxProtobuf := splithttp.Multiplexing{
+		RequestsPerConnection: splithttpNewRandRangeConfig(c.HttpMux.RequestsPerConnection),
+		ConnectionLifetimeMs:  splithttpNewRandRangeConfig(c.HttpMux.ConnectionLifetimeMs),
+		Connections:           splithttpNewRandRangeConfig(c.HttpMux.Connections),
+		Concurrency:           splithttpNewRandRangeConfig(c.HttpMux.Concurrency),
+	}
+
 	config := &splithttp.Config{
 		Path:                 c.Path,
 		Host:                 c.Host,
@@ -266,6 +283,7 @@ func (c *SplitHTTPConfig) Build() (proto.Message, error) {
 		ScMinPostsIntervalMs: splithttpNewRandRangeConfig(c.ScMinPostsIntervalMs),
 		NoSSEHeader:          c.NoSSEHeader,
 		XPaddingBytes:        splithttpNewRandRangeConfig(c.XPaddingBytes),
+		HttpMux:              &muxProtobuf,
 	}
 	return config, nil
 }

transport/internet/splithttp/config.go

@@ -53,7 +53,6 @@ func (c *Config) GetRequestHeader() http.Header {
 
 	return header
 }
-
 func (c *Config) WriteResponseHeader(writer http.ResponseWriter) {
 	paddingLen := c.GetNormalizedXPaddingBytes().roll()
 	if paddingLen > 0 {
@@ -79,10 +78,8 @@ func (c *Config) GetNormalizedScMaxEachPostBytes() RandRangeConfig {
 			To:   1000000,
 		}
 	}
-
 	return *c.ScMaxEachPostBytes
 }
-
 func (c *Config) GetNormalizedScMinPostsIntervalMs() RandRangeConfig {
 	if c.ScMinPostsIntervalMs == nil || c.ScMinPostsIntervalMs.To == 0 {
 		return RandRangeConfig{
@@ -105,6 +102,49 @@ func (c *Config) GetNormalizedXPaddingBytes() RandRangeConfig {
 	return *c.XPaddingBytes
 }
 
+func (m *Multiplexing) GetNormalizedRequestsPerConnection() RandRangeConfig {
+	if m.RequestsPerConnection == nil {
+		return RandRangeConfig{
+			From: 0,
+			To:   0,
+		}
+	}
+
+	return *m.RequestsPerConnection
+}
+
+func (m *Multiplexing) GetNormalizedConnectionLifetimeMs() RandRangeConfig {
+	if m.ConnectionLifetimeMs == nil || m.ConnectionLifetimeMs.To == 0 {
+		return RandRangeConfig{
+			From: 0,
+			To:   0,
+		}
+	}
+	return *m.ConnectionLifetimeMs
+}
+
+func (m *Multiplexing) GetNormalizedConnections() RandRangeConfig {
+	if m.Connections == nil {
+		return RandRangeConfig{
+			From: 0,
+			To:   0,
+		}
+	}
+
+	return *m.Connections
+}
+
+func (m *Multiplexing) GetNormalizedConcurrency() RandRangeConfig {
+	if m.Concurrency == nil {
+		return RandRangeConfig{
+			From: 0,
+			To:   0,
+		}
+	}
+
+	return *m.Concurrency
+}
+
 func init() {
 	common.Must(internet.RegisterProtocolConfigCreator(protocolName, func() interface{} {
 		return new(Config)

transport/internet/splithttp/config.proto

@@ -15,9 +15,17 @@ message Config {
   RandRangeConfig scMinPostsIntervalMs = 6;
   bool noSSEHeader = 7;
   RandRangeConfig xPaddingBytes = 8;
+  Multiplexing httpMux = 9;
 }
 
 message RandRangeConfig {
     int32 from = 1;
     int32 to = 2;
 }
+
+message Multiplexing {
+  RandRangeConfig requestsPerConnection = 4;
+  RandRangeConfig connectionLifetimeMs = 5;
+  RandRangeConfig connections = 6;
+  RandRangeConfig concurrency = 7;
+}