bug fixes

Author: syphar

src/storage/archive_index.rs

@@ -44,8 +44,8 @@ async fn sqlite_open<P: AsRef<Path>>(path: P) -> Result<sqlx::SqlitePool> {
         sqlx::sqlite::SqliteConnectOptions::new()
             .filename(path)
             .read_only(true)
-            // not needed for readonly db
-            .pragma("synchronous", "off")
+            .pragma("synchronous", "off") // not needed for readonly db
+            .serialized(false) // same as OPEN_NOMUTEX
             .create_if_missing(false),
     )
     .await?)
@@ -222,7 +222,7 @@ mod tests {
         let tempfile = tempfile::NamedTempFile::new()?.into_temp_path();
         create(&mut tf, &tempfile).await?;
 
-        let pool = sqlite_open(tempfile).await?;
+        let pool = sqlite_open(&tempfile).await?;
         let mut conn = pool.acquire().await?;
 
         let result = sqlx::query("SELECT count(*) FROM files")

src/utils/sized_buffer.rs

@@ -51,16 +51,16 @@ impl AsyncWrite for SizedBuffer {
         _cx: &mut task::Context<'_>,
         buf: &[u8],
     ) -> task::Poll<io::Result<usize>> {
-        let this = self.get_mut();
-        match io::Write::write(&mut this.inner, buf) {
+        let mut this = self.get_mut();
+        match io::Write::write(&mut this, buf) {
             Ok(n) => task::Poll::Ready(Ok(n)),
             Err(e) => task::Poll::Ready(Err(e)),
         }
     }
 
     fn poll_flush(self: Pin<&mut Self>, _cx: &mut task::Context<'_>) -> task::Poll<io::Result<()>> {
-        let this = self.get_mut();
-        match io::Write::flush(&mut this.inner) {
+        let mut this = self.get_mut();
+        match io::Write::flush(&mut this) {
             Ok(()) => task::Poll::Ready(Ok(())),
             Err(e) => task::Poll::Ready(Err(e)),
         }