1
Fork 0

Remove thread-blocking call to libc::stat in Path::stat

Fixes #9958
This commit is contained in:
Ziad Hatahet 2013-10-22 18:25:07 -07:00
parent b477f7a7b7
commit 60245b9290
10 changed files with 65 additions and 318 deletions

View file

@ -12,15 +12,14 @@
pub use std::path::Path; pub use std::path::Path;
pub use package_id::PkgId; pub use package_id::PkgId;
pub use std::libc; pub use std::rt::io::FileStat;
pub use std::libc::stat;
condition! { condition! {
pub bad_path: (Path, ~str) -> Path; pub bad_path: (Path, ~str) -> Path;
} }
condition! { condition! {
pub bad_stat: (Path, ~str) -> stat; pub bad_stat: (Path, ~str) -> FileStat;
} }
condition! { condition! {

View file

@ -1,4 +1,4 @@
// Copyright 2012 The Rust Project Developers. See the COPYRIGHT // Copyright 2012-2013 The Rust Project Developers. See the COPYRIGHT
// file at the top-level directory of this distribution and at // file at the top-level directory of this distribution and at
// http://rust-lang.org/COPYRIGHT. // http://rust-lang.org/COPYRIGHT.
// //
@ -609,7 +609,7 @@ fn debug_flags() -> ~[~str] { ~[] }
/// Returns the last-modified date as an Option /// Returns the last-modified date as an Option
pub fn datestamp(p: &Path) -> Option<libc::time_t> { pub fn datestamp(p: &Path) -> Option<libc::time_t> {
debug!("Scrutinizing datestamp for {} - does it exist? {:?}", p.display(), os::path_exists(p)); debug!("Scrutinizing datestamp for {} - does it exist? {:?}", p.display(), os::path_exists(p));
let out = p.stat().map(|stat| stat.st_mtime); let out = p.stat().map(|stat| stat.modified);
debug!("Date = {:?}", out); debug!("Date = {:?}", out);
out.map(|t| { t as libc::time_t }) out.map(|t| { t as libc::time_t })
} }

View file

@ -18,17 +18,17 @@ pub fn digest_file_with_date(path: &Path) -> ~str {
use conditions::bad_path::cond; use conditions::bad_path::cond;
use cond1 = conditions::bad_stat::cond; use cond1 = conditions::bad_stat::cond;
let mut sha = ~Sha1::new();
let s = io::read_whole_file_str(path); let s = io::read_whole_file_str(path);
match s { match s {
Ok(s) => { Ok(s) => {
(*sha).input_str(s); let mut sha = Sha1::new();
sha.input_str(s);
let st = match path.stat() { let st = match path.stat() {
Some(st) => st, Some(st) => st,
None => cond1.raise((path.clone(), format!("Couldn't get file access time"))) None => cond1.raise((path.clone(), format!("Couldn't get file access time")))
}; };
(*sha).input_str(st.st_mtime.to_str()); sha.input_str(st.modified.to_str());
(*sha).result_str() sha.result_str()
} }
Err(e) => { Err(e) => {
let path = cond.raise((path.clone(), format!("Couldn't read file: {}", e))); let path = cond.raise((path.clone(), format!("Couldn't read file: {}", e)));
@ -43,13 +43,13 @@ pub fn digest_file_with_date(path: &Path) -> ~str {
pub fn digest_only_date(path: &Path) -> ~str { pub fn digest_only_date(path: &Path) -> ~str {
use cond = conditions::bad_stat::cond; use cond = conditions::bad_stat::cond;
let mut sha = ~Sha1::new(); let mut sha = Sha1::new();
let st = match path.stat() { let st = match path.stat() {
Some(st) => st, Some(st) => st,
None => cond.raise((path.clone(), format!("Couldn't get file access time"))) None => cond.raise((path.clone(), format!("Couldn't get file access time")))
}; };
(*sha).input_str(st.st_mtime.to_str()); sha.input_str(st.modified.to_str());
(*sha).result_str() sha.result_str()
} }
/// Adds multiple discovered outputs /// Adds multiple discovered outputs

View file

@ -688,228 +688,6 @@ fn from_utf8_with_replacement(mut v: &[u8]) -> ~str {
} }
s s
} }
// FIXME (#9537): libc::stat should derive Default
#[cfg(target_os = "linux")]
#[cfg(target_os = "android")]
mod stat {
#[allow(missing_doc)];
#[cfg(target_arch = "x86")]
pub mod arch {
use libc;
pub fn default_stat() -> libc::stat {
libc::stat {
st_dev: 0,
__pad1: 0,
st_ino: 0,
st_mode: 0,
st_nlink: 0,
st_uid: 0,
st_gid: 0,
st_rdev: 0,
__pad2: 0,
st_size: 0,
st_blksize: 0,
st_blocks: 0,
st_atime: 0,
st_atime_nsec: 0,
st_mtime: 0,
st_mtime_nsec: 0,
st_ctime: 0,
st_ctime_nsec: 0,
__unused4: 0,
__unused5: 0,
}
}
}
#[cfg(target_arch = "arm")]
pub mod arch {
use libc;
pub fn default_stat() -> libc::stat {
libc::stat {
st_dev: 0,
__pad0: [0, ..4],
__st_ino: 0,
st_mode: 0,
st_nlink: 0,
st_uid: 0,
st_gid: 0,
st_rdev: 0,
__pad3: [0, ..4],
st_size: 0,
st_blksize: 0,
st_blocks: 0,
st_atime: 0,
st_atime_nsec: 0,
st_mtime: 0,
st_mtime_nsec: 0,
st_ctime: 0,
st_ctime_nsec: 0,
st_ino: 0
}
}
}
#[cfg(target_arch = "mips")]
pub mod arch {
use libc;
pub fn default_stat() -> libc::stat {
libc::stat {
st_dev: 0,
st_pad1: [0, ..3],
st_ino: 0,
st_mode: 0,
st_nlink: 0,
st_uid: 0,
st_gid: 0,
st_rdev: 0,
st_pad2: [0, ..2],
st_size: 0,
st_pad3: 0,
st_atime: 0,
st_atime_nsec: 0,
st_mtime: 0,
st_mtime_nsec: 0,
st_ctime: 0,
st_ctime_nsec: 0,
st_blksize: 0,
st_blocks: 0,
st_pad5: [0, ..14],
}
}
}
#[cfg(target_arch = "x86_64")]
pub mod arch {
use libc;
pub fn default_stat() -> libc::stat {
libc::stat {
st_dev: 0,
st_ino: 0,
st_nlink: 0,
st_mode: 0,
st_uid: 0,
st_gid: 0,
__pad0: 0,
st_rdev: 0,
st_size: 0,
st_blksize: 0,
st_blocks: 0,
st_atime: 0,
st_atime_nsec: 0,
st_mtime: 0,
st_mtime_nsec: 0,
st_ctime: 0,
st_ctime_nsec: 0,
__unused: [0, 0, 0],
}
}
}
}
#[cfg(target_os = "freebsd")]
mod stat {
#[allow(missing_doc)];
#[cfg(target_arch = "x86_64")]
pub mod arch {
use libc;
pub fn default_stat() -> libc::stat {
libc::stat {
st_dev: 0,
st_ino: 0,
st_mode: 0,
st_nlink: 0,
st_uid: 0,
st_gid: 0,
st_rdev: 0,
st_atime: 0,
st_atime_nsec: 0,
st_mtime: 0,
st_mtime_nsec: 0,
st_ctime: 0,
st_ctime_nsec: 0,
st_size: 0,
st_blocks: 0,
st_blksize: 0,
st_flags: 0,
st_gen: 0,
st_lspare: 0,
st_birthtime: 0,
st_birthtime_nsec: 0,
__unused: [0, 0],
}
}
}
}
#[cfg(target_os = "macos")]
mod stat {
#[allow(missing_doc)];
pub mod arch {
use libc;
pub fn default_stat() -> libc::stat {
libc::stat {
st_dev: 0,
st_mode: 0,
st_nlink: 0,
st_ino: 0,
st_uid: 0,
st_gid: 0,
st_rdev: 0,
st_atime: 0,
st_atime_nsec: 0,
st_mtime: 0,
st_mtime_nsec: 0,
st_ctime: 0,
st_ctime_nsec: 0,
st_birthtime: 0,
st_birthtime_nsec: 0,
st_size: 0,
st_blocks: 0,
st_blksize: 0,
st_flags: 0,
st_gen: 0,
st_lspare: 0,
st_qspare: [0, 0],
}
}
}
}
#[cfg(target_os = "win32")]
mod stat {
#[allow(missing_doc)];
pub mod arch {
use libc;
pub fn default_stat() -> libc::stat {
libc::stat {
st_dev: 0,
st_ino: 0,
st_mode: 0,
st_nlink: 0,
st_uid: 0,
st_gid: 0,
st_rdev: 0,
st_size: 0,
st_atime: 0,
st_mtime: 0,
st_ctime: 0,
}
}
}
}
#[cfg(test)] #[cfg(test)]
mod tests { mod tests {
use super::{GenericPath, PosixPath, WindowsPath}; use super::{GenericPath, PosixPath, WindowsPath};
@ -921,7 +699,7 @@ mod tests {
let path: PosixPath = PosixPath::new(input.to_c_str()); let path: PosixPath = PosixPath::new(input.to_c_str());
assert_eq!(path.as_vec(), input.as_bytes()); assert_eq!(path.as_vec(), input.as_bytes());
let input = "\\foo\\bar\\baz"; let input = r"\foo\bar\baz";
let path: WindowsPath = WindowsPath::new(input.to_c_str()); let path: WindowsPath = WindowsPath::new(input.to_c_str());
assert_eq!(path.as_str().unwrap(), input.as_slice()); assert_eq!(path.as_str().unwrap(), input.as_slice());
} }

View file

@ -25,7 +25,7 @@ use vec::{CopyableVector, RSplitIterator, SplitIterator, Vector, VectorVector};
use super::{BytesContainer, GenericPath, GenericPathUnsafe}; use super::{BytesContainer, GenericPath, GenericPathUnsafe};
#[cfg(not(target_os = "win32"))] #[cfg(not(target_os = "win32"))]
use libc; use rt::io::{FileStat, file, io_error};
/// Iterator that yields successive components of a Path as &[u8] /// Iterator that yields successive components of a Path as &[u8]
pub type ComponentIter<'self> = SplitIterator<'self, u8>; pub type ComponentIter<'self> = SplitIterator<'self, u8>;
@ -445,16 +445,13 @@ static dot_dot_static: &'static [u8] = bytes!("..");
// Stat support // Stat support
#[cfg(not(target_os = "win32"))] #[cfg(not(target_os = "win32"))]
impl Path { impl Path {
/// Calls stat() on the represented file and returns the resulting libc::stat /// Calls stat() on the represented file and returns the resulting rt::io::FileStat
pub fn stat(&self) -> Option<libc::stat> { pub fn stat(&self) -> Option<FileStat> {
#[fixed_stack_segment]; #[inline(never)]; let mut file_stat: Option<FileStat> = None;
do self.with_c_str |buf| { do io_error::cond.trap(|_| { /* Ignore error, will return None */ }).inside {
let mut st = super::stat::arch::default_stat(); file_stat = file::stat(self);
match unsafe { libc::stat(buf as *libc::c_char, &mut st) } {
0 => Some(st),
_ => None
}
} }
file_stat
} }
/// Returns whether the represented file exists /// Returns whether the represented file exists
@ -466,10 +463,10 @@ impl Path {
} }
/// Returns the filesize of the represented file /// Returns the filesize of the represented file
pub fn get_size(&self) -> Option<i64> { pub fn get_size(&self) -> Option<u64> {
match self.stat() { match self.stat() {
None => None, None => None,
Some(st) => Some(st.st_size as i64) Some(st) => Some(st.size)
} }
} }
@ -477,7 +474,7 @@ impl Path {
pub fn get_mode(&self) -> Option<uint> { pub fn get_mode(&self) -> Option<uint> {
match self.stat() { match self.stat() {
None => None, None => None,
Some(st) => Some(st.st_mode as uint) Some(st) => Some(st.mode as uint)
} }
} }
} }
@ -486,54 +483,27 @@ impl Path {
#[cfg(target_os = "linux")] #[cfg(target_os = "linux")]
#[cfg(target_os = "macos")] #[cfg(target_os = "macos")]
impl Path { impl Path {
/// Returns the atime of the represented file, as (secs, nsecs) /// Returns the atime of the represented file, as msecs
pub fn get_atime(&self) -> Option<(i64, int)> { pub fn get_atime(&self) -> Option<u64> {
match self.stat() { match self.stat() {
None => None, None => None,
Some(st) => Some((st.st_atime as i64, st.st_atime_nsec as int)) Some(st) => Some(st.accessed)
} }
} }
/// Returns the mtime of the represented file, as (secs, nsecs) /// Returns the mtime of the represented file, as msecs
pub fn get_mtime(&self) -> Option<(i64, int)> { pub fn get_mtime(&self) -> Option<u64> {
match self.stat() { match self.stat() {
None => None, None => None,
Some(st) => Some((st.st_mtime as i64, st.st_mtime_nsec as int)) Some(st) => Some(st.modified)
} }
} }
/// Returns the ctime of the represented file, as (secs, nsecs) /// Returns the ctime of the represented file, as msecs
pub fn get_ctime(&self) -> Option<(i64, int)> { pub fn get_ctime(&self) -> Option<u64> {
match self.stat() { match self.stat() {
None => None, None => None,
Some(st) => Some((st.st_ctime as i64, st.st_ctime_nsec as int)) Some(st) => Some(st.created)
}
}
}
#[cfg(unix)]
impl Path {
/// Calls lstat() on the represented file and returns the resulting libc::stat
pub fn lstat(&self) -> Option<libc::stat> {
#[fixed_stack_segment]; #[inline(never)];
do self.with_c_str |buf| {
let mut st = super::stat::arch::default_stat();
match unsafe { libc::lstat(buf, &mut st) } {
0 => Some(st),
_ => None
}
}
}
}
#[cfg(target_os = "freebsd")]
#[cfg(target_os = "macos")]
impl Path {
/// Returns the birthtime of the represented file
pub fn get_birthtime(&self) -> Option<(i64, int)> {
match self.stat() {
None => None,
Some(st) => Some((st.st_birthtime as i64, st.st_birthtime_nsec as int))
} }
} }
} }

View file

@ -24,7 +24,7 @@ use vec::Vector;
use super::{contains_nul, BytesContainer, GenericPath, GenericPathUnsafe}; use super::{contains_nul, BytesContainer, GenericPath, GenericPathUnsafe};
#[cfg(target_os = "win32")] #[cfg(target_os = "win32")]
use libc; use rt::io::{FileStat, file, io_error};
/// Iterator that yields successive components of a Path as &str /// Iterator that yields successive components of a Path as &str
/// ///
@ -1059,16 +1059,13 @@ fn prefix_is_sep(p: Option<PathPrefix>, c: u8) -> bool {
// Stat support // Stat support
#[cfg(target_os = "win32")] #[cfg(target_os = "win32")]
impl Path { impl Path {
/// Calls stat() on the represented file and returns the resulting libc::stat /// Calls stat() on the represented file and returns the resulting rt::io::FileStat
pub fn stat(&self) -> Option<libc::stat> { pub fn stat(&self) -> Option<FileStat> {
#[fixed_stack_segment]; #[inline(never)]; let mut file_stat: Option<FileStat> = None;
do self.with_c_str |buf| { do io_error::cond.trap(|_| { /* Ignore error, will return None */ }).inside {
let mut st = super::stat::arch::default_stat(); file_stat = file::stat(self);
match unsafe { libc::stat(buf, &mut st) } {
0 => Some(st),
_ => None
}
} }
file_stat
} }
/// Returns whether the represented file exists /// Returns whether the represented file exists
@ -1080,10 +1077,10 @@ impl Path {
} }
/// Returns the filesize of the represented file /// Returns the filesize of the represented file
pub fn get_size(&self) -> Option<i64> { pub fn get_size(&self) -> Option<u64> {
match self.stat() { match self.stat() {
None => None, None => None,
Some(st) => Some(st.st_size as i64) Some(st) => Some(st.size)
} }
} }
@ -1091,37 +1088,31 @@ impl Path {
pub fn get_mode(&self) -> Option<uint> { pub fn get_mode(&self) -> Option<uint> {
match self.stat() { match self.stat() {
None => None, None => None,
Some(st) => Some(st.st_mode as uint) Some(st) => Some(st.mode as uint)
} }
} }
/// Returns the atime of the represented file, as (secs, nsecs) /// Returns the atime of the represented file, as msecs
/// pub fn get_atime(&self) -> Option<u64> {
/// nsecs is always 0
pub fn get_atime(&self) -> Option<(i64, int)> {
match self.stat() { match self.stat() {
None => None, None => None,
Some(st) => Some((st.st_atime as i64, 0)) Some(st) => Some(st.accessed)
} }
} }
/// Returns the mtime of the represented file, as (secs, nsecs) /// Returns the mtime of the represented file, as msecs
/// pub fn get_mtime(&self) -> Option<u64> {
/// nsecs is always 0
pub fn get_mtime(&self) -> Option<(i64, int)> {
match self.stat() { match self.stat() {
None => None, None => None,
Some(st) => Some((st.st_mtime as i64, 0)) Some(st) => Some(st.modified)
} }
} }
/// Returns the ctime of the represented file, as (secs, nsecs) /// Returns the ctime of the represented file, as msecs
/// pub fn get_ctime(&self) -> Option<u64> {
/// nsecs is always 0
pub fn get_ctime(&self) -> Option<(i64, int)> {
match self.stat() { match self.stat() {
None => None, None => None,
Some(st) => Some((st.st_ctime as i64, 0)) Some(st) => Some(st.created)
} }
} }
} }

View file

@ -59,8 +59,8 @@ use path::Path;
/// }).inside { /// }).inside {
/// let stream = match open(p, Create, ReadWrite) { /// let stream = match open(p, Create, ReadWrite) {
/// Some(s) => s, /// Some(s) => s,
/// None => fail!("whoops! I'm sure this raised, anyways.."); /// None => fail!("whoops! I'm sure this raised, anyways..")
/// } /// };
/// // do some stuff with that stream /// // do some stuff with that stream
/// ///
/// // the file stream will be closed at the end of this block /// // the file stream will be closed at the end of this block

View file

@ -654,6 +654,12 @@ pub struct FileStat {
is_file: bool, is_file: bool,
/// `true` if the file pointed at by the `PathInfo` is a directory /// `true` if the file pointed at by the `PathInfo` is a directory
is_dir: bool, is_dir: bool,
/// The file pointed at by the `PathInfo`'s device
device: u64,
/// The file pointed at by the `PathInfo`'s mode
mode: u64,
/// The file pointed at by the `PathInfo`'s inode
inode: u64,
/// The file pointed at by the `PathInfo`'s size in bytes /// The file pointed at by the `PathInfo`'s size in bytes
size: u64, size: u64,
/// The file pointed at by the `PathInfo`'s creation time /// The file pointed at by the `PathInfo`'s creation time

View file

@ -635,6 +635,9 @@ impl IoFactory for UvIoFactory {
path: Path::new(path_str.as_slice()), path: Path::new(path_str.as_slice()),
is_file: stat.is_file(), is_file: stat.is_file(),
is_dir: stat.is_dir(), is_dir: stat.is_dir(),
device: stat.st_dev,
mode: stat.st_mode,
inode: stat.st_ino,
size: stat.st_size, size: stat.st_size,
created: stat.st_ctim.tv_sec as u64, created: stat.st_ctim.tv_sec as u64,
modified: stat.st_mtim.tv_sec as u64, modified: stat.st_mtim.tv_sec as u64,

View file

@ -584,8 +584,8 @@ mod tests {
let parent_stat = parent_dir.stat().unwrap(); let parent_stat = parent_dir.stat().unwrap();
let child_stat = child_dir.stat().unwrap(); let child_stat = child_dir.stat().unwrap();
assert_eq!(parent_stat.st_dev, child_stat.st_dev); assert_eq!(parent_stat.device, child_stat.device);
assert_eq!(parent_stat.st_ino, child_stat.st_ino); assert_eq!(parent_stat.inode, child_stat.inode);
} }
#[test] #[test]
@ -601,8 +601,8 @@ mod tests {
let parent_stat = parent_dir.stat().unwrap(); let parent_stat = parent_dir.stat().unwrap();
let child_stat = child_dir.stat().unwrap(); let child_stat = child_dir.stat().unwrap();
assert_eq!(parent_stat.st_dev, child_stat.st_dev); assert_eq!(parent_stat.device, child_stat.device);
assert_eq!(parent_stat.st_ino, child_stat.st_ino); assert_eq!(parent_stat.inode, child_stat.inode);
} }
#[cfg(unix,not(target_os="android"))] #[cfg(unix,not(target_os="android"))]