From a51b088982466dedcb390a85cfdb11af25a333d5 Mon Sep 17 00:00:00 2001 From: icey-yu <1186114839@qq.com> Date: Mon, 9 Sep 2024 17:31:12 +0800 Subject: [PATCH] fix: init online status --- pkg/rpccache/online.go | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/pkg/rpccache/online.go b/pkg/rpccache/online.go index f41f7877f..0d188bcc4 100644 --- a/pkg/rpccache/online.go +++ b/pkg/rpccache/online.go @@ -110,9 +110,10 @@ func (o *OnlineCache) initUsersOnlineStatus(ctx context.Context) (err error) { return err } + cursor := uint64(0) for resp == nil || resp.NextCursor != 0 { if err = retryOperation(func() error { - resp, err = o.user.GetAllOnlineUsers(ctx, 0) + resp, err = o.user.GetAllOnlineUsers(ctx, cursor) if err != nil { return err } @@ -123,6 +124,7 @@ func (o *OnlineCache) initUsersOnlineStatus(ctx context.Context) (err error) { } totalSet.Add(1) } + cursor = resp.NextCursor return nil }, "getAllOnlineUsers"); err != nil { return err