Mirrors/chatmail-core
1
0
Fork 0
mirror of https://github.com/chatmail/core.git synced 2026-05-02 04:46:29 +03:00
Code Issues Packages Projects Releases Wiki Activity

Cache INSERT statement in receive_imf

Browse Source 
It reduces iteration time by ~8% in message reception benchmarks
ran by `cargo criterion --bench receive_emails`.
This commit is contained in:
link2xt
2023-02-24 10:11:13 +00:00
parent bc9e347a80
commit e9668b3cfa
1 changed files with 49 additions and 42 deletions
Download Patch File Download Diff File Expand all files Collapse all files

91
src/receive_imf.rs
View File

@@ -1149,7 +1149,10 @@ async fn add_parts(
// also change `MsgId::trash()` and `delete_expired_messages()` // also change `MsgId::trash()` and `delete_expired_messages()`
let trash = chat_id.is_trash() || (is_location_kml && msg.is_empty()); let trash = chat_id.is_trash() || (is_location_kml && msg.is_empty());
let row_id = context.sql.insert( let row_id = context
.sql
.call(|conn| {
let mut stmt = conn.prepare_cached(
r#" r#"
INSERT INTO msgs INSERT INTO msgs
( (
@@ -1179,47 +1182,51 @@ SET rfc724_mid=excluded.rfc724_mid, chat_id=excluded.chat_id,
bytes=excluded.bytes, mime_headers=excluded.mime_headers, mime_in_reply_to=excluded.mime_in_reply_to, bytes=excluded.bytes, mime_headers=excluded.mime_headers, mime_in_reply_to=excluded.mime_in_reply_to,
mime_references=excluded.mime_references, mime_modified=excluded.mime_modified, error=excluded.error, ephemeral_timer=excluded.ephemeral_timer, mime_references=excluded.mime_references, mime_modified=excluded.mime_modified, error=excluded.error, ephemeral_timer=excluded.ephemeral_timer,
ephemeral_timestamp=excluded.ephemeral_timestamp, download_state=excluded.download_state, hop_info=excluded.hop_info ephemeral_timestamp=excluded.ephemeral_timestamp, download_state=excluded.download_state, hop_info=excluded.hop_info
"#, "#)?;
paramsv![ stmt.execute(params![
replace_msg_id, replace_msg_id,
rfc724_mid, rfc724_mid,
if trash { DC_CHAT_ID_TRASH } else { chat_id }, if trash { DC_CHAT_ID_TRASH } else { chat_id },
if trash { ContactId::UNDEFINED } else { from_id }, if trash { ContactId::UNDEFINED } else { from_id },
if trash { ContactId::UNDEFINED } else { to_id }, if trash { ContactId::UNDEFINED } else { to_id },
sort_timestamp, sort_timestamp,
sent_timestamp, sent_timestamp,
rcvd_timestamp, rcvd_timestamp,
typ, typ,
state, state,
is_dc_message, is_dc_message,
if trash { "" } else { msg }, if trash { "" } else { msg },
if trash { "" } else { &subject }, if trash { "" } else { &subject },
// txt_raw might contain invalid utf8 // txt_raw might contain invalid utf8
if trash { "" } else { &txt_raw }, if trash { "" } else { &txt_raw },
if trash { if trash {
"".to_string() "".to_string()
} else { } else {
param.to_string() param.to_string()
}, },
part.bytes as isize, part.bytes as isize,
if (save_mime_headers || mime_modified) && !trash { if (save_mime_headers || mime_modified) && !trash {
mime_headers.clone() mime_headers.clone()
} else { } else {
Vec::new() Vec::new()
}, },
mime_in_reply_to, mime_in_reply_to,
mime_references, mime_references,
mime_modified, mime_modified,
part.error.as_deref().unwrap_or_default(), part.error.as_deref().unwrap_or_default(),
ephemeral_timer, ephemeral_timer,
ephemeral_timestamp, ephemeral_timestamp,
if is_partial_download.is_some() { if is_partial_download.is_some() {
DownloadState::Available DownloadState::Available
} else { } else {
DownloadState::Done DownloadState::Done
}, },
mime_parser.hop_info mime_parser.hop_info
]).await?; ])?;
let row_id = conn.last_insert_rowid();
Ok(row_id)
})
.await?;
// We only replace placeholder with a first part, // We only replace placeholder with a first part,
// afterwards insert additional parts. // afterwards insert additional parts.