diff options
| author | Quentin Dufour <quentin@deuxfleurs.fr> | 2023-12-27 14:58:09 +0100 |
|---|---|---|
| committer | Quentin Dufour <quentin@deuxfleurs.fr> | 2023-12-27 14:58:09 +0100 |
| commit | 54c9736a247bb3534a285caa637c9afb052bc2dd (patch) | |
| tree | 91efb131a2f2bb65ec07a202031927d476f78e09 /src/mail | |
| parent | 477a784e45d07d414fea77cf5b49ee241dc01f65 (diff) | |
| download | aerogramme-54c9736a247bb3534a285caa637c9afb052bc2dd.tar.gz aerogramme-54c9736a247bb3534a285caa637c9afb052bc2dd.zip | |
implemente garage storage
Diffstat (limited to 'src/mail')
| -rw-r--r-- | src/mail/incoming.rs | 2 | ||||
| -rw-r--r-- | src/mail/mailbox.rs | 2 |
2 files changed, 2 insertions, 2 deletions
diff --git a/src/mail/incoming.rs b/src/mail/incoming.rs index b17959a..7e33a9a 100644 --- a/src/mail/incoming.rs +++ b/src/mail/incoming.rs @@ -386,7 +386,7 @@ async fn k2v_lock_loop_internal( _ => None, }; if let Some(ct) = release { - match storage.row_rm_single(&ct).await { + match storage.row_rm(&storage::Selector::Single(&ct)).await { Err(e) => warn!("Unable to release lock {:?}: {}", ct, e), Ok(_) => (), }; diff --git a/src/mail/mailbox.rs b/src/mail/mailbox.rs index c925f39..6fb7dea 100644 --- a/src/mail/mailbox.rs +++ b/src/mail/mailbox.rs @@ -365,7 +365,7 @@ impl MailboxInternal { .row_fetch(&storage::Selector::Single(&RowRef::new(&self.mail_path, &sk))) .await?; if let Some(row_val) = res.into_iter().next() { - self.storage.row_rm_single(&row_val.row_ref).await?; + self.storage.row_rm(&storage::Selector::Single(&row_val.row_ref)).await?; } Ok::<_, anyhow::Error>(()) } |