Constellation, Spacedust, Slingshot, UFOs: atproto crates and services for microcosm
prevent writer drop on cursor reset
author
phil
date
(May 6, 2026, 11:39 AM -0400)
commit
ee910500
ee910500843518ddbd66e2ed7235aee9bdb1f806
parent
dedec698
dedec698586120a6dd7aa5b7d3ccf5d9f41d0986
+4
-5
+2
-5
constellation/src/bin/main.rs
+2
-5
constellation/src/bin/main.rs
···
135
135
println!("rocks ready.");
136
136
std::thread::scope(|s| {
137
137
if args.reset_db_start {
138
-
let rocks = rocks.clone();
139
-
s.spawn(move || {
140
-
let res = rocks.reset_start();
141
-
eprintln!("reset start finished: {res:?}");
142
-
});
138
+
let res = rocks.reset_start();
139
+
eprintln!("reset start finished: {res:?}");
143
140
}
144
141
s.spawn(|| {
145
142
let r = run(
+2
constellation/src/storage/rocks_store.rs
+2
constellation/src/storage/rocks_store.rs
···
718
718
impl Drop for RocksStorage {
719
719
fn drop(&mut self) {
720
720
if self.is_writer {
721
+
// TODO: cloning a writer is possible and currently breaks things
722
+
// (constellation code currently doesn't/shouldn't clone the writer)
721
723
println!("rocksdb writer: cleaning up for shutdown...");
722
724
if let Err(e) = self.db.flush_wal(true) {
723
725
eprintln!("rocks: flushing wal failed: {e:?}");