Constellation, Spacedust, Slingshot, UFOs: atproto crates and services for microcosm
let tokio know we're blocking!!!
i knew i missed this somewhere, idk how it took this long to remember where :s
+2
-2
+2
-2
ufos/src/storage_fjall.rs
+2
-2
ufos/src/storage_fjall.rs
···
1350
1350
loop {
1351
1351
tokio::select! {
1352
1352
_ = rollup.tick() => {
1353
-
let (n, dirty) = self.0.step_rollup().inspect_err(|e| log::error!("rollup error: {e:?}"))?;
1353
+
let (n, dirty) = tokio::task::block_in_place(|| self.0.step_rollup())?;
1354
1354
if n == 0 {
1355
1355
rollup.reset_after(Duration::from_millis(1_200)); // we're caught up, take a break
1356
1356
}
···
1363
1363
let t0 = Instant::now();
1364
1364
let (mut total_danglers, mut total_deleted) = (0, 0);
1365
1365
for collection in &dirty_nsids {
1366
-
let (danglers, deleted) = self.0.trim_collection(collection, 512, false).inspect_err(|e| log::error!("trim error: {e:?}"))?;
1366
+
let (danglers, deleted) = tokio::task::block_in_place(|| self.0.trim_collection(collection, 512, false))?;
1367
1367
total_danglers += danglers;
1368
1368
total_deleted += deleted;
1369
1369
if total_deleted > 100_000_000 {