v0.3.0 (#107)

Author: losfair

Cargo.lock

@@ -1,6 +1,6 @@
 [package]
 name = "mvclient"
-version = "0.3.0-beta.1"
+version = "0.3.0"
 edition = "2021"
 license = "Apache-2.0"
 authors = ["Heyang Zhou <[email protected]>"]

mvclient/Cargo.toml

@@ -430,8 +430,8 @@ impl Transaction {
     }
 
     pub async fn read_many_nomark(&self, page_id_list: &[u32]) -> Result<Vec<Vec<u8>>> {
-        // wait for async completion
-        self.async_ctx.background_completion.write().await;
+        // Read-your-writes: wait for completion of asynchronous writes.
+        let _ = self.async_ctx.background_completion.write().await;
         self.check_async_error()?;
 
         let mut raw_request: Vec<u8> = Vec::new();
@@ -631,8 +631,8 @@ impl Transaction {
         metadata: Option<String>,
         fast_writes: &HashMap<u32, Bytes>,
     ) -> Result<Option<NamespaceCommitIntent>> {
-        // wait for async completion
-        self.async_ctx.background_completion.write().await;
+        // Wait for all pages in the page buffer to be flushed.
+        let _ = self.async_ctx.background_completion.write().await;
         self.check_async_error()?;
 
         if self.page_buffer.is_empty() && metadata.is_none() && fast_writes.is_empty() {

mvclient/src/lib.rs

@@ -1,6 +1,6 @@
 [package]
 name = "mvfs"
-version = "0.3.0-beta.1"
+version = "0.3.0"
 edition = "2021"
 license = "Apache-2.0"
 authors = ["Heyang Zhou <[email protected]>"]
@@ -14,7 +14,7 @@ crate-type = ["rlib", "staticlib"]
 anyhow = "1"
 thiserror = "1"
 tokio = { version = "1", features = ["full"] }
-mvclient = { path = "../mvclient" }
+mvclient = { path = "../mvclient", version = "0.3.0" }
 tracing = "0.1"
 serde = { version = "1", features = ["derive"] }
 serde_json = "1"

mvfs/Cargo.toml

@@ -11,7 +11,7 @@ thiserror = "1"
 tokio = { version = "1", features = ["full"] }
 log = "0.4"
 rand = "0.8.5"
-mvclient = { path = "../mvclient" }
+mvclient = { path = "../mvclient", version = "0.3.0" }
 tracing = "0.1"
 tracing-subscriber = { version = "0.3.16", features = ["env-filter", "fmt", "tracing-log", "json"] }
 libc = "0.2"
@@ -20,7 +20,7 @@ serde = { version = "1", features = ["derive"] }
 serde_json = "1"
 lazy_static = "1.4.0"
 reqwest = { version = "0.11.11", default-features = false, features = ["rustls-tls"] }
-mvfs = { path = "../mvfs" }
+mvfs = { path = "../mvfs", version = "0.3.0" }
 fuser = "0.11.0"
 structopt = "0.3.26"
 indexmap = "1.9.1"

mvsqlite-fuse/Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "mvsqlite"
-version = "0.3.0-beta.1"
+version = "0.3.0"
 edition = "2021"
 license = "Apache-2.0"
 authors = ["Heyang Zhou <[email protected]>"]
@@ -17,7 +17,7 @@ tokio = { version = "1", features = ["full"] }
 log = "0.4"
 rand = "0.8.5"
 stackful = "0.1.5"
-mvclient = { path = "../mvclient" }
+mvclient = { path = "../mvclient", version = "0.3.0" }
 tracing = "0.1"
 ctor = "0.1.22"
 tracing-subscriber = { version = "0.3.16", features = ["env-filter", "fmt", "json"], optional = true }
@@ -27,7 +27,7 @@ serde = { version = "1", features = ["derive"] }
 serde_json = "1"
 lazy_static = "1.4.0"
 reqwest = { version = "0.11.11", default-features = false }
-mvfs = { path = "../mvfs" }
+mvfs = { path = "../mvfs", version = "0.3.0" }
 
 [features]
 default = ["loadext", "syscall", "rustls-tls", "global-init"]

mvsqlite/Cargo.toml

@@ -6,7 +6,7 @@ edition = "2021"
 # See more keys and their definitions at https://doc.rust-lang.org/cargo/reference/manifest.html
 
 [dependencies]
-mvclient = { path = "../mvclient" }
+mvclient = { path = "../mvclient", version = "0.3.0" }
 anyhow = "1"
 thiserror = "1"
 tokio = { version = "1", features = ["full"] }

mvstore-stress/Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "mvstore"
-version = "0.3.0-beta.1"
+version = "0.3.0"
 edition = "2021"
 license = "Apache-2.0"
 authors = ["Heyang Zhou <[email protected]>"]