update kcp

listener/kcp/listener.go

@@ -146,7 +146,9 @@ func (l *kcpListener) mux(conn net.Conn) {
 	defer conn.Close()
 
 	smuxConfig := smux.DefaultConfig()
-	smuxConfig.MaxReceiveBuffer = l.md.config.SockBuf
+	smuxConfig.Version = l.md.config.SmuxVer
+	smuxConfig.MaxReceiveBuffer = l.md.config.SmuxBuf
+	smuxConfig.MaxStreamBuffer = l.md.config.StreamBuf
 	smuxConfig.KeepAliveInterval = time.Duration(l.md.config.KeepAlive) * time.Second
 
 	if !l.md.config.NoComp {

listener/kcp/metadata.go

@@ -19,10 +19,18 @@ type metadata struct {
 
 func (l *kcpListener) parseMetadata(md mdata.Metadata) (err error) {
 	const (
-		backlog = "backlog"
-		config  = "config"
+		backlog    = "backlog"
+		config     = "config"
+		configFile = "c"
 	)
 
+	if file := mdx.GetString(md, configFile); file != "" {
+		l.md.config, err = kcp_util.ParseFromFile(file)
+		if err != nil {
+			return
+		}
+	}
+
 	if m := mdx.GetStringMap(md, config); len(m) > 0 {
 		b, err := json.Marshal(m)
 		if err != nil {