supabase
diff --git a/‎.github/workflows/ci.yml‎
Lines changed: 1 addition & 1 deletion b/‎.github/workflows/ci.yml‎
Lines changed: 1 addition & 1 deletion
diff --git a/‎crates/base/src/deno_runtime.rs‎
Lines changed: 9 additions & 0 deletions b/‎crates/base/src/deno_runtime.rs‎
Lines changed: 9 additions & 0 deletions
diff --git a/‎crates/base/src/worker/pool.rs‎
Lines changed: 3 additions & 11 deletions b/‎crates/base/src/worker/pool.rs‎
Lines changed: 3 additions & 11 deletions
@@ -13,7 +13,7 @@ env:
   CARGO_TERM_COLOR: always
   RUSTUP_MAX_RETRIES: 10
   ORT_DYLIB_PATH: /tmp/onnxruntime/lib/libonnxruntime.so
-  RUST_LOG: event_worker=trace
+  RUST_LOG: sb_event_worker=trace
 
 jobs:
   cargo-fmt:
 
@@ -279,6 +279,7 @@ pub struct RuntimeState {
     pub event_loop_completed: Arc<AtomicFlag>,
     pub terminated: Arc<AtomicFlag>,
     pub found_inspector_session: Arc<AtomicFlag>,
+    pub mem_reached_half: Arc<AtomicFlag>,
 }
 
 impl RuntimeState {
@@ -1324,6 +1325,14 @@ where
                     }
                 }
 
+                if let Some(limit) = mem_state.limit {
+                    if total_malloced_bytes >= limit / 2 {
+                        state.mem_reached_half.raise();
+                    } else {
+                        state.mem_reached_half.lower();
+                    }
+                }
+
                 if let Some(threshold_bytes) = beforeunload_mem_threshold.load().as_deref().copied()
                 {
                     let total_malloced_bytes = total_malloced_bytes as u64;
 
@@ -460,8 +460,6 @@ impl WorkerPool {
                     if tx.send(Ok(CreateUserWorkerResult { key: uuid })).is_err() {
                         error!("main worker receiver dropped")
                     };
-
-                    status.demand.fetch_add(1, Ordering::Release);
                 }
                 Err(err) => {
                     error!("{err:#}");
@@ -502,6 +500,8 @@ impl WorkerPool {
                 let cancel = worker.cancel.clone();
                 let (req_start_tx, req_end_tx) = profile.timing_tx_pair.clone();
 
+                profile.status.demand.fetch_add(1, Ordering::Release);
+
                 // Create a closure to handle the request and send the response
                 let request_handler = async move {
                     if !policy.is_per_worker() {
@@ -648,15 +648,7 @@ impl WorkerPool {
             .get(&worker_uuid)
             .map(|it| it.status.is_retired.clone())
         {
-            Some(is_retired) if !is_retired.is_raised() => {
-                self.user_workers
-                    .get(&worker_uuid)
-                    .map(|it| it.status.demand.as_ref())
-                    .unwrap()
-                    .fetch_add(1, Ordering::Release);
-
-                Some(worker_uuid)
-            }
+            Some(is_retired) if !is_retired.is_raised() => Some(worker_uuid),
 
             _ => {
                 self.retire(&worker_uuid);
Original file line number	Diff line number	Diff line change
`@@ -279,6 +279,7 @@ pub struct RuntimeState {`
`279`	`279`	`pub event_loop_completed: Arc<AtomicFlag>,`
`280`	`280`	`pub terminated: Arc<AtomicFlag>,`
`281`	`281`	`pub found_inspector_session: Arc<AtomicFlag>,`
	`282`	`+ pub mem_reached_half: Arc<AtomicFlag>,`
`282`	`283`	`}`
`283`	`284`
`284`	`285`	`impl RuntimeState {`
`@@ -1324,6 +1325,14 @@ where`
`1324`	`1325`	`}`
`1325`	`1326`	`}`
`1326`	`1327`
	`1328`	`+ if let Some(limit) = mem_state.limit {`
	`1329`	`+ if total_malloced_bytes >= limit / 2 {`
	`1330`	`+ state.mem_reached_half.raise();`
	`1331`	`+ } else {`
	`1332`	`+ state.mem_reached_half.lower();`
	`1333`	`+ }`
	`1334`	`+ }`
	`1335`	`+`
`1327`	`1336`	`if let Some(threshold_bytes) = beforeunload_mem_threshold.load().as_deref().copied()`
`1328`	`1337`	`{`
`1329`	`1338`	`let total_malloced_bytes = total_malloced_bytes as u64;`