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

Merge d2409dff07d0418817677e7e006aac22cc17d896 into 11358404f9e6bfb15bc62445cedeefbad9bd342c

Browse Source
This commit is contained in:
wsy6543 2025-10-23 21:12:07 +08:00 committed by GitHub
commit aa1a96770b
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
pkg/common/storage/cache/mcache/seq_conversation.go vendored
View File

@ -32,7 +32,7 @@ func (x *seqConversationCache) GetMinSeq(ctx context.Context, conversationID str
func (x *seqConversationCache) GetMaxSeqs(ctx context.Context, conversationIDs []string) (map[string]int64, error) { func (x *seqConversationCache) GetMaxSeqs(ctx context.Context, conversationIDs []string) (map[string]int64, error) {
res := make(map[string]int64) res := make(map[string]int64)
for _, conversationID := range conversationIDs { for _, conversationID := range conversationIDs {
seq, err := x.GetMinSeq(ctx, conversationID) seq, err := x.GetMaxSeq(ctx, conversationID)
if err != nil { if err != nil {
return nil, err return nil, err
} }
@ -44,7 +44,7 @@ func (x *seqConversationCache) GetMaxSeqs(ctx context.Context, conversationIDs [
func (x *seqConversationCache) GetMaxSeqsWithTime(ctx context.Context, conversationIDs []string) (map[string]database.SeqTime, error) { func (x *seqConversationCache) GetMaxSeqsWithTime(ctx context.Context, conversationIDs []string) (map[string]database.SeqTime, error) {
res := make(map[string]database.SeqTime) res := make(map[string]database.SeqTime)
for _, conversationID := range conversationIDs { for _, conversationID := range conversationIDs {
seq, err := x.GetMinSeq(ctx, conversationID) seq, err := x.GetMaxSeq(ctx, conversationID)
if err != nil { if err != nil {
return nil, err return nil, err
} }