simplify connection reuse settings

shell/point/point.go

@@ -16,7 +16,6 @@ import (
 	"github.com/v2ray/v2ray-core/common/retry"
 	"github.com/v2ray/v2ray-core/proxy"
 	proxyrepo "github.com/v2ray/v2ray-core/proxy/repo"
-	"github.com/v2ray/v2ray-core/transport"
 )
 
 // Point shell of V2Ray.
@@ -40,7 +39,7 @@ func NewPoint(pConfig *Config) (*Point, error) {
 	vpoint.listen = pConfig.ListenOn
 
 	if pConfig.TransportConfig != nil {
-		transport.ApplyConfig(pConfig.TransportConfig)
+		pConfig.TransportConfig.Apply()
 	}
 
 	if pConfig.LogConfig != nil {

testing/scenarios/data/test_4_client.json

@@ -31,9 +31,6 @@
     }
   },
   "transport": {
-    "streamType": "tcp",
+    "connectionReuse": true
-    "settings": {
-      "connectionReuse": true
-    }
   }
 }

testing/scenarios/data/test_4_server.json

@@ -40,9 +40,6 @@
     }
   ],
   "transport": {
-    "streamType": "tcp",
+    "connectionReuse": true
-    "settings": {
-      "connectionReuse": true
-    }
   }
 }

transport/config.go

@@ -2,15 +2,13 @@ package transport
 
 type StreamType int
 
-const (
+type Config struct {
-	StreamTypeTCP = StreamType(0)
-)
-
-type TCPConfig struct {
 	ConnectionReuse bool
 }
 
-type Config struct {
+func (this *Config) Apply() error {
-	StreamType StreamType
+	if this.ConnectionReuse {
-	TCPConfig  *TCPConfig
+		connectionReuse = true
+	}
+	return nil
 }

transport/config_json.go

@@ -2,37 +2,16 @@
 
 package transport
 
-import (
+import "encoding/json"
-	"encoding/json"
-	"strings"
-)
 
 func (this *Config) UnmarshalJSON(data []byte) error {
-	type TypeConfig struct {
+	type JsonConfig struct {
-		StreamType string          `json:"streamType"`
-		Settings   json.RawMessage `json:"settings"`
-	}
-	type JsonTCPConfig struct {
 		ConnectionReuse bool `json:"connectionReuse"`
 	}
-
+	jsonConfig := new(JsonConfig)
-	typeConfig := new(TypeConfig)
+	if err := json.Unmarshal(data, jsonConfig); err != nil {
-	if err := json.Unmarshal(data, typeConfig); err != nil {
 		return err
 	}
-
+	this.ConnectionReuse = jsonConfig.ConnectionReuse
-	this.StreamType = StreamTypeTCP
-
-	streamType := strings.ToLower(typeConfig.StreamType)
-	if streamType == "tcp" {
-		jsonTCPConfig := new(JsonTCPConfig)
-		if err := json.Unmarshal(typeConfig.Settings, jsonTCPConfig); err != nil {
-			return err
-		}
-		this.TCPConfig = &TCPConfig{
-			ConnectionReuse: jsonTCPConfig.ConnectionReuse,
-		}
-	}
-
 	return nil
 }

transport/hub/connection.go

@@ -39,7 +39,7 @@ func (this *Connection) Close() error {
 	if this == nil || this.conn == nil {
 		return ErrorClosedConnection
 	}
-	if transport.TCPStreamConfig.ConnectionReuse && this.Reusable() {
+	if transport.IsConnectionReusable() && this.Reusable() {
 		this.listener.Recycle(this.dest, this.conn)
 		return nil
 	}

transport/hub/dialer.go

@@ -19,7 +19,7 @@ var (
 func Dial(dest v2net.Destination) (*Connection, error) {
 	destStr := dest.String()
 	var conn net.Conn
-	if transport.TCPStreamConfig.ConnectionReuse {
+	if transport.IsConnectionReusable() {
 		conn = globalCache.Get(destStr)
 	}
 	if conn == nil {

transport/transport.go

@@ -1,22 +1,9 @@
 package transport
 
-import "github.com/v2ray/v2ray-core/common/log"
-
 var (
-	TCPStreamConfig = TCPConfig{
+	connectionReuse = false
-		ConnectionReuse: false,
-	}
 )
 
-func ApplyConfig(config *Config) error {
+func IsConnectionReusable() bool {
-	if config.StreamType == StreamTypeTCP {
+	return connectionReuse
-		if config.TCPConfig != nil {
-			TCPStreamConfig.ConnectionReuse = config.TCPConfig.ConnectionReuse
-			if TCPStreamConfig.ConnectionReuse {
-				log.Info("Transport: TCP connection reuse enabled.")
-			}
-		}
-	}
-
-	return nil
 }