blackteay/open-im-server
1
0
Fork 0
mirror of https://github.com/openimsdk/open-im-server.git synced 2025-04-27 12:08:52 +08:00
Code Issues Packages Projects Releases Wiki Activity

cache

Browse Source
This commit is contained in:
wangchuxiao 2023-05-11 15:15:16 +08:00
parent 798f946651
commit 89d5f7bd45
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
pkg/common/db/cache/msg.go vendored
View File

@ -158,13 +158,11 @@ func (c *msgCache) getSeqs(ctx context.Context, items []string, getkey func(s st
m = make(map[string]int64, len(items)) m = make(map[string]int64, len(items))
for i, v := range result { for i, v := range result {
seq := v.(*redis.StringCmd) seq := v.(*redis.StringCmd)
log.ZDebug(ctx, "getSeqs", "v", v.String())
if seq.Err() != nil && seq.Err() != redis.Nil { if seq.Err() != nil && seq.Err() != redis.Nil {
return nil, errs.Wrap(v.Err()) return nil, errs.Wrap(v.Err())
} }
m[items[i]] = utils.StringToInt64(seq.Val()) m[items[i]] = utils.StringToInt64(seq.Val())
} }
log.ZDebug(ctx, "getSeqs", "m", m)
return m, nil return m, nil
} }
@ -269,11 +267,13 @@ func (c *msgCache) GetMessagesBySeq(ctx context.Context, conversationID string,
} }
result, err := pipe.Exec(ctx) result, err := pipe.Exec(ctx)
for i, v := range result { for i, v := range result {
if v.Err() != nil { cmd := v.(*redis.StringCmd)
if cmd.Err() != nil {
log.ZWarn(ctx, "get msg from cache failed", cmd.Err(), "cmd", cmd.Val())
failedSeqs = append(failedSeqs, seqs[i]) failedSeqs = append(failedSeqs, seqs[i])
} else { } else {
msg := sdkws.MsgData{} msg := sdkws.MsgData{}
err = jsonpb.UnmarshalString(v.String(), &msg) err = jsonpb.UnmarshalString(cmd.Val(), &msg)
if err == nil { if err == nil {
if msg.Status != constant.MsgDeleted { if msg.Status != constant.MsgDeleted {
seqMsgs = append(seqMsgs, &msg) seqMsgs = append(seqMsgs, &msg)