bitrust 0.1.0

A Rust implementation of Bitcask, usable as a binary or a library.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26

use std::io;
use std::path::Path;
use std::process;

use common::BitrustOperation;
use lockfile::LockFile;

fn lock_file_base_name(op: BitrustOperation) -> String {
  String::from(match op {
    BitrustOperation::Create => ".create_lock",
    BitrustOperation::Write => ".write_lock",
    BitrustOperation::Merge => ".merge_lock",
  })
}

pub fn acquire<P>(
  data_dir: P,
  lock_type: BitrustOperation,
) -> io::Result<LockFile>
where
  P: AsRef<Path>,
{
  let lockfile_path = data_dir.as_ref().join(lock_file_base_name(lock_type));
  let pid_str = process::id().to_string();
  LockFile::new(lockfile_path, Some(pid_str.as_bytes()))
}