Add gc command to clean up vault
This commit is contained in:
parent
099cb8d4f7
commit
4e014168b4
2 changed files with 17 additions and 0 deletions
10
src/vault.rs
10
src/vault.rs
|
|
@ -13,6 +13,7 @@ pub use self::euph::{EuphMsg, EuphVault};
|
|||
|
||||
enum Request {
|
||||
Close(oneshot::Sender<()>),
|
||||
Gc(oneshot::Sender<()>),
|
||||
Euph(EuphRequest),
|
||||
}
|
||||
|
||||
|
|
@ -28,6 +29,12 @@ impl Vault {
|
|||
let _ = rx.await;
|
||||
}
|
||||
|
||||
pub async fn gc(&self) {
|
||||
let (tx, rx) = oneshot::channel();
|
||||
let _ = self.tx.send(Request::Gc(tx));
|
||||
let _ = rx.await;
|
||||
}
|
||||
|
||||
pub fn euph(&self, room: String) -> EuphVault {
|
||||
EuphVault {
|
||||
tx: self.tx.clone(),
|
||||
|
|
@ -48,6 +55,9 @@ fn run(mut conn: Connection, mut rx: mpsc::UnboundedReceiver<Request>) {
|
|||
drop(tx);
|
||||
break;
|
||||
}
|
||||
Request::Gc(tx) => {
|
||||
let _ = conn.execute_batch("ANALYZE; VACUUM;");
|
||||
}
|
||||
Request::Euph(r) => r.perform(&mut conn),
|
||||
}
|
||||
}
|
||||
|
|
|
|||
Loading…
Add table
Add a link
Reference in a new issue