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
use std::fs::{File, OpenOptions};
use std::hash::{Hash, Hasher};
use std::io;
use std::os::unix::fs::MetadataExt;
use std::os::unix::io::{AsRawFd, FromRawFd, IntoRawFd, RawFd};
use std::path::Path;
#[derive(Debug)]
pub struct Handle {
file: Option<File>,
is_std: bool,
dev: u64,
ino: u64,
}
impl Drop for Handle {
fn drop(&mut self) {
if self.is_std {
self.file.take().unwrap().into_raw_fd();
}
}
}
impl Eq for Handle {}
impl PartialEq for Handle {
fn eq(&self, other: &Handle) -> bool {
(self.dev, self.ino) == (other.dev, other.ino)
}
}
impl AsRawFd for crate::Handle {
fn as_raw_fd(&self) -> RawFd {
self.0.file.as_ref().take().unwrap().as_raw_fd()
}
}
impl IntoRawFd for crate::Handle {
fn into_raw_fd(mut self) -> RawFd {
self.0.file.take().unwrap().into_raw_fd()
}
}
impl Hash for Handle {
fn hash<H: Hasher>(&self, state: &mut H) {
self.dev.hash(state);
self.ino.hash(state);
}
}
impl Handle {
pub fn from_path<P: AsRef<Path>>(p: P) -> io::Result<Handle> {
Handle::from_file(OpenOptions::new().read(true).open(p)?)
}
pub fn from_file(file: File) -> io::Result<Handle> {
let md = file.metadata()?;
Ok(Handle {
file: Some(file),
is_std: false,
dev: md.dev(),
ino: md.ino(),
})
}
pub fn from_std(file: File) -> io::Result<Handle> {
Handle::from_file(file).map(|mut h| {
h.is_std = true;
h
})
}
pub fn stdin() -> io::Result<Handle> {
Handle::from_std(unsafe { File::from_raw_fd(0) })
}
pub fn stdout() -> io::Result<Handle> {
Handle::from_std(unsafe { File::from_raw_fd(1) })
}
pub fn stderr() -> io::Result<Handle> {
Handle::from_std(unsafe { File::from_raw_fd(2) })
}
pub fn as_file(&self) -> &File {
self.file.as_ref().take().unwrap()
}
pub fn as_file_mut(&mut self) -> &mut File {
self.file.as_mut().take().unwrap()
}
pub fn dev(&self) -> u64 {
self.dev
}
pub fn ino(&self) -> u64 {
self.ino
}
}