From 2080669943e79aba619bc80829172c696ec1f15c Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E6=9E=97=E7=82=B3=E6=9D=83?= <695601626@qq.com> Date: Sun, 27 Aug 2023 12:04:12 +0800 Subject: chore: update to Rust 1.72 (#20258) As the title. --------- Co-authored-by: Matt Mastracci --- ext/kv/sqlite.rs | 27 +++++++++++++++------------ 1 file changed, 15 insertions(+), 12 deletions(-) (limited to 'ext/kv/sqlite.rs') diff --git a/ext/kv/sqlite.rs b/ext/kv/sqlite.rs index f67154cb4..ea46aae32 100644 --- a/ext/kv/sqlite.rs +++ b/ext/kv/sqlite.rs @@ -355,7 +355,7 @@ impl SqliteDb { spawn_blocking(move || { let mut db = db.try_lock().ok(); let Some(db) = db.as_mut().and_then(|x| x.as_mut()) else { - return Err(type_error(ERROR_USING_CLOSED_DATABASE)) + return Err(type_error(ERROR_USING_CLOSED_DATABASE)); }; let result = match db.transaction() { Ok(tx) => f(tx), @@ -626,16 +626,17 @@ impl SqliteQueue { tx: &rusqlite::Transaction<'_>, ) -> Result { let Some((_, id, data, backoff_schedule, keys_if_undelivered)) = tx - .prepare_cached(STATEMENT_QUEUE_GET_RUNNING_BY_ID)? - .query_row([id], |row| { - let deadline: u64 = row.get(0)?; - let id: String = row.get(1)?; - let data: Vec = row.get(2)?; - let backoff_schedule: String = row.get(3)?; - let keys_if_undelivered: String = row.get(4)?; - Ok((deadline, id, data, backoff_schedule, keys_if_undelivered)) - }) - .optional()? else { + .prepare_cached(STATEMENT_QUEUE_GET_RUNNING_BY_ID)? + .query_row([id], |row| { + let deadline: u64 = row.get(0)?; + let id: String = row.get(1)?; + let data: Vec = row.get(2)?; + let backoff_schedule: String = row.get(3)?; + let keys_if_undelivered: String = row.get(4)?; + Ok((deadline, id, data, backoff_schedule, keys_if_undelivered)) + }) + .optional()? + else { return Ok(false); }; @@ -926,7 +927,9 @@ fn mutate_le64( mutate: impl FnOnce(u64, u64) -> u64, ) -> Result<(), AnyError> { let Value::U64(operand) = *operand else { - return Err(type_error(format!("Failed to perform '{op_name}' mutation on a non-U64 operand"))); + return Err(type_error(format!( + "Failed to perform '{op_name}' mutation on a non-U64 operand" + ))); }; let old_value = tx -- cgit v1.2.3