feat: support to clean globalCCMap manually

daeuniverse · Jun 18, 2023 · 5c79a91 · 5c79a91
1 parent c341d43
commit 5c79a91
Showing 1 changed file with 12 additions and 5 deletions.
diff --git a/transport/grpc/grpc_client.go b/transport/grpc/grpc_client.go
@@ -3,6 +3,12 @@ package grpc
 import (
 	"context"
 	"fmt"
+	"io"
+	"net"
+	"os"
+	"sync"
+	"time"
+
 	"github.com/mzz2017/softwind/netproxy"
 	"github.com/mzz2017/softwind/pkg/cert"
 	proto "github.com/mzz2017/softwind/pkg/gun_proto"
@@ -15,11 +21,6 @@ import (
 	"google.golang.org/grpc/credentials/insecure"
 	"google.golang.org/grpc/keepalive"
 	"google.golang.org/grpc/status"
-	"io"
-	"net"
-	"os"
-	"sync"
-	"time"
 )
 
 // https://github.com/v2fly/v2ray-core/blob/v5.0.6/transport/internet/grpc/dial.go
@@ -32,6 +33,12 @@ var (
 	globalCCAccess sync.Mutex
 )
 
+func CleanGlobalClientConnectionCache() {
+	globalCCAccess.Lock()
+	defer globalCCAccess.Unlock()
+	globalCCMap = make(map[string]*clientConnMeta)
+}
+
 type ccCanceller func()
 
 type ClientConn struct {