tikv allocator

Cargo.toml

@@ -61,7 +61,11 @@ prometheus = "*"
 async-trait = "*"
 tokio-stream = "*"
 zip = "*"
-jemallocator = "*"
+
+tikv-jemalloc-ctl = { version = "*", features = ['use_std'] }
+tikv-jemallocator = { version = "*", features = [
+    "unprefixed_malloc_on_supported_platforms",
+] }
 
 [build-dependencies]
 tonic-build = { version = "*", features = ["prost"] }

src/app/metrics.rs

@@ -154,15 +154,19 @@ impl PrometheusMetrics {
     pub fn update_tcp_threads(&self, threads_statistics: &ThreadsStatistics) {
         self.tcp_connections
             .with_label_values(&["ping_threads"])
-            .set(threads_statistics.get_ping_threads() as i64);
+            .set(threads_statistics.ping_threads.get());
 
         self.tcp_connections
             .with_label_values(&["read_threads"])
-            .set(threads_statistics.get_read_threads() as i64);
+            .set(threads_statistics.read_threads.get());
 
         self.tcp_connections
             .with_label_values(&["write_threads"])
-            .set(threads_statistics.get_write_threads() as i64);
+            .set(threads_statistics.write_threads.get());
+
+        self.tcp_connections
+            .with_label_values(&["connection_objects"])
+            .set(threads_statistics.connections_objects.get());
     }
 
     pub fn mark_new_tcp_disconnection(&self) {

src/main.rs

@@ -36,7 +36,7 @@ pub mod mynosqlserver_grpc {
 }
 
 #[global_allocator]
-static ALLOC: jemallocator::Jemalloc = jemallocator::Jemalloc;
+static ALLOC: tikv_jemallocator::Jemalloc = tikv_jemallocator::Jemalloc;
 
 #[tokio::main]
 async fn main() {