Use jemalloc

Cargo.toml

@@ -4,5 +4,5 @@ resolver = "2"
 
 [workspace.dependencies]
 contract-client = { git = "ssh://[email protected]/subsquid/subsquid-network.git", version = "1.0.0-rc1" }
-subsquid-messages = { git = "ssh://[email protected]/subsquid/subsquid-network.git", version = "1.0.0-rc1" }
-subsquid-network-transport = { git = "ssh://[email protected]/subsquid/subsquid-network.git", version = "1.0.0-rc1" }
+subsquid-messages = { git = "ssh://[email protected]/subsquid/subsquid-network.git", version = "1.0.0-rc2" }
+subsquid-network-transport = { git = "ssh://[email protected]/subsquid/subsquid-network.git", version = "1.0.0-rc2" }

crates/logs-collector/Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "logs-collector"
-version = "1.0.0-rc1"
+version = "1.0.0-rc2"
 edition = "2021"
 
 [dependencies]
@@ -20,3 +20,6 @@ tokio = { version = "1", features = ["full"] }
 contract-client = { workspace = true }
 subsquid-messages = { workspace = true }
 subsquid-network-transport = { workspace = true, features = ["logs-collector"] }
+
+[target.'cfg(not(target_env = "msvc"))'.dependencies]
+tikv-jemallocator = "0.5"

crates/logs-collector/src/collector.rs

@@ -36,12 +36,10 @@ impl<T: LogsStorage + Sync> LogsCollector<T> {
         log::trace!("Logs collected: {logs:?}");
         let mut rows: Vec<QueryExecutedRow> = logs
             .into_iter()
-            .filter_map(|log| match log.try_into() {
-                Ok(log) => Some(log),
-                Err(e) => {
-                    log::error!("Invalid log message: {e}");
-                    None
-                }
+            .filter_map(|log| {
+                log.try_into()
+                    .map_err(|e| log::error!("Invalid log message: {e}"))
+                    .ok()
             })
             .collect();
 

crates/logs-collector/src/main.rs

@@ -15,6 +15,13 @@ mod server;
 mod storage;
 mod utils;
 
+#[cfg(not(target_env = "msvc"))]
+use tikv_jemallocator::Jemalloc;
+
+#[cfg(not(target_env = "msvc"))]
+#[global_allocator]
+static GLOBAL: Jemalloc = Jemalloc;
+
 #[tokio::main]
 async fn main() -> anyhow::Result<()> {
     // Init logger and parse arguments

crates/network-scheduler/Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "network-scheduler"
-version = "1.0.0-rc1"
+version = "1.0.0-rc2"
 edition = "2021"
 
 [dependencies]
@@ -37,3 +37,6 @@ url = "2.5.0"
 contract-client = { workspace = true }
 subsquid-messages = { workspace = true, features = ["semver"] }
 subsquid-network-transport = { workspace = true, features = ["scheduler", "metrics"] }
+
+[target.'cfg(not(target_env = "msvc"))'.dependencies]
+tikv-jemallocator = "0.5"

crates/network-scheduler/src/main.rs

@@ -20,6 +20,13 @@ mod signature;
 mod storage;
 mod worker_state;
 
+#[cfg(not(target_env = "msvc"))]
+use tikv_jemallocator::Jemalloc;
+
+#[cfg(not(target_env = "msvc"))]
+#[global_allocator]
+static GLOBAL: Jemalloc = Jemalloc;
+
 #[tokio::main]
 async fn main() -> anyhow::Result<()> {
     // Init logger and parse arguments and config

crates/query-gateway/Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "query-gateway"
-version = "1.0.0-rc1"
+version = "1.0.0-rc2"
 edition = "2021"
 
 [dependencies]
@@ -31,3 +31,6 @@ uuid = { version = "1", features = ["v4", "fast-rng"] }
 contract-client = { workspace = true }
 subsquid-messages = { workspace = true, features = ["semver"] }
 subsquid-network-transport = { workspace = true, features = ["gateway"] }
+
+[target.'cfg(not(target_env = "msvc"))'.dependencies]
+tikv-jemallocator = "0.5"

crates/query-gateway/src/main.rs

@@ -24,6 +24,13 @@ mod scheme_extractor;
 mod server;
 mod task;
 
+#[cfg(not(target_env = "msvc"))]
+use tikv_jemallocator::Jemalloc;
+
+#[cfg(not(target_env = "msvc"))]
+#[global_allocator]
+static GLOBAL: Jemalloc = Jemalloc;
+
 #[derive(Parser)]
 #[command(version)]
 struct Cli {