expose stream multi receive option

Author: noboruma

pkg/quic/c/msquic.c

@@ -45,6 +45,7 @@ struct QUICConfig {
 	int EnableDatagramReceive;
 	int DisableSendBuffering;
 	int MaxBytesPerKey;
+	char EnableMultiStream;
 };
 
 int64_t
@@ -410,6 +411,11 @@ LoadListenConfiguration(
 		Settings.IsSet.MaxBytesPerKey = TRUE;
 	}
 
+	if (cfg.EnableMultiStream != 0) {
+		Settings.StreamMultiReceiveEnabled = TRUE;
+		Settings.IsSet.StreamMultiReceiveEnabled = TRUE;
+	}
+
 	QUIC_CREDENTIAL_CONFIG_HELPER config = {0};
 	config.CredConfig.Flags = QUIC_CREDENTIAL_FLAG_NONE;
 

pkg/quic/connection.go

@@ -39,11 +39,12 @@ type Config struct {
 	TracePerfCounts               func([]string, []uint64)
 	TracePerfCountReport          time.Duration
 	//FailOnOpenStream       bool // deprecated in favor of DisableFailOnOpenStream
-	DisableFailOnOpenStream bool
-	EnableDatagramReceive   bool
-	DisableSendBuffering    bool // Do not allocate & copy sent buffers
-	MaxBytesPerKey          int64
-	EnableAppBuffering      bool // This flags is global across all listeners & dialers
+	DisableFailOnOpenStream  bool
+	EnableDatagramReceive    bool
+	DisableSendBuffering     bool // Do not allocate & copy sent buffers
+	MaxBytesPerKey           int64
+	EnableAppBuffering       bool // This flags is global across all listeners & dialers
+	EnableStreamMultiReceive bool
 }
 
 type ConnState struct {

pkg/quic/listener.go

@@ -19,6 +19,7 @@ type MsQuicListener struct {
 	failOnOpenStream bool
 	noAllocStream    bool
 	appBuffers       bool
+	multiReceives    bool
 }
 
 func newMsQuicListener(c C.HQUIC, config C.HQUIC, key, cert, alpn *C.char, failOnOpenStream, noAlloc, appBuffers bool) MsQuicListener {

pkg/quic/wrapper.go

@@ -144,6 +144,7 @@ func ListenAddr(addr string, cfg Config) (MsQuicListener, error) {
 		EnableDatagramReceive:         enableDatagram,
 		DisableSendBuffering:          disableSendBuffering,
 		MaxBytesPerKey:                C.int(cfg.MaxBytesPerKey),
+		EnableMultiStream:             C.char(cfg.EnableStreamMultiReceive),
 	})
 
 	if config == nil {