|
|
@ -211,12 +211,11 @@ func (ws *WsServer) sendUserOnlineInfoToOtherNode(ctx context.Context, client *C
|
|
|
|
|
|
|
|
|
|
|
|
// Online push user online message to other node
|
|
|
|
// Online push user online message to other node
|
|
|
|
for _, v := range conns {
|
|
|
|
for _, v := range conns {
|
|
|
|
v := v // safe closure var
|
|
|
|
log.ZDebug(ctx, " sendUserOnlineInfoToOtherNode conn ", "target", v.Target())
|
|
|
|
if v.Target() == ws.disCov.GetSelfConnTarget() {
|
|
|
|
if v.Target() == ws.disCov.GetSelfConnTarget() {
|
|
|
|
log.ZDebug(ctx, "Filter out this node", "node", v.Target())
|
|
|
|
log.ZDebug(ctx, "Filter out this node", "node", v.Target())
|
|
|
|
continue
|
|
|
|
continue
|
|
|
|
}
|
|
|
|
}
|
|
|
|
log.ZDebug(ctx, " sendUserOnlineInfoToOtherNode conn ", "target", v.Target(), v.GetState())
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
wg.Go(func() error {
|
|
|
|
wg.Go(func() error {
|
|
|
|
msgClient := msggateway.NewMsgGatewayClient(v)
|
|
|
|
msgClient := msggateway.NewMsgGatewayClient(v)
|
|
|
|