go/sliding-sync
go/sliding-sync
1
0
Fork 0
mirror of https://github.com/matrix-org/sliding-sync.git synced 2025-03-10 13:37:11 +00:00
Code Issues Packages Projects Releases Wiki Activity

Log errors when removing unknown keys

Browse Source
This commit is contained in:
Kegan Dougal 2023-11-24 14:16:13 +00:00
parent eb351ff9b8
commit b1fd9a1218
1 changed files with 8 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
sync3/connmap.go
View File

@ -164,7 +164,10 @@ func (m *ConnMap) CloseConnsForDevice(userID, deviceID string) {
// gather open connections for this user|device
connIDs := m.connIDsForDevice(userID, deviceID)
for _, cid := range connIDs {
m.cache.Remove(cid.String()) // this will fire TTL callbacks which calls closeConn
err := m.cache.Remove(cid.String()) // this will fire TTL callbacks which calls closeConn
if err != nil {
logger.Err(err).Str("cid", cid.String()).Msg("CloseConnsForDevice: cid did not exist in ttlcache")
}
}
}
@ -191,7 +194,10 @@ func (m *ConnMap) CloseConnsForUsers(userIDs []string) (closed int) {
logger.Trace().Str("user", userID).Int("num_conns", len(conns)).Msg("closing all device connections due to CloseConn()")
for _, conn := range conns {
m.cache.Remove(conn.String()) // this will fire TTL callbacks which calls closeConn
err := m.cache.Remove(conn.String()) // this will fire TTL callbacks which calls closeConn
if err != nil {
logger.Err(err).Str("cid", conn.String()).Msg("CloseConnsForDevice: cid did not exist in ttlcache")
}
}
closed += len(conns)
}