monolith

public

Star0

Watch0

147 commits 1 branch 0 tags 0 releases1.5 MiB

Commit `4908715e1814`

atagen <boss@atagen.co>2026-10-19 06:54 UTC

1 file changed+4-4

import: drop the job sender by taking it

Swapping in a dummy channel to drop the real sender hid why the line was there.

Modified file: crates/monolith/src/import.rs+4 additions−4 deletions@@ -26,7 +26,7 @@ use std::sync::mpsc;
 const OFFLOAD_BYTES: i64 = 512 * 1024;
 
 pub struct Imports {
-    jobs: mpsc::Sender<Job>,
+    jobs: Option<mpsc::Sender<Job>>,
     worker: Option<std::thread::JoinHandle<()>>,
     dmabufs: HashMap<WeakDmabuf, Waiters>,
     shm: HashMap<ObjectId, Waiters>,
@@ -56,7 +56,7 @@ impl Drop for Imports {
     // running, it destroys the device while NVIDIA's exit handlers tear down
     // the same driver state on the main thread, and glibc aborts.
     fn drop(&mut self) {
-        self.jobs = mpsc::channel().0;
+        self.jobs = None;
         if let Some(worker) = self.worker.take() {
             let _ = worker.join();
         }
@@ -108,7 +108,7 @@ impl Imports {
             })
             .map_err(|e| std::io::Error::other(e.to_string()))?;
         Ok(Self {
-            jobs,
+            jobs: Some(jobs),
             worker: Some(worker),
             dmabufs: HashMap::new(),
             shm: HashMap::new(),
@@ -126,7 +126,7 @@ impl Imports {
     }
 
     fn send(&self, job: Job) -> bool {
-        let sent = self.jobs.send(job).is_ok();
+        let sent = self.jobs.as_ref().is_some_and(|j| j.send(job).is_ok());
         if !sent {
             tracing::warn!("buffer import worker is gone");
         }