| ... | @@ -2091,7 +2091,7 @@ pub(crate) fn sync_status( | ... | @@ -2091,7 +2091,7 @@ pub(crate) fn sync_status( |
| 2091 | synced: Option<u64>, | 2091 | synced: Option<u64>, |
| 2092 | observed: &Mutex<Observed>, | 2092 | observed: &Mutex<Observed>, |
| 2093 | ) -> Result<SyncStatus> { | 2093 | ) -> Result<SyncStatus> { |
| 2094 | let queued: u64 = crate::lock(&replica.section.connection)?.query_row( | 2094 | let queued: i64 = crate::lock(&replica.section.connection)?.query_row( |
| 2095 | "SELECT count(*) FROM edits", | 2095 | "SELECT count(*) FROM edits", |
| 2096 | [], | 2096 | [], |
| 2097 | |row| row.get(0), | 2097 | |row| row.get(0), |
| ... | @@ -2105,7 +2105,7 @@ pub(crate) fn sync_status( | ... | @@ -2105,7 +2105,7 @@ pub(crate) fn sync_status( |
| 2105 | .as_ref() | 2105 | .as_ref() |
| 2106 | .and_then(Option::as_ref) | 2106 | .and_then(Option::as_ref) |
| 2107 | .map(|error| io::Error::new(error.kind(), error.to_string())), | 2107 | .map(|error| io::Error::new(error.kind(), error.to_string())), |
| 2108 | queued, | 2108 | queued: crate::unsigned(queued)?, |
| 2109 | }) | 2109 | }) |
| 2110 | } | 2110 | } |
| 2111 | | 2111 | |