Struct garage_model::block::BlockManager

pub struct BlockManager {
    pub replication: TableShardedReplication,
    pub data_dir: PathBuf,
    pub data_dir_lock: Mutex<()>,
    // some fields omitted
}

The block manager, handling block exchange between nodes, and block storage on local node

Fields

replication: TableShardedReplication

Replication strategy, allowing to find on which node blocks should be located

data_dir: PathBuf

Directory in which block are stored

data_dir_lock: Mutex<()>

Lock to prevent concurrent edition of the directory

Implementations

impl BlockManager

pub fn new(
    db: &Db,
    data_dir: PathBuf,
    replication: TableShardedReplication,
    system: Arc<System>,
    rpc_server: &mut RpcServer
) -> Arc<Self>

pub fn spawn_background_worker(self: Arc<Self>)

pub fn block_incref(&self, hash: &Hash) -> Result<(), Error>

Increment the number of time a block is used, putting it to resynchronization if it is required, but not known

pub fn block_decref(&self, hash: &Hash) -> Result<(), Error>

Decrement the number of time a block is used

pub async fn rpc_get_block(&self, hash: &Hash) -> Result<Vec<u8>, Error>

Ask nodes that might have a block for it

pub async fn rpc_put_block(
    &self,
    hash: Hash,
    data: Vec<u8>
) -> Result<(), Error>

Send block to nodes that should have it

pub async fn repair_data_store(
    &self,
    must_exit: &Receiver<bool>
) -> Result<(), Error>

pub fn resync_queue_len(&self) -> usize

Get lenght of resync queue

pub fn rc_len(&self) -> usize