Changeset 484 in code for trunk/downstream.go
- Timestamp:
- Mar 29, 2021, 3:07:39 PM (4 years ago)
- File:
-
- 1 edited
Legend:
- Unmodified
- Added
- Removed
-
trunk/downstream.go
r482 r484 1002 1002 1003 1003 // Fast-forward history to last message 1004 for target , entry := range net.delivered.innerMap {1004 for targetCM, entry := range net.delivered.innerMap { 1005 1005 delivered := entry.value.(deliveredClientMap) 1006 ch := net.channels.Value(target )1006 ch := net.channels.Value(targetCM) 1007 1007 if ch != nil && ch.Detached { 1008 1008 continue 1009 1009 } 1010 1010 1011 lastID, err := dc.user.msgStore.LastMsgID(net, target , time.Now())1011 lastID, err := dc.user.msgStore.LastMsgID(net, targetCM, time.Now()) 1012 1012 if err != nil { 1013 1013 dc.logger.Printf("failed to get last message ID: %v", err) … … 1059 1059 1060 1060 limit := 4000 1061 history, err := dc.user.msgStore.LoadLatestID(net, target, lastDelivered, limit) 1061 targetCM := net.casemap(target) 1062 history, err := dc.user.msgStore.LoadLatestID(net, targetCM, lastDelivered, limit) 1062 1063 if err != nil { 1063 1064 dc.logger.Printf("failed to send implicit history for %q: %v", target, err)
Note:
See TracChangeset
for help on using the changeset viewer.