fix: await after gc spawn blocking

docs/src/content/docs/reference/env.md

@@ -23,7 +23,7 @@ HTTP port to listen to.
 
 *Default: 9876*
 
-##### `SMOLTABLE_WRITE_BUFFER_SIZE`
+##### `SMOLTABLE_WRITE_BUFFER_SIZE_MB`
 
 Global write buffer size, shared by all tables, locality groups, metrics tables and internal tables.
 

server/src/env.rs

@@ -25,8 +25,8 @@ pub fn metrics_cap_mb() -> u16 {
 }
 
 /// Global write buffer size
-pub fn write_buffer_size() -> u32 {
-    let port = std::env::var("SMOLTABLE_WRITE_BUFFER_SIZE").unwrap_or("67108864".into());
+pub fn write_buffer_size() -> u16 {
+    let port = std::env::var("SMOLTABLE_WRITE_BUFFER_SIZE_MB").unwrap_or("64".into());
 
-    port.parse::<u32>().expect("invalid metrics cap MB setting")
+    port.parse::<u16>().expect("invalid metrics cap MB setting")
 }

server/src/main.rs

@@ -49,7 +49,7 @@ async fn main() -> smoltable::Result<()> {
 
     let keyspace = fjall::Config::new(data_folder())
         .block_cache(block_cache.clone())
-        .max_write_buffer_size(u64::from(write_buffer_size()))
+        .max_write_buffer_size(u64::from(write_buffer_size()) * 1_024 * 1_024)
         .open()?;
 
     let manifest_table = ManifestTable::open(keyspace.clone())?;
@@ -119,9 +119,15 @@ async fn main() -> smoltable::Result<()> {
             .allowed_header("*")
             .max_age(3600);
 
+        // custom `Json` extractor configuration
+        let json_cfg = web::JsonConfig::default()
+            // limit request payload size
+            .limit(10 * 1_024 * 1_024);
+
         App::new()
             .wrap(cors)
             .wrap(Logger::new("%r %s - %{User-Agent}i"))
+            .app_data(json_cfg)
             .app_data(app_state.clone())
             .route("/", web::get().to(render_dashboard))
             .route("/index.html", web::get().to(render_dashboard))

server/src/worker/gc.rs

@@ -31,7 +31,9 @@ pub async fn start(tables: Arc<RwLock<HashMap<String, MonitoredSmoltable>>>) {
                     }
                 };
             }
-        });
+        })
+        .await
+        .expect("should join");
 
         log::info!("TTL worker done");
         tokio::time::sleep(Duration::from_secs(/* 24 hours*/ 21_600 * 4)).await;