feat: dockerfile

Author: eastspire

frameworks/Rust/hyperlane/hyperlane.dockerfile

@@ -1,5 +1,7 @@
 FROM rust:1.85
 
+RUN apt-get update -yqq && apt-get install -yqq cmake g++ binutils lld
+
 ENV POSTGRES_URL=postgres://benchmarkdbuser:benchmarkdbpass@tfb-database:5432/hello_world
 
 ADD ./ /hyperlane_techempower

frameworks/Rust/hyperlane/src/db.rs

@@ -2,14 +2,12 @@ use crate::*;
 
 #[inline]
 pub async fn get_db_connection() -> DbPoolConnection {
-    if let Some(db_pool) = DB.read().await.clone() {
-        return db_pool;
+    if let Some(db_pool) = DB.get() {
+        return db_pool.clone();
     };
     let db_pool: DbPoolConnection = connection_db().await;
-    {
-        let mut db_pool_lock: RwLockWriteGuard<'_, Option<DbPoolConnection>> = DB.write().await;
-        *db_pool_lock = Some(db_pool.clone());
-    }
+    DB.set(db_pool.clone())
+        .expect("Failed to initialize DB_POOL");
     db_pool
 }
 
@@ -97,8 +95,7 @@ pub async fn init_cache() {
             res.push(QueryRow::new(id, random_number));
         }
     }
-    let mut cache: RwLockWriteGuard<'_, Vec<QueryRow>> = CACHE.write().await;
-    *cache = res;
+    let _ = CACHE.set(res);
 }
 
 #[inline]
@@ -170,10 +167,7 @@ pub async fn get_update_data(
 
 #[inline]
 pub async fn init_db() {
-    {
-        let mut db_pool_lock: RwLockWriteGuard<'_, Option<DbPoolConnection>> = DB.write().await;
-        *db_pool_lock = Some(connection_db().await);
-    }
+    get_db_connection().await;
     #[cfg(feature = "dev")]
     {
         create_database().await;

frameworks/Rust/hyperlane/src/lazy.rs

@@ -1,5 +1,4 @@
 use crate::*;
 
-pub static DB: Lazy<ArcRwLock<Option<DbPoolConnection>>> =
-    Lazy::new(|| Arc::new(RwLock::new(None)));
-pub static CACHE: Lazy<ArcRwLock<Vec<QueryRow>>> = Lazy::new(|| arc_rwlock(vec![]));
+pub static DB: OnceCell<DbPoolConnection> = OnceCell::new();
+pub static CACHE: OnceCell<Vec<QueryRow>> = OnceCell::new();

frameworks/Rust/hyperlane/src/main.rs

@@ -10,13 +10,7 @@ pub(crate) mod utils;
 
 pub(crate) use constant::*;
 pub(crate) use db::*;
-pub(crate) use hyperlane::{
-    once_cell::sync::Lazy,
-    serde::*,
-    serde_json::json,
-    tokio::sync::{RwLock, RwLockReadGuard, RwLockWriteGuard},
-    *,
-};
+pub(crate) use hyperlane::{once_cell::sync::OnceCell, serde::*, serde_json::json, *};
 pub(crate) use lazy::*;
 pub(crate) use rand::{Rng, SeedableRng, rng, rngs::SmallRng};
 pub(crate) use request_middleware::*;
@@ -27,7 +21,7 @@ pub(crate) use sqlx::{
     postgres::{PgPoolOptions, PgRow},
     *,
 };
-pub(crate) use std::{fmt, sync::Arc};
+pub(crate) use std::fmt;
 pub(crate) use r#type::*;
 pub(crate) use utils::*;
 

frameworks/Rust/hyperlane/src/route.rs

@@ -97,7 +97,7 @@ pub async fn cached_queries(controller_data: ControllerData) {
         .min(ROW_LIMIT as Queries)
         .max(1);
     let mut res: Vec<QueryRow> = Vec::with_capacity(count as usize);
-    let cache: RwLockReadGuard<'_, Vec<QueryRow>> = CACHE.read().await;
+    let cache: Vec<QueryRow> = CACHE.get().cloned().unwrap_or_default();
     for i in 0..count {
         res.push(cache[i as usize].clone());
     }