This is an automated email from the ASF dual-hosted git repository. hgruszecki pushed a commit to branch io_uring_tpc_direct_io_socket_transfer in repository https://gitbox.apache.org/repos/asf/iggy.git
commit 398e2d19a09bd12ed5d84f4a2a2c6205470e65f7 Author: Hubert Gruszecki <[email protected]> AuthorDate: Thu Jul 10 18:59:45 2025 +0200 gxhash, uuid v4 --- Cargo.lock | 11 +++++++++++ Cargo.toml | 1 + core/common/Cargo.toml | 1 + core/common/src/utils/checksum.rs | 2 +- core/server/Cargo.toml | 9 ++++++++- core/server/src/streaming/utils/random_id.rs | 2 +- 6 files changed, 23 insertions(+), 3 deletions(-) diff --git a/Cargo.lock b/Cargo.lock index 20d0a61b..6c6f968a 100644 --- a/Cargo.lock +++ b/Cargo.lock @@ -3437,6 +3437,15 @@ dependencies = [ "web-time", ] +[[package]] +name = "gxhash" +version = "3.5.0" +source = "registry+https://github.com/rust-lang/crates.io-index"; +checksum = "f3ce1bab7aa741d4e7042b2aae415b78741f267a98a7271ea226cd5ba6c43d7d" +dependencies = [ + "rustversion", +] + [[package]] name = "h2" version = "0.3.26" @@ -4066,6 +4075,7 @@ dependencies = [ "crc32fast", "derive_more 2.0.1", "fast-async-mutex", + "gxhash", "humantime", "rcgen", "rustls", @@ -7125,6 +7135,7 @@ dependencies = [ "figment", "flume", "futures", + "gxhash", "hash32 1.0.0", "human-repr", "iggy_common", diff --git a/Cargo.toml b/Cargo.toml index 6a2c27f4..6afc3eba 100644 --- a/Cargo.toml +++ b/Cargo.toml @@ -133,6 +133,7 @@ uuid = { version = "1.17.0", features = [ "serde", "zerocopy", ] } +gxhash = "3.5.0" rust-s3 = { version = "0.36.0-beta.2", default-features = false, features = [ "tokio-rustls-tls", "tags", diff --git a/core/common/Cargo.toml b/core/common/Cargo.toml index 443b0150..9168ac2b 100644 --- a/core/common/Cargo.toml +++ b/core/common/Cargo.toml @@ -43,6 +43,7 @@ chrono = { workspace = true } clap = { workspace = true } comfy-table = { workspace = true } crc32fast = { workspace = true } +gxhash = { workspace = true } derive_more = { workspace = true } fast-async-mutex = { version = "0.6.7", optional = true } humantime = { workspace = true } diff --git a/core/common/src/utils/checksum.rs b/core/common/src/utils/checksum.rs index 900b4fb9..c29a28e0 100644 --- a/core/common/src/utils/checksum.rs +++ b/core/common/src/utils/checksum.rs @@ -17,5 +17,5 @@ */ pub fn calculate_checksum(data: &[u8]) -> u32 { - crc32fast::hash(data) + gxhash::gxhash32(data, 0) } diff --git a/core/server/Cargo.toml b/core/server/Cargo.toml index 1ce3aa05..060fb185 100644 --- a/core/server/Cargo.toml +++ b/core/server/Cargo.toml @@ -58,6 +58,7 @@ error_set = { version = "0.8.5", features = ["tracing"] } figlet-rs = { workspace = true } figment = { version = "0.10.19", features = ["toml", "env"] } flume = { workspace = true } +gxhash = { workspace = true } async-channel = { workspace = true } futures = { workspace = true } human-repr = { workspace = true } @@ -68,7 +69,13 @@ lending-iterator = "0.1.7" hash32 = "1.0.0" mimalloc = { workspace = true, optional = true } moka = { version = "0.12.10", features = ["future"] } -compio = { git = "https://github.com/compio-rs/compio.git";, rev = "fe4243f0b6811ebc325afd081c9b087b4d9817be", features = ["runtime", "macros", "io-uring", "time", "rustls"] } +compio = { git = "https://github.com/compio-rs/compio.git";, rev = "fe4243f0b6811ebc325afd081c9b087b4d9817be", features = [ + "runtime", + "macros", + "io-uring", + "time", + "rustls", +] } nix = { version = "0.30", features = ["fs"] } once_cell = "1.21.3" opentelemetry = { version = "0.30.0", features = ["trace", "logs"] } diff --git a/core/server/src/streaming/utils/random_id.rs b/core/server/src/streaming/utils/random_id.rs index 6fb6b411..4dbfe5d4 100644 --- a/core/server/src/streaming/utils/random_id.rs +++ b/core/server/src/streaming/utils/random_id.rs @@ -20,7 +20,7 @@ use ulid::Ulid; use uuid::Uuid; pub fn get_uuid() -> u128 { - Uuid::now_v7().to_u128_le() + Uuid::new_v4().to_u128_le() } pub fn get_ulid() -> Ulid {
