char
/
matrix-rust-sdk
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

crypto: Add a bit more info to the room key sharing logic logging

master
Damir Jelić 2021-03-02 17:15:10 +01:00
parent 6597948564
commit 93e5c34670
2 changed files with 20 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
matrix_sdk_crypto/src/olm/group_sessions/outbound.rs
View File

@ -226,9 +226,10 @@ impl OutboundGroupSession {
if self.to_share_with_set.is_empty() { if self.to_share_with_set.is_empty() {
debug!( debug!(
"Marking session {} for room {} as shared.", session_id = self.session_id(),
self.session_id(), room_id = self.room_id.as_str(),
self.room_id "All m.room_key to-device requests were sent out, marking \
session as shared.",
); );
self.mark_as_shared(); self.mark_as_shared();
} }

16
matrix_sdk_crypto/src/session_manager/group_sessions.rs
View File

@ -427,6 +427,13 @@ impl GroupSessionManager {
let requests = outbound.pending_requests(); let requests = outbound.pending_requests();
debug!(
room_id = room_id.as_str(),
session_id = outbound.session_id(),
request_count = requests.len(),
"Done generating to-device requests for a room key share"
);
if requests.is_empty() { if requests.is_empty() {
debug!( debug!(
room_id = room_id.as_str(), room_id = room_id.as_str(),
@ -437,8 +444,17 @@ impl GroupSessionManager {
outbound.mark_as_shared(); outbound.mark_as_shared();
} }
let session_count = changes.sessions.len();
self.store.save_changes(changes).await?; self.store.save_changes(changes).await?;
debug!(
room_id = room_id.as_str(),
session_id = outbound.session_id(),
session_count = session_count,
"Stored the changed sessions after encrypting an room key"
);
Ok(requests) Ok(requests)
} }
} }