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 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131 132 133 134 135 136 137 138 139 140 141 142 143 144 145 146 147 148 149 150 151 152 153 154 155 156 157 158 159 160 161 162 163 164 165
//#![doc(html_root_url = "https://alfiedotwtf.github.io/file-lock/")] //! File locking via POSIX advisory record locks. //! //! This crate provides the facility to obtain a write-lock and unlock a file following the //! advisory record lock scheme as specified by UNIX IEEE Std 1003.1-2001 (POSIX.1) via `fcntl()`. //! //! # Examples //! //! Please note that the examples use `tempfile` merely to quickly create a file which is removed //! automatically. In the common case, you would want to lock a file which is known to multiple //! processes. //! //! ``` //! extern crate file_lock; //! extern crate tempfile; //! //! use file_lock::*; //! use std::os::unix::io::AsRawFd; //! //! fn main() { //! let f = tempfile::TempFile::new().unwrap(); //! //! match Lock::new(f.as_raw_fd()).lock(LockKind::NonBlocking, AccessMode::Write) { //! Ok(_) => println!("Got lock"), //! Err(Error::Errno(i)) => println!("Got filesystem error {}", i), //! } //! } //! ``` extern crate libc; use std::os::unix::io::RawFd; /// Represents a write lock on a file. /// /// The `lock(LockKind)` method tries to obtain a write-lock on the file identified by a /// file-descriptor. One can obtain different kinds of write-locks. /// /// * LockKind::NonBlocking - immediately return with an `Errno` error. /// * LockKind::Blocking - waits (i.e. blocks the running thread) for the current owner of the lock /// to relinquish the lock. /// /// # Example /// /// Please note that the examples use `tempfile` merely to quickly create a file which is removed /// automatically. In the common case, you would want to lock a file which is known to multiple /// processes. /// /// ``` /// extern crate file_lock; /// extern crate tempfile; /// /// use file_lock::*; /// use std::os::unix::io::AsRawFd; /// /// fn main() { /// let f = tempfile::TempFile::new().unwrap(); /// /// match Lock::new(f.as_raw_fd()).lock(LockKind::NonBlocking, AccessMode::Write) { /// Ok(_) => { /// // we have a lock, which is discarded automatically. Otherwise you could call /// // `unlock()` to make it explicit /// println!("Got lock"); /// }, /// Err(Error::Errno(i)) => println!("Got filesystem error {}", i), /// } /// } /// ``` #[derive(Debug, Eq, PartialEq)] pub struct Lock { fd: RawFd, } /// Represents the error that occurred while trying to lock or unlock a file. #[derive(Debug, Eq, PartialEq)] pub enum Error { /// Caused when the error occurred at the filesystem layer (see /// [errno](https://crates.io/crates/errno)). Errno(i32), } /// Represents the kind of lock (e.g. *blocking*, *non-blocking*) #[derive(Clone, Debug)] pub enum LockKind { NonBlocking, Blocking, } /// Represents a file access mode, e.g. read or write #[derive(Clone, Debug)] pub enum AccessMode { Read, Write } impl Into<i32> for AccessMode { fn into(self) -> i32 { match self { AccessMode::Read => 0, AccessMode::Write => 1, } } } impl Into<i32> for LockKind { fn into(self) -> i32 { match self { LockKind::NonBlocking => 0, LockKind::Blocking => 1, } } } extern { fn c_lock(fd: i32, should_block: i32, is_write_lock: i32) -> i32; fn c_unlock(fd: i32) -> i32; } impl Lock { /// Create a new lock instance from the given file descriptor `fd`. /// /// You will have to call `lock(...)` on it to acquire any lock. pub fn new(fd: RawFd) -> Lock { Lock { fd: fd, } } /// Obtain a write-lock the file-descriptor /// /// For an example, please see the documentation of the [`Lock`](struct.Lock.html) structure. pub fn lock(&self, kind: LockKind, mode: AccessMode) -> Result<(), Error> { let errno = unsafe { c_lock(self.fd, kind.into(), mode.into()) }; return match errno { 0 => Ok(()), _ => Err(Error::Errno(errno)), } } /// Unlocks the file held by `Lock`. /// /// In reality, you shouldn't need to call `unlock()`. As `Lock` implements the `Drop` trait, /// once the `Lock` reference goes out of scope, `unlock()` will be called automatically. /// /// For an example, please see the documentation of the [`Lock`](struct.Lock.html) structure. pub fn unlock(&self) -> Result<(), Error> { unsafe { let errno = c_unlock(self.fd); return match errno { 0 => Ok(()), _ => Err(Error::Errno(errno)), } } } } #[allow(unused_must_use)] impl Drop for Lock { fn drop(&mut self) { self.unlock().ok(); } }