aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
Diffstat
-rw-r--r--Cargo.lock34
-rw-r--r--src/block/Cargo.toml2
-rw-r--r--src/garage/Cargo.toml2
-rw-r--r--src/garage/repair.rs4
-rw-r--r--src/model/Cargo.toml2
-rw-r--r--src/model/index_counter.rs8
-rw-r--r--src/model/key_table.rs2
-rw-r--r--src/model/migrate.rs2
-rw-r--r--src/model/s3/object_table.rs2
-rw-r--r--src/model/s3/version_table.rs2
-rw-r--r--src/rpc/Cargo.toml2
-rw-r--r--src/table/Cargo.toml2
-rw-r--r--src/table/data.rs2
-rw-r--r--src/table/merkle.rs2
-rw-r--r--src/util/Cargo.toml2
-rw-r--r--src/util/data.rs2
-rw-r--r--src/util/persister.rs4
17 files changed, 46 insertions, 30 deletions
diff --git a/Cargo.lock b/Cargo.lock
index c43aa81f..a953779b 100644
--- a/Cargo.lock
+++ b/Cargo.lock
@@ -930,7 +930,7 @@ dependencies = [
"pretty_env_logger",
"prometheus",
"rand 0.8.5",
- "rmp-serde 0.15.5",
+ "rmp-serde 1.1.0",
"serde",
"serde_bytes",
"serde_json",
@@ -1002,7 +1002,7 @@ dependencies = [
"hex",
"opentelemetry",
"rand 0.8.5",
- "rmp-serde 0.15.5",
+ "rmp-serde 1.1.0",
"serde",
"serde_bytes",
"tokio",
@@ -1069,7 +1069,7 @@ dependencies = [
"netapp 0.4.4",
"opentelemetry",
"rand 0.8.5",
- "rmp-serde 0.15.5",
+ "rmp-serde 1.1.0",
"serde",
"serde_bytes",
"tokio",
@@ -1126,7 +1126,7 @@ dependencies = [
"opentelemetry",
"pnet_datalink",
"rand 0.8.5",
- "rmp-serde 0.15.5",
+ "rmp-serde 1.1.0",
"schemars",
"serde",
"serde_bytes",
@@ -1172,7 +1172,7 @@ dependencies = [
"hexdump",
"opentelemetry",
"rand 0.8.5",
- "rmp-serde 0.15.5",
+ "rmp-serde 1.1.0",
"serde",
"serde_bytes",
"tokio",
@@ -1220,7 +1220,7 @@ dependencies = [
"netapp 0.4.4",
"opentelemetry",
"rand 0.8.5",
- "rmp-serde 0.15.5",
+ "rmp-serde 1.1.0",
"serde",
"serde_json",
"sha2",
@@ -2250,6 +2250,12 @@ dependencies = [
]
[[package]]
+name = "paste"
+version = "1.0.7"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "0c520e05135d6e763148b6426a837e239041653ba7becd2e538c076c738025fc"
+
+[[package]]
name = "pem"
version = "0.8.3"
source = "registry+https://github.com/rust-lang/crates.io-index"
@@ -2638,12 +2644,13 @@ dependencies = [
[[package]]
name = "rmp"
-version = "0.8.10"
+version = "0.8.11"
source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "4f55e5fa1446c4d5dd1f5daeed2a4fe193071771a2636274d0d7a3b082aa7ad6"
+checksum = "44519172358fd6d58656c86ab8e7fbc9e1490c3e8f14d35ed78ca0dd07403c9f"
dependencies = [
"byteorder",
"num-traits",
+ "paste",
]
[[package]]
@@ -2669,6 +2676,17 @@ dependencies = [
]
[[package]]
+name = "rmp-serde"
+version = "1.1.0"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "25786b0d276110195fa3d6f3f31299900cf71dfbd6c28450f3f58a0e7f7a347e"
+dependencies = [
+ "byteorder",
+ "rmp",
+ "serde",
+]
+
+[[package]]
name = "roxmltree"
version = "0.14.1"
source = "registry+https://github.com/rust-lang/crates.io-index"
diff --git a/src/block/Cargo.toml b/src/block/Cargo.toml
index 80346aca..1a49947c 100644
--- a/src/block/Cargo.toml
+++ b/src/block/Cargo.toml
@@ -28,7 +28,7 @@ tracing = "0.1.30"
rand = "0.8"
zstd = { version = "0.9", default-features = false }
-rmp-serde = "0.15"
+rmp-serde = "1.1"
serde = { version = "1.0", default-features = false, features = ["derive", "rc"] }
serde_bytes = "0.11"
diff --git a/src/garage/Cargo.toml b/src/garage/Cargo.toml
index eb643160..d5299291 100644
--- a/src/garage/Cargo.toml
+++ b/src/garage/Cargo.toml
@@ -37,7 +37,7 @@ rand = "0.8"
async-trait = "0.1.7"
sodiumoxide = { version = "0.2.5-0", package = "kuska-sodiumoxide" }
-rmp-serde = "0.15"
+rmp-serde = "1.1"
serde = { version = "1.0", default-features = false, features = ["derive", "rc"] }
serde_bytes = "0.11"
structopt = { version = "0.3", default-features = false }
diff --git a/src/garage/repair.rs b/src/garage/repair.rs
index cdcfc90f..1ae26181 100644
--- a/src/garage/repair.rs
+++ b/src/garage/repair.rs
@@ -81,7 +81,7 @@ impl Repair {
info!("repair_versions: {}", i);
}
- let version = rmp_serde::decode::from_read_ref::<_, Version>(&item_bytes)?;
+ let version = rmp_serde::decode::from_slice::<Version>(&item_bytes)?;
if version.deleted.get() {
continue;
}
@@ -133,7 +133,7 @@ impl Repair {
info!("repair_block_ref: {}", i);
}
- let block_ref = rmp_serde::decode::from_read_ref::<_, BlockRef>(&item_bytes)?;
+ let block_ref = rmp_serde::decode::from_slice::<BlockRef>(&item_bytes)?;
if block_ref.deleted.get() {
continue;
}
diff --git a/src/model/Cargo.toml b/src/model/Cargo.toml
index d908dc01..322feee1 100644
--- a/src/model/Cargo.toml
+++ b/src/model/Cargo.toml
@@ -31,7 +31,7 @@ tracing = "0.1.30"
rand = "0.8"
zstd = { version = "0.9", default-features = false }
-rmp-serde = "0.15"
+rmp-serde = "1.1"
serde = { version = "1.0", default-features = false, features = ["derive", "rc"] }
serde_bytes = "0.11"
diff --git a/src/model/index_counter.rs b/src/model/index_counter.rs
index 33de797d..9e343e5f 100644
--- a/src/model/index_counter.rs
+++ b/src/model/index_counter.rs
@@ -181,11 +181,9 @@ impl<T: CounterSchema> IndexCounter<T> {
let new_entry = self.local_counter.db().transaction(|tx| {
let mut entry = match tx.get(&self.local_counter, &tree_key[..])? {
- Some(old_bytes) => {
- rmp_serde::decode::from_read_ref::<_, LocalCounterEntry>(&old_bytes)
- .map_err(Error::RmpDecode)
- .map_err(db::TxError::Abort)?
- }
+ Some(old_bytes) => rmp_serde::decode::from_slice::<LocalCounterEntry>(&old_bytes)
+ .map_err(Error::RmpDecode)
+ .map_err(db::TxError::Abort)?,
None => LocalCounterEntry {
values: BTreeMap::new(),
},
diff --git a/src/model/key_table.rs b/src/model/key_table.rs
index 330e83f0..852bf607 100644
--- a/src/model/key_table.rs
+++ b/src/model/key_table.rs
@@ -175,7 +175,7 @@ impl TableSchema for KeyTable {
}
fn try_migrate(bytes: &[u8]) -> Option<Self::E> {
- let old_k = rmp_serde::decode::from_read_ref::<_, old::Key>(bytes).ok()?;
+ let old_k = rmp_serde::decode::from_slice::<old::Key>(bytes).ok()?;
let name = crdt::Lww::raw(old_k.name.timestamp(), old_k.name.get().clone());
let state = if old_k.deleted.get() {
diff --git a/src/model/migrate.rs b/src/model/migrate.rs
index 25acb4b0..bfd9845b 100644
--- a/src/model/migrate.rs
+++ b/src/model/migrate.rs
@@ -28,7 +28,7 @@ impl Migrate {
let mut old_buckets = vec![];
for res in tree.iter().map_err(GarageError::from)? {
let (_k, v) = res.map_err(GarageError::from)?;
- let bucket = rmp_serde::decode::from_read_ref::<_, old_bucket::Bucket>(&v[..])
+ let bucket = rmp_serde::decode::from_slice::<old_bucket::Bucket>(&v[..])
.map_err(GarageError::from)?;
old_buckets.push(bucket);
}
diff --git a/src/model/s3/object_table.rs b/src/model/s3/object_table.rs
index 3d9a89f7..c242b325 100644
--- a/src/model/s3/object_table.rs
+++ b/src/model/s3/object_table.rs
@@ -270,7 +270,7 @@ impl TableSchema for ObjectTable {
}
fn try_migrate(bytes: &[u8]) -> Option<Self::E> {
- let old_obj = rmp_serde::decode::from_read_ref::<_, old::Object>(bytes).ok()?;
+ let old_obj = rmp_serde::decode::from_slice::<old::Object>(bytes).ok()?;
Some(migrate_object(old_obj))
}
}
diff --git a/src/model/s3/version_table.rs b/src/model/s3/version_table.rs
index ad096772..f67f2ff1 100644
--- a/src/model/s3/version_table.rs
+++ b/src/model/s3/version_table.rs
@@ -168,7 +168,7 @@ impl TableSchema for VersionTable {
}
fn try_migrate(bytes: &[u8]) -> Option<Self::E> {
- let old = rmp_serde::decode::from_read_ref::<_, old::Version>(bytes).ok()?;
+ let old = rmp_serde::decode::from_slice::<old::Version>(bytes).ok()?;
let blocks = old
.blocks
diff --git a/src/rpc/Cargo.toml b/src/rpc/Cargo.toml
index 73328993..93df02a4 100644
--- a/src/rpc/Cargo.toml
+++ b/src/rpc/Cargo.toml
@@ -26,7 +26,7 @@ rand = "0.8"
sodiumoxide = { version = "0.2.5-0", package = "kuska-sodiumoxide" }
async-trait = "0.1.7"
-rmp-serde = "0.15"
+rmp-serde = "1.1"
serde = { version = "1.0", default-features = false, features = ["derive", "rc"] }
serde_bytes = "0.11"
serde_json = "1.0"
diff --git a/src/table/Cargo.toml b/src/table/Cargo.toml
index 6de37cda..690d5a71 100644
--- a/src/table/Cargo.toml
+++ b/src/table/Cargo.toml
@@ -26,7 +26,7 @@ hexdump = "0.1"
tracing = "0.1.30"
rand = "0.8"
-rmp-serde = "0.15"
+rmp-serde = "1.1"
serde = { version = "1.0", default-features = false, features = ["derive", "rc"] }
serde_bytes = "0.11"
diff --git a/src/table/data.rs b/src/table/data.rs
index 427ce763..17402bb6 100644
--- a/src/table/data.rs
+++ b/src/table/data.rs
@@ -297,7 +297,7 @@ where
}
pub fn decode_entry(&self, bytes: &[u8]) -> Result<F::E, Error> {
- match rmp_serde::decode::from_read_ref::<_, F::E>(bytes) {
+ match rmp_serde::decode::from_slice::<F::E>(bytes) {
Ok(x) => Ok(x),
Err(e) => match F::try_migrate(bytes) {
Some(x) => Ok(x),
diff --git a/src/table/merkle.rs b/src/table/merkle.rs
index c6653a64..8c574d09 100644
--- a/src/table/merkle.rs
+++ b/src/table/merkle.rs
@@ -354,7 +354,7 @@ impl MerkleNode {
fn decode_opt(ent: Option<db::Value<'_>>) -> Result<Self, Error> {
match ent {
None => Ok(MerkleNode::Empty),
- Some(v) => Ok(rmp_serde::decode::from_read_ref::<_, MerkleNode>(&v[..])?),
+ Some(v) => Ok(rmp_serde::decode::from_slice::<MerkleNode>(&v[..])?),
}
}
diff --git a/src/util/Cargo.toml b/src/util/Cargo.toml
index 5d073436..e68704ad 100644
--- a/src/util/Cargo.toml
+++ b/src/util/Cargo.toml
@@ -25,7 +25,7 @@ rand = "0.8"
sha2 = "0.9"
chrono = "0.4"
-rmp-serde = "0.15"
+rmp-serde = "1.1"
serde = { version = "1.0", default-features = false, features = ["derive", "rc"] }
serde_json = "1.0"
toml = "0.5"
diff --git a/src/util/data.rs b/src/util/data.rs
index 7715c2cc..2ef976a5 100644
--- a/src/util/data.rs
+++ b/src/util/data.rs
@@ -151,7 +151,7 @@ where
let mut wr = Vec::with_capacity(128);
let mut se = rmp_serde::Serializer::new(&mut wr)
.with_struct_map()
- .with_string_variants();
+ .with_binary();
val.serialize(&mut se)?;
Ok(wr)
}
diff --git a/src/util/persister.rs b/src/util/persister.rs
index 9e1a1910..d0759db7 100644
--- a/src/util/persister.rs
+++ b/src/util/persister.rs
@@ -33,7 +33,7 @@ where
let mut bytes = vec![];
file.read_to_end(&mut bytes)?;
- let value = rmp_serde::decode::from_read_ref(&bytes[..])?;
+ let value = rmp_serde::decode::from_slice(&bytes[..])?;
Ok(value)
}
@@ -57,7 +57,7 @@ where
let mut bytes = vec![];
file.read_to_end(&mut bytes).await?;
- let value = rmp_serde::decode::from_read_ref(&bytes[..])?;
+ let value = rmp_serde::decode::from_slice(&bytes[..])?;
Ok(value)
}
generated by cgit v1.2.3 (git 2.25.1) at 2024-11-15 10:43:51 +0000