fix: use internal method

Signed-off-by: hlts2 <[email protected]>
vdaas · Dec 5, 2023 · 19ee272 · 19ee272
1 parent 2b1cac5
commit 19ee272
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/pkg/gateway/mirror/service/mirror.go b/pkg/gateway/mirror/service/mirror.go
@@ -287,7 +287,7 @@ func (m *mirr) Disconnect(ctx context.Context, targets ...*payload.Mirror_Target
 	}
 	for _, target := range targets {
 		addr := net.JoinHostPort(target.GetHost(), uint16(target.GetPort()))
-		if _, ok := m.gwAddrl.Load(addr); !ok {
+		if !m.isGatewayAddr(addr) {
 			_, ok := m.addrl.Load(addr)
 			if ok || m.IsConnected(ctx, addr) {
 				if err := m.gateway.GRPCClient().Disconnect(ctx, addr); err != nil &&