mirror of
https://github.com/RGBCube/uutils-coreutils
synced 2025-08-01 05:27:45 +00:00
Merge pull request #464 from Arcterus/fix-build
Fix build for latest Rust and switch to -O
This commit is contained in:
commit
5e581907c1
8 changed files with 58 additions and 74 deletions
2
Makefile
2
Makefile
|
@ -19,7 +19,7 @@ TESTDIR := $(BASEDIR)/test
|
||||||
TEMPDIR := $(BASEDIR)/tmp
|
TEMPDIR := $(BASEDIR)/tmp
|
||||||
|
|
||||||
# Flags
|
# Flags
|
||||||
RUSTCFLAGS := --opt-level=3 -L $(BUILDDIR)/
|
RUSTCFLAGS := -O -L $(BUILDDIR)/
|
||||||
RMFLAGS :=
|
RMFLAGS :=
|
||||||
|
|
||||||
# Handle config setup
|
# Handle config setup
|
||||||
|
|
|
@ -122,13 +122,13 @@ fn copy(matches: getopts::Matches) {
|
||||||
panic!();
|
panic!();
|
||||||
}
|
}
|
||||||
} else {
|
} else {
|
||||||
if fs::stat(&dest).unwrap().kind != io::TypeDirectory {
|
if fs::stat(&dest).unwrap().kind != io::FileType::Directory {
|
||||||
error!("error: TARGET must be a directory");
|
error!("error: TARGET must be a directory");
|
||||||
panic!();
|
panic!();
|
||||||
}
|
}
|
||||||
|
|
||||||
for source in sources.iter() {
|
for source in sources.iter() {
|
||||||
if fs::stat(source).unwrap().kind != io::TypeFile {
|
if fs::stat(source).unwrap().kind != io::FileType::RegularFile {
|
||||||
error!("error: \"{}\" is not a file", source.display().to_string());
|
error!("error: \"{}\" is not a file", source.display().to_string());
|
||||||
continue;
|
continue;
|
||||||
}
|
}
|
||||||
|
@ -165,12 +165,12 @@ pub fn paths_refer_to_same_file(p1: &Path, p2: &Path) -> io::IoResult<bool> {
|
||||||
};
|
};
|
||||||
|
|
||||||
// We have to take symlinks and relative paths into account.
|
// We have to take symlinks and relative paths into account.
|
||||||
if p1_lstat.kind == io::TypeSymlink {
|
if p1_lstat.kind == io::FileType::Symlink {
|
||||||
raw_p1 = fs::readlink(&raw_p1).unwrap();
|
raw_p1 = fs::readlink(&raw_p1).unwrap();
|
||||||
}
|
}
|
||||||
raw_p1 = os::make_absolute(&raw_p1).unwrap();
|
raw_p1 = os::make_absolute(&raw_p1).unwrap();
|
||||||
|
|
||||||
if p2_lstat.kind == io::TypeSymlink {
|
if p2_lstat.kind == io::FileType::Symlink {
|
||||||
raw_p2 = fs::readlink(&raw_p2).unwrap();
|
raw_p2 = fs::readlink(&raw_p2).unwrap();
|
||||||
}
|
}
|
||||||
raw_p2 = os::make_absolute(&raw_p2).unwrap();
|
raw_p2 = os::make_absolute(&raw_p2).unwrap();
|
||||||
|
|
|
@ -16,7 +16,7 @@ extern crate getopts;
|
||||||
extern crate libc;
|
extern crate libc;
|
||||||
extern crate time;
|
extern crate time;
|
||||||
|
|
||||||
use std::io::{stderr, fs, FileStat, TypeDirectory};
|
use std::io::{stderr, fs, FileStat, FileType};
|
||||||
use std::num::Float;
|
use std::num::Float;
|
||||||
use std::option::Option;
|
use std::option::Option;
|
||||||
use std::path::Path;
|
use std::path::Path;
|
||||||
|
@ -48,7 +48,7 @@ fn du(path: &Path, mut my_stat: Stat,
|
||||||
let mut stats = vec!();
|
let mut stats = vec!();
|
||||||
let mut futures = vec!();
|
let mut futures = vec!();
|
||||||
|
|
||||||
if my_stat.fstat.kind == TypeDirectory {
|
if my_stat.fstat.kind == FileType::Directory {
|
||||||
let read = match fs::readdir(path) {
|
let read = match fs::readdir(path) {
|
||||||
Ok(read) => read,
|
Ok(read) => read,
|
||||||
Err(e) => {
|
Err(e) => {
|
||||||
|
@ -60,7 +60,7 @@ fn du(path: &Path, mut my_stat: Stat,
|
||||||
|
|
||||||
for f in read.into_iter() {
|
for f in read.into_iter() {
|
||||||
let this_stat = Stat{path: f.clone(), fstat: safe_unwrap!(fs::lstat(&f))};
|
let this_stat = Stat{path: f.clone(), fstat: safe_unwrap!(fs::lstat(&f))};
|
||||||
if this_stat.fstat.kind == TypeDirectory {
|
if this_stat.fstat.kind == FileType::Directory {
|
||||||
let oa_clone = options.clone();
|
let oa_clone = options.clone();
|
||||||
futures.push(Future::spawn(proc() { du(&f, this_stat, oa_clone, depth + 1) }))
|
futures.push(Future::spawn(proc() { du(&f, this_stat, oa_clone, depth + 1) }))
|
||||||
} else {
|
} else {
|
||||||
|
|
|
@ -89,7 +89,7 @@ fn resolve_path(path: &str, strip: bool, zero: bool, quiet: bool) -> bool {
|
||||||
}
|
}
|
||||||
match std::io::fs::lstat(&result) {
|
match std::io::fs::lstat(&result) {
|
||||||
Err(_) => break,
|
Err(_) => break,
|
||||||
Ok(ref s) if s.kind != std::io::TypeSymlink => break,
|
Ok(ref s) if s.kind != std::io::FileType::Symlink => break,
|
||||||
Ok(_) => {
|
Ok(_) => {
|
||||||
links_left -= 1;
|
links_left -= 1;
|
||||||
match std::io::fs::readlink(&result) {
|
match std::io::fs::readlink(&result) {
|
||||||
|
|
|
@ -9,7 +9,7 @@
|
||||||
* file that was distributed with this source code.
|
* file that was distributed with this source code.
|
||||||
*/
|
*/
|
||||||
|
|
||||||
#![feature(macro_rules)]
|
#![feature(if_let, macro_rules)]
|
||||||
|
|
||||||
extern crate getopts;
|
extern crate getopts;
|
||||||
extern crate libc;
|
extern crate libc;
|
||||||
|
@ -114,10 +114,9 @@ pub fn uumain(args: Vec<String>) -> int {
|
||||||
return 0;
|
return 0;
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
match remove(matches.free, force, interactive, one_fs, preserve_root,
|
if let Err(e) = remove(matches.free, force, interactive, one_fs, preserve_root,
|
||||||
recursive, dir, verbose) {
|
recursive, dir, verbose) {
|
||||||
Ok(()) => ( /* pass */ ),
|
return e;
|
||||||
Err(e) => return e
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
100
src/tail/tail.rs
100
src/tail/tail.rs
|
@ -9,12 +9,12 @@
|
||||||
*
|
*
|
||||||
*/
|
*/
|
||||||
|
|
||||||
#![feature(macro_rules)]
|
#![feature(if_let, macro_rules)]
|
||||||
|
|
||||||
extern crate getopts;
|
extern crate getopts;
|
||||||
|
|
||||||
use std::char::UnicodeChar;
|
use std::char::UnicodeChar;
|
||||||
use std::io::{stdin};
|
use std::io::{stdin, stdout};
|
||||||
use std::io::{BufferedReader, BytesReader};
|
use std::io::{BufferedReader, BytesReader};
|
||||||
use std::io::fs::File;
|
use std::io::fs::File;
|
||||||
use std::path::Path;
|
use std::path::Path;
|
||||||
|
@ -235,11 +235,44 @@ fn obsolete(options: &[String]) -> (Vec<String>, Option<uint>) {
|
||||||
(options, None)
|
(options, None)
|
||||||
}
|
}
|
||||||
|
|
||||||
fn tail<T: Reader>(reader: &mut BufferedReader<T>, line_count: uint, byte_count: uint, beginning: bool, lines: bool, follow: bool, sleep_msec: u64) {
|
macro_rules! tail_impl (
|
||||||
|
($kind:ty, $kindfn:ident, $kindprint:ident, $reader:ident, $count:ident, $beginning:ident) => ({
|
||||||
|
// read through each line and store them in a ringbuffer that always contains
|
||||||
|
// count lines/chars. When reaching the end of file, output the data in the
|
||||||
|
// ringbuf.
|
||||||
|
let mut ringbuf: RingBuf<$kind> = RingBuf::new();
|
||||||
|
let mut data = $reader.$kindfn().skip(
|
||||||
|
if $beginning {
|
||||||
|
let temp = $count;
|
||||||
|
$count = ::std::uint::MAX;
|
||||||
|
temp - 1
|
||||||
|
} else {
|
||||||
|
0
|
||||||
|
}
|
||||||
|
);
|
||||||
|
for io_datum in data {
|
||||||
|
match io_datum {
|
||||||
|
Ok(datum) => {
|
||||||
|
if $count <= ringbuf.len() {
|
||||||
|
ringbuf.pop_front();
|
||||||
|
}
|
||||||
|
ringbuf.push_back(datum);
|
||||||
|
}
|
||||||
|
Err(err) => panic!(err)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
let mut stdout = stdout();
|
||||||
|
for datum in ringbuf.iter() {
|
||||||
|
$kindprint(&mut stdout, datum);
|
||||||
|
}
|
||||||
|
})
|
||||||
|
)
|
||||||
|
|
||||||
|
fn tail<T: Reader>(reader: &mut BufferedReader<T>, mut line_count: uint, mut byte_count: uint, beginning: bool, lines: bool, follow: bool, sleep_msec: u64) {
|
||||||
if lines {
|
if lines {
|
||||||
tail_lines(reader, line_count, beginning);
|
tail_impl!(String, lines, print_string, reader, line_count, beginning);
|
||||||
} else {
|
} else {
|
||||||
tail_bytes(reader, byte_count, beginning);
|
tail_impl!(u8, bytes, print_byte, reader, byte_count, beginning);
|
||||||
}
|
}
|
||||||
|
|
||||||
// if we follow the file, sleep a bit and print the rest if the file has grown.
|
// if we follow the file, sleep a bit and print the rest if the file has grown.
|
||||||
|
@ -255,62 +288,15 @@ fn tail<T: Reader>(reader: &mut BufferedReader<T>, line_count: uint, byte_count:
|
||||||
}
|
}
|
||||||
|
|
||||||
#[inline]
|
#[inline]
|
||||||
fn tail_lines<T: Reader>(reader: &mut BufferedReader<T>, mut line_count: uint, beginning: bool) {
|
fn print_byte<T: Writer>(stdout: &mut T, ch: &u8) {
|
||||||
// read through each line and store them in a ringbuffer that always contains
|
if let Err(err) = stdout.write_u8(*ch) {
|
||||||
// line_count lines. When reaching the end of file, output the lines in the
|
crash!(1, "{}", err);
|
||||||
// ringbuf.
|
|
||||||
let mut ringbuf: RingBuf<String> = RingBuf::new();
|
|
||||||
let mut lines = reader.lines().skip(
|
|
||||||
if beginning {
|
|
||||||
let temp = line_count;
|
|
||||||
line_count = ::std::uint::MAX;
|
|
||||||
temp - 1
|
|
||||||
} else {
|
|
||||||
0
|
|
||||||
}
|
|
||||||
);
|
|
||||||
for io_line in lines {
|
|
||||||
match io_line {
|
|
||||||
Ok(line) => {
|
|
||||||
if line_count <= ringbuf.len() {
|
|
||||||
ringbuf.pop_front();
|
|
||||||
}
|
|
||||||
ringbuf.push_back(line);
|
|
||||||
}
|
|
||||||
Err(err) => panic!(err)
|
|
||||||
}
|
|
||||||
}
|
|
||||||
for line in ringbuf.iter() {
|
|
||||||
print!("{}", line);
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
#[inline]
|
#[inline]
|
||||||
fn tail_bytes<T: Reader>(reader: &mut BufferedReader<T>, mut byte_count: uint, beginning: bool) {
|
fn print_string<T: Writer>(_: &mut T, s: &String) {
|
||||||
let mut ringbuf: RingBuf<char> = RingBuf::new();
|
print!("{}", s);
|
||||||
let mut bytes = reader.bytes().skip(
|
|
||||||
if beginning {
|
|
||||||
let temp = byte_count;
|
|
||||||
byte_count = ::std::uint::MAX;
|
|
||||||
temp - 1
|
|
||||||
} else {
|
|
||||||
0
|
|
||||||
}
|
|
||||||
);
|
|
||||||
for io_byte in bytes {
|
|
||||||
match io_byte {
|
|
||||||
Ok(byte) => {
|
|
||||||
if byte_count <= ringbuf.len() {
|
|
||||||
ringbuf.pop_front();
|
|
||||||
}
|
|
||||||
ringbuf.push_back(byte as char);
|
|
||||||
}
|
|
||||||
Err(err) => panic!(err)
|
|
||||||
}
|
|
||||||
}
|
|
||||||
for byte in ringbuf.iter() {
|
|
||||||
print!("{}", byte);
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
|
|
||||||
fn version () {
|
fn version () {
|
||||||
|
|
|
@ -1,5 +1,4 @@
|
||||||
#![crate_name = "tee"]
|
#![crate_name = "tee"]
|
||||||
#![license="MIT"]
|
|
||||||
#![feature(phase)]
|
#![feature(phase)]
|
||||||
#![feature(macro_rules)]
|
#![feature(macro_rules)]
|
||||||
|
|
||||||
|
|
|
@ -64,8 +64,8 @@ pub fn uumain(args: Vec<String>) -> int {
|
||||||
|
|
||||||
let result = path.lstat().and_then(|info| {
|
let result = path.lstat().and_then(|info| {
|
||||||
match info.kind {
|
match info.kind {
|
||||||
io::TypeFile => Ok(()),
|
io::FileType::RegularFile => Ok(()),
|
||||||
io::TypeSymlink => Ok(()),
|
io::FileType::Symlink => Ok(()),
|
||||||
_ => Err(io::IoError {
|
_ => Err(io::IoError {
|
||||||
kind: io::OtherIoError,
|
kind: io::OtherIoError,
|
||||||
desc: "is not a file or symlink",
|
desc: "is not a file or symlink",
|
||||||
|
|
Loading…
Add table
Add a link
Reference in a new issue