diff --git a/internal/msggateway/n_ws_server.go b/internal/msggateway/n_ws_server.go index 515e1f7e8..defec16df 100644 --- a/internal/msggateway/n_ws_server.go +++ b/internal/msggateway/n_ws_server.go @@ -211,6 +211,7 @@ func (ws *WsServer) sendUserOnlineInfoToOtherNode(ctx context.Context, client *C // Online push user online message to other node for _, v := range conns { + v := v log.ZDebug(ctx, " sendUserOnlineInfoToOtherNode conn ", "target", v.Target()) if v.Target() == ws.disCov.GetSelfConnTarget() { log.ZDebug(ctx, "Filter out this node", "node", v.Target()) diff --git a/internal/push/onlinepusher.go b/internal/push/onlinepusher.go index a61399fb6..adeff3737 100644 --- a/internal/push/onlinepusher.go +++ b/internal/push/onlinepusher.go @@ -86,6 +86,7 @@ func (d *DefaultAllNode) GetConnsAndOnlinePush(ctx context.Context, msg *sdkws.M // Online push message for _, conn := range conns { + log.ZDebug(ctx, "get gateway conn detail ", "conn ", *conn) conn := conn // loop var safe ctx := ctx wg.Go(func() error { diff --git a/pkg/common/discoveryregister/etcd/etcd.go b/pkg/common/discoveryregister/etcd/etcd.go index bf510051f..7baac73f3 100644 --- a/pkg/common/discoveryregister/etcd/etcd.go +++ b/pkg/common/discoveryregister/etcd/etcd.go @@ -107,8 +107,9 @@ func (r *SvcDiscoveryRegistryImpl) GetConns(ctx context.Context, serviceName str return nil, err } conns = append(conns, conn) + fmt.Println("GetConns detail ", *conn) + } - fmt.Println("GetConns number ", len(conns)) return conns, nil }