aboutsummaryrefslogtreecommitdiff
path: root/src/store/block_ref_table.rs
diff options
context:
space:
mode:
authorAlex Auvolat <alex@adnab.me>2020-04-24 10:10:01 +0000
committerAlex Auvolat <alex@adnab.me>2020-04-24 10:10:01 +0000
commitd8f5e643bcee95969b59c309809710a38b0661e3 (patch)
tree9bb179f351f60fc0396db731cb8ca0fe25dde17e /src/store/block_ref_table.rs
parent51fb3799a153a0db990fc74a37563ec612e20fc2 (diff)
downloadgarage-d8f5e643bcee95969b59c309809710a38b0661e3.tar.gz
garage-d8f5e643bcee95969b59c309809710a38b0661e3.zip
Split code for modular compilation
Diffstat (limited to 'src/store/block_ref_table.rs')
-rw-r--r--src/store/block_ref_table.rs68
1 files changed, 0 insertions, 68 deletions
diff --git a/src/store/block_ref_table.rs b/src/store/block_ref_table.rs
deleted file mode 100644
index c8a2a2a1..00000000
--- a/src/store/block_ref_table.rs
+++ /dev/null
@@ -1,68 +0,0 @@
-use async_trait::async_trait;
-use serde::{Deserialize, Serialize};
-use std::sync::Arc;
-
-use crate::background::*;
-use crate::data::*;
-use crate::error::Error;
-
-use crate::table::*;
-
-use crate::store::block::*;
-
-#[derive(PartialEq, Clone, Debug, Serialize, Deserialize)]
-pub struct BlockRef {
- // Primary key
- pub block: Hash,
-
- // Sort key
- pub version: UUID,
-
- // Keep track of deleted status
- pub deleted: bool,
-}
-
-impl Entry<Hash, UUID> for BlockRef {
- fn partition_key(&self) -> &Hash {
- &self.block
- }
- fn sort_key(&self) -> &UUID {
- &self.version
- }
-
- fn merge(&mut self, other: &Self) {
- if other.deleted {
- self.deleted = true;
- }
- }
-}
-
-pub struct BlockRefTable {
- pub background: Arc<BackgroundRunner>,
- pub block_manager: Arc<BlockManager>,
-}
-
-#[async_trait]
-impl TableSchema for BlockRefTable {
- type P = Hash;
- type S = UUID;
- type E = BlockRef;
- type Filter = ();
-
- async fn updated(&self, old: Option<Self::E>, new: Option<Self::E>) -> Result<(), Error> {
- let block = &old.as_ref().or(new.as_ref()).unwrap().block;
- let was_before = old.as_ref().map(|x| !x.deleted).unwrap_or(false);
- let is_after = new.as_ref().map(|x| !x.deleted).unwrap_or(false);
- if is_after && !was_before {
- self.block_manager.block_incref(block)?;
- }
- if was_before && !is_after {
- self.block_manager.block_decref(block)?;
- }
- Ok(())
- }
-
- fn matches_filter(entry: &Self::E, _filter: &Self::Filter) -> bool {
- !entry.deleted
- }
-}