crypto: Make sure we don't deadlock when we cancel the verification request

master
Damir Jelić 2021-07-09 14:31:54 +02:00
parent b0e8f12426
commit 7644ceea8a
1 changed files with 15 additions and 11 deletions

View File

@ -385,15 +385,6 @@ impl VerificationRequest {
/// Cancel the verification request /// Cancel the verification request
pub fn cancel(&self) -> Option<OutgoingVerificationRequest> { pub fn cancel(&self) -> Option<OutgoingVerificationRequest> {
if let Some(verification) =
self.verification_cache.get(self.other_user(), self.flow_id().as_str())
{
match verification {
crate::Verification::SasV1(s) => s.cancel(),
crate::Verification::QrV1(q) => q.cancel(),
};
}
let mut inner = self.inner.lock().unwrap(); let mut inner = self.inner.lock().unwrap();
inner.cancel(true, &CancelCode::User); inner.cancel(true, &CancelCode::User);
@ -403,14 +394,27 @@ impl VerificationRequest {
None None
}; };
content.map(|c| match c { let request = content.map(|c| match c {
OutgoingContent::ToDevice(content) => { OutgoingContent::ToDevice(content) => {
ToDeviceRequest::new(&self.other_user(), inner.other_device_id(), content).into() ToDeviceRequest::new(&self.other_user(), inner.other_device_id(), content).into()
} }
OutgoingContent::Room(room_id, content) => { OutgoingContent::Room(room_id, content) => {
RoomMessageRequest { room_id, txn_id: Uuid::new_v4(), content }.into() RoomMessageRequest { room_id, txn_id: Uuid::new_v4(), content }.into()
} }
}) });
drop(inner);
if let Some(verification) =
self.verification_cache.get(self.other_user(), self.flow_id().as_str())
{
match verification {
crate::Verification::SasV1(s) => s.cancel(),
crate::Verification::QrV1(q) => q.cancel(),
};
}
request
} }
pub(crate) fn receive_ready(&self, sender: &UserId, content: &ReadyContent) { pub(crate) fn receive_ready(&self, sender: &UserId, content: &ReadyContent) {