cluFlock 1.2.7

Installation and subsequent safe removal of `flock` locks for data streams.
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
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66



#[cfg(windows)]
pub mod windows {
	use core::ops::Deref;
	use std::fs::File;
	use std::path::Path;
	use cluFlock::ExclusiveFlock;

	struct AutoRemoveFile<'a>(&'a Path, File);

	impl<'a> AutoRemoveFile<'a> {
		pub fn file_create(path: &'a Path) -> Self {
			AutoRemoveFile(path, File::create(path).unwrap())
		}
	}

	impl<'a> Deref for AutoRemoveFile<'a> {
		type Target = File;
		
		#[inline(always)]
		fn deref(&self) -> &Self::Target {
			&self.1
		}
	}

	impl<'a> Drop for AutoRemoveFile<'a> {
		#[inline]
		fn drop(&mut self) {
			std::fs::remove_file(self.0).unwrap();
		}
	}



	#[test]
	fn windows_two_lock_behavior_onprocess() {
		let file = AutoRemoveFile::file_create(Path::new("./del_windows_two_lock_behavior_onprocess"));
		
		if let Err(e) = ExclusiveFlock::wait_lock(&*file) {
			panic!("Different platform behavior expected. {:?}", e);
		}
		
		let one_exclusive = ExclusiveFlock::wait_lock(&*file);
		let one_exclusive2 = ExclusiveFlock::try_lock(&*file);
		let one_exclusive3 = ExclusiveFlock::try_lock(&*file);
		
		if let Err(e) = one_exclusive { //one_exclusive: Ok
			panic!("Different platform behavior expected. {:?}", e);
		}
		if let Ok(e) = one_exclusive2 { //one_exclusive2: Err! the ok!
			panic!("Different platform behavior expected. {:?}", e);
		}
		if let Ok(e) = one_exclusive3 { //one_exclusive2: Err! the ok!
			panic!("Different platform behavior expected. {:?}", e);
		}
		
		// 1: Ok, 2: Err, 3: Err !
		
		drop(one_exclusive);
		drop(one_exclusive2);
		drop(one_exclusive3);
	}
}