Auto merge of #23430 - alexcrichton:io-error, r=aturon
This commit stabilizes the `ErrorKind` enumeration which is consumed by and generated by the `io::Error` type. The purpose of this type is to serve as a cross-platform namespace to categorize errors into. Two specific issues are addressed as part of this stablization: * The naming of each variant was scrutinized and some were tweaked. An example is how `FileNotFound` was renamed to simply `NotFound`. These names should not show either a Unix or Windows bias and the set of names is intended to grow over time. For now the names will likely largely consist of those errors generated by the I/O APIs in the standard library. * The mapping of OS error codes onto kinds has been altered. Coalescing no longer occurs (multiple error codes become one kind). It is intended that each OS error code, if bound, corresponds to only one `ErrorKind`. The current set of error kinds was expanded slightly to include some networking errors. This commit also adds a `raw_os_error` function which returns an `Option<i32>` to extract the underlying raw error code from the `Error`. Closes #16666 [breaking-change]
This commit is contained in:
@@ -61,12 +61,12 @@ impl TempDir {
|
|||||||
let path = tmpdir.join(&leaf);
|
let path = tmpdir.join(&leaf);
|
||||||
match fs::create_dir(&path) {
|
match fs::create_dir(&path) {
|
||||||
Ok(_) => return Ok(TempDir { path: Some(path) }),
|
Ok(_) => return Ok(TempDir { path: Some(path) }),
|
||||||
Err(ref e) if e.kind() == ErrorKind::PathAlreadyExists => {}
|
Err(ref e) if e.kind() == ErrorKind::AlreadyExists => {}
|
||||||
Err(e) => return Err(e)
|
Err(e) => return Err(e)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
Err(Error::new(ErrorKind::PathAlreadyExists,
|
Err(Error::new(ErrorKind::AlreadyExists,
|
||||||
"too many temporary directories already exist",
|
"too many temporary directories already exist",
|
||||||
None))
|
None))
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -35,7 +35,6 @@
|
|||||||
#![feature(test)]
|
#![feature(test)]
|
||||||
#![feature(unicode)]
|
#![feature(unicode)]
|
||||||
#![feature(str_words)]
|
#![feature(str_words)]
|
||||||
#![feature(io)]
|
|
||||||
#![feature(file_path)]
|
#![feature(file_path)]
|
||||||
#![feature(path_ext)]
|
#![feature(path_ext)]
|
||||||
#![feature(path_relative_from)]
|
#![feature(path_relative_from)]
|
||||||
|
|||||||
@@ -31,7 +31,6 @@ Core encoding and decoding interfaces.
|
|||||||
#![feature(collections)]
|
#![feature(collections)]
|
||||||
#![feature(core)]
|
#![feature(core)]
|
||||||
#![feature(int_uint)]
|
#![feature(int_uint)]
|
||||||
#![feature(io)]
|
|
||||||
#![feature(old_path)]
|
#![feature(old_path)]
|
||||||
#![feature(rustc_private)]
|
#![feature(rustc_private)]
|
||||||
#![feature(staged_api)]
|
#![feature(staged_api)]
|
||||||
|
|||||||
@@ -493,7 +493,7 @@ pub fn copy<P: AsPath, Q: AsPath>(from: P, to: Q) -> io::Result<u64> {
|
|||||||
let from = from.as_path();
|
let from = from.as_path();
|
||||||
let to = to.as_path();
|
let to = to.as_path();
|
||||||
if !from.is_file() {
|
if !from.is_file() {
|
||||||
return Err(Error::new(ErrorKind::MismatchedFileTypeForOperation,
|
return Err(Error::new(ErrorKind::InvalidInput,
|
||||||
"the source path is not an existing file",
|
"the source path is not an existing file",
|
||||||
None))
|
None))
|
||||||
}
|
}
|
||||||
@@ -1134,7 +1134,7 @@ mod tests {
|
|||||||
let dir = &tmpdir.join("mkdir_error_twice");
|
let dir = &tmpdir.join("mkdir_error_twice");
|
||||||
check!(fs::create_dir(dir));
|
check!(fs::create_dir(dir));
|
||||||
let e = fs::create_dir(dir).err().unwrap();
|
let e = fs::create_dir(dir).err().unwrap();
|
||||||
assert_eq!(e.kind(), ErrorKind::PathAlreadyExists);
|
assert_eq!(e.kind(), ErrorKind::AlreadyExists);
|
||||||
}
|
}
|
||||||
|
|
||||||
#[test]
|
#[test]
|
||||||
|
|||||||
@@ -68,12 +68,12 @@ impl TempDir {
|
|||||||
let path = tmpdir.join(&leaf);
|
let path = tmpdir.join(&leaf);
|
||||||
match fs::create_dir(&path) {
|
match fs::create_dir(&path) {
|
||||||
Ok(_) => return Ok(TempDir { path: Some(path) }),
|
Ok(_) => return Ok(TempDir { path: Some(path) }),
|
||||||
Err(ref e) if e.kind() == ErrorKind::PathAlreadyExists => {}
|
Err(ref e) if e.kind() == ErrorKind::AlreadyExists => {}
|
||||||
Err(e) => return Err(e)
|
Err(e) => return Err(e)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
Err(Error::new(ErrorKind::PathAlreadyExists,
|
Err(Error::new(ErrorKind::AlreadyExists,
|
||||||
"too many temporary directories already exist",
|
"too many temporary directories already exist",
|
||||||
None))
|
None))
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -51,41 +51,53 @@ struct Custom {
|
|||||||
}
|
}
|
||||||
|
|
||||||
/// A list specifying general categories of I/O error.
|
/// A list specifying general categories of I/O error.
|
||||||
|
///
|
||||||
|
/// This list is intended to grow over time and it is not recommended to
|
||||||
|
/// exhaustively match against it.
|
||||||
#[derive(Copy, PartialEq, Eq, Clone, Debug)]
|
#[derive(Copy, PartialEq, Eq, Clone, Debug)]
|
||||||
#[unstable(feature = "io",
|
#[stable(feature = "rust1", since = "1.0.0")]
|
||||||
reason = "the interaction between OS error codes and how they map to \
|
|
||||||
these names (as well as the names themselves) has not \
|
|
||||||
been thoroughly thought out")]
|
|
||||||
pub enum ErrorKind {
|
pub enum ErrorKind {
|
||||||
/// The file was not found.
|
/// An entity was not found, often a file.
|
||||||
FileNotFound,
|
#[stable(feature = "rust1", since = "1.0.0")]
|
||||||
/// The file permissions disallowed access to this file.
|
NotFound,
|
||||||
|
/// The operation lacked the necessary privileges to complete.
|
||||||
|
#[stable(feature = "rust1", since = "1.0.0")]
|
||||||
PermissionDenied,
|
PermissionDenied,
|
||||||
/// The connection was refused by the remote server.
|
/// The connection was refused by the remote server.
|
||||||
|
#[stable(feature = "rust1", since = "1.0.0")]
|
||||||
ConnectionRefused,
|
ConnectionRefused,
|
||||||
/// The connection was reset by the remote server.
|
/// The connection was reset by the remote server.
|
||||||
|
#[stable(feature = "rust1", since = "1.0.0")]
|
||||||
ConnectionReset,
|
ConnectionReset,
|
||||||
/// The connection was aborted (terminated) by the remote server.
|
/// The connection was aborted (terminated) by the remote server.
|
||||||
|
#[stable(feature = "rust1", since = "1.0.0")]
|
||||||
ConnectionAborted,
|
ConnectionAborted,
|
||||||
/// The network operation failed because it was not connected yet.
|
/// The network operation failed because it was not connected yet.
|
||||||
|
#[stable(feature = "rust1", since = "1.0.0")]
|
||||||
NotConnected,
|
NotConnected,
|
||||||
|
/// A socket address could not be bound because the address is already in
|
||||||
|
/// use elsewhere.
|
||||||
|
#[stable(feature = "rust1", since = "1.0.0")]
|
||||||
|
AddrInUse,
|
||||||
|
/// A nonexistent interface was requested or the requested address was not
|
||||||
|
/// local.
|
||||||
|
#[stable(feature = "rust1", since = "1.0.0")]
|
||||||
|
AddrNotAvailable,
|
||||||
/// The operation failed because a pipe was closed.
|
/// The operation failed because a pipe was closed.
|
||||||
|
#[stable(feature = "rust1", since = "1.0.0")]
|
||||||
BrokenPipe,
|
BrokenPipe,
|
||||||
/// A file already existed with that name.
|
/// An entity already exists, often a file.
|
||||||
PathAlreadyExists,
|
#[stable(feature = "rust1", since = "1.0.0")]
|
||||||
/// No file exists at that location.
|
AlreadyExists,
|
||||||
PathDoesntExist,
|
/// The operation needs to block to complete, but the blocking operation was
|
||||||
/// The path did not specify the type of file that this operation required.
|
/// requested to not occur.
|
||||||
/// For example, attempting to copy a directory with the `fs::copy()`
|
#[stable(feature = "rust1", since = "1.0.0")]
|
||||||
/// operation will fail with this error.
|
WouldBlock,
|
||||||
MismatchedFileTypeForOperation,
|
/// A parameter was incorrect.
|
||||||
/// The operation temporarily failed (for example, because a signal was
|
#[stable(feature = "rust1", since = "1.0.0")]
|
||||||
/// received), and retrying may succeed.
|
|
||||||
ResourceUnavailable,
|
|
||||||
/// A parameter was incorrect in a way that caused an I/O error not part of
|
|
||||||
/// this list.
|
|
||||||
InvalidInput,
|
InvalidInput,
|
||||||
/// The I/O operation's timeout expired, causing it to be canceled.
|
/// The I/O operation's timeout expired, causing it to be canceled.
|
||||||
|
#[stable(feature = "rust1", since = "1.0.0")]
|
||||||
TimedOut,
|
TimedOut,
|
||||||
/// An error returned when an operation could not be completed because a
|
/// An error returned when an operation could not be completed because a
|
||||||
/// call to `write` returned `Ok(0)`.
|
/// call to `write` returned `Ok(0)`.
|
||||||
@@ -93,11 +105,23 @@ pub enum ErrorKind {
|
|||||||
/// This typically means that an operation could only succeed if it wrote a
|
/// This typically means that an operation could only succeed if it wrote a
|
||||||
/// particular number of bytes but only a smaller number of bytes could be
|
/// particular number of bytes but only a smaller number of bytes could be
|
||||||
/// written.
|
/// written.
|
||||||
|
#[stable(feature = "rust1", since = "1.0.0")]
|
||||||
WriteZero,
|
WriteZero,
|
||||||
/// This operation was interrupted
|
/// This operation was interrupted.
|
||||||
|
///
|
||||||
|
/// Interrupted operations can typically be retried.
|
||||||
|
#[stable(feature = "rust1", since = "1.0.0")]
|
||||||
Interrupted,
|
Interrupted,
|
||||||
/// Any I/O error not part of this list.
|
/// Any I/O error not part of this list.
|
||||||
|
#[stable(feature = "rust1", since = "1.0.0")]
|
||||||
Other,
|
Other,
|
||||||
|
|
||||||
|
/// Any I/O error not part of this list.
|
||||||
|
#[unstable(feature = "std_misc",
|
||||||
|
reason = "better expressed through extensible enums that this \
|
||||||
|
enum cannot be exhaustively matched against")]
|
||||||
|
#[doc(hidden)]
|
||||||
|
__Nonexhaustive,
|
||||||
}
|
}
|
||||||
|
|
||||||
impl Error {
|
impl Error {
|
||||||
@@ -134,6 +158,19 @@ impl Error {
|
|||||||
Error { repr: Repr::Os(code) }
|
Error { repr: Repr::Os(code) }
|
||||||
}
|
}
|
||||||
|
|
||||||
|
/// Returns the OS error that this error represents (if any).
|
||||||
|
///
|
||||||
|
/// If this `Error` was constructed via `last_os_error` then this function
|
||||||
|
/// will return `Some`, otherwise it will return `None`.
|
||||||
|
#[unstable(feature = "io", reason = "function was just added and the return \
|
||||||
|
type may become an abstract OS error")]
|
||||||
|
pub fn raw_os_error(&self) -> Option<i32> {
|
||||||
|
match self.repr {
|
||||||
|
Repr::Os(i) => Some(i),
|
||||||
|
Repr::Custom(..) => None,
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
/// Return the corresponding `ErrorKind` for this error.
|
/// Return the corresponding `ErrorKind` for this error.
|
||||||
#[stable(feature = "rust1", since = "1.0.0")]
|
#[stable(feature = "rust1", since = "1.0.0")]
|
||||||
pub fn kind(&self) -> ErrorKind {
|
pub fn kind(&self) -> ErrorKind {
|
||||||
|
|||||||
@@ -273,8 +273,7 @@ mod tests {
|
|||||||
match TcpListener::bind("1.1.1.1:9999") {
|
match TcpListener::bind("1.1.1.1:9999") {
|
||||||
Ok(..) => panic!(),
|
Ok(..) => panic!(),
|
||||||
Err(e) =>
|
Err(e) =>
|
||||||
// EADDRNOTAVAIL is mapped to ConnectionRefused
|
assert_eq!(e.kind(), ErrorKind::AddrNotAvailable),
|
||||||
assert_eq!(e.kind(), ErrorKind::ConnectionRefused),
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -282,8 +281,11 @@ mod tests {
|
|||||||
fn connect_error() {
|
fn connect_error() {
|
||||||
match TcpStream::connect("0.0.0.0:1") {
|
match TcpStream::connect("0.0.0.0:1") {
|
||||||
Ok(..) => panic!(),
|
Ok(..) => panic!(),
|
||||||
Err(e) => assert!((e.kind() == ErrorKind::ConnectionRefused)
|
Err(e) => assert!(e.kind() == ErrorKind::ConnectionRefused ||
|
||||||
|| (e.kind() == ErrorKind::InvalidInput)),
|
e.kind() == ErrorKind::InvalidInput ||
|
||||||
|
e.kind() == ErrorKind::AddrInUse ||
|
||||||
|
e.kind() == ErrorKind::AddrNotAvailable,
|
||||||
|
"bad error: {} {:?}", e, e.kind()),
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -535,7 +537,8 @@ mod tests {
|
|||||||
Ok(..) => panic!(),
|
Ok(..) => panic!(),
|
||||||
Err(e) => {
|
Err(e) => {
|
||||||
assert!(e.kind() == ErrorKind::ConnectionRefused ||
|
assert!(e.kind() == ErrorKind::ConnectionRefused ||
|
||||||
e.kind() == ErrorKind::Other,
|
e.kind() == ErrorKind::Other ||
|
||||||
|
e.kind() == ErrorKind::AddrInUse,
|
||||||
"unknown error: {} {:?}", e, e.kind());
|
"unknown error: {} {:?}", e, e.kind());
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -668,7 +668,7 @@ mod tests {
|
|||||||
#[test]
|
#[test]
|
||||||
fn test_process_output_fail_to_start() {
|
fn test_process_output_fail_to_start() {
|
||||||
match Command::new("/no-binary-by-this-name-should-exist").output() {
|
match Command::new("/no-binary-by-this-name-should-exist").output() {
|
||||||
Err(e) => assert_eq!(e.kind(), ErrorKind::FileNotFound),
|
Err(e) => assert_eq!(e.kind(), ErrorKind::NotFound),
|
||||||
Ok(..) => panic!()
|
Ok(..) => panic!()
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -139,22 +139,19 @@ pub fn decode_error_kind(errno: i32) -> ErrorKind {
|
|||||||
libc::EPIPE => ErrorKind::BrokenPipe,
|
libc::EPIPE => ErrorKind::BrokenPipe,
|
||||||
libc::ENOTCONN => ErrorKind::NotConnected,
|
libc::ENOTCONN => ErrorKind::NotConnected,
|
||||||
libc::ECONNABORTED => ErrorKind::ConnectionAborted,
|
libc::ECONNABORTED => ErrorKind::ConnectionAborted,
|
||||||
libc::EADDRNOTAVAIL => ErrorKind::ConnectionRefused,
|
libc::EADDRNOTAVAIL => ErrorKind::AddrNotAvailable,
|
||||||
libc::EADDRINUSE => ErrorKind::ConnectionRefused,
|
libc::EADDRINUSE => ErrorKind::AddrInUse,
|
||||||
libc::ENOENT => ErrorKind::FileNotFound,
|
libc::ENOENT => ErrorKind::NotFound,
|
||||||
libc::EISDIR => ErrorKind::InvalidInput,
|
|
||||||
libc::EINTR => ErrorKind::Interrupted,
|
libc::EINTR => ErrorKind::Interrupted,
|
||||||
libc::EINVAL => ErrorKind::InvalidInput,
|
libc::EINVAL => ErrorKind::InvalidInput,
|
||||||
libc::ENOTTY => ErrorKind::MismatchedFileTypeForOperation,
|
|
||||||
libc::ETIMEDOUT => ErrorKind::TimedOut,
|
libc::ETIMEDOUT => ErrorKind::TimedOut,
|
||||||
libc::ECANCELED => ErrorKind::TimedOut,
|
libc::consts::os::posix88::EEXIST => ErrorKind::AlreadyExists,
|
||||||
libc::consts::os::posix88::EEXIST => ErrorKind::PathAlreadyExists,
|
|
||||||
|
|
||||||
// These two constants can have the same value on some systems,
|
// These two constants can have the same value on some systems,
|
||||||
// but different values on others, so we can't use a match
|
// but different values on others, so we can't use a match
|
||||||
// clause
|
// clause
|
||||||
x if x == libc::EAGAIN || x == libc::EWOULDBLOCK =>
|
x if x == libc::EAGAIN || x == libc::EWOULDBLOCK =>
|
||||||
ErrorKind::ResourceUnavailable,
|
ErrorKind::WouldBlock,
|
||||||
|
|
||||||
_ => ErrorKind::Other,
|
_ => ErrorKind::Other,
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -149,25 +149,21 @@ pub fn decode_error_detailed(errno: i32) -> IoError {
|
|||||||
pub fn decode_error_kind(errno: i32) -> ErrorKind {
|
pub fn decode_error_kind(errno: i32) -> ErrorKind {
|
||||||
match errno as libc::c_int {
|
match errno as libc::c_int {
|
||||||
libc::ERROR_ACCESS_DENIED => ErrorKind::PermissionDenied,
|
libc::ERROR_ACCESS_DENIED => ErrorKind::PermissionDenied,
|
||||||
libc::ERROR_ALREADY_EXISTS => ErrorKind::PathAlreadyExists,
|
libc::ERROR_ALREADY_EXISTS => ErrorKind::AlreadyExists,
|
||||||
libc::ERROR_BROKEN_PIPE => ErrorKind::BrokenPipe,
|
libc::ERROR_BROKEN_PIPE => ErrorKind::BrokenPipe,
|
||||||
libc::ERROR_FILE_NOT_FOUND => ErrorKind::FileNotFound,
|
libc::ERROR_FILE_NOT_FOUND => ErrorKind::NotFound,
|
||||||
libc::ERROR_INVALID_FUNCTION => ErrorKind::InvalidInput,
|
|
||||||
libc::ERROR_INVALID_HANDLE => ErrorKind::MismatchedFileTypeForOperation,
|
|
||||||
libc::ERROR_INVALID_NAME => ErrorKind::InvalidInput,
|
|
||||||
libc::ERROR_NOTHING_TO_TERMINATE => ErrorKind::InvalidInput,
|
|
||||||
libc::ERROR_NO_DATA => ErrorKind::BrokenPipe,
|
libc::ERROR_NO_DATA => ErrorKind::BrokenPipe,
|
||||||
libc::ERROR_OPERATION_ABORTED => ErrorKind::TimedOut,
|
libc::ERROR_OPERATION_ABORTED => ErrorKind::TimedOut,
|
||||||
|
|
||||||
libc::WSAEACCES => ErrorKind::PermissionDenied,
|
libc::WSAEACCES => ErrorKind::PermissionDenied,
|
||||||
libc::WSAEADDRINUSE => ErrorKind::ConnectionRefused,
|
libc::WSAEADDRINUSE => ErrorKind::AddrInUse,
|
||||||
libc::WSAEADDRNOTAVAIL => ErrorKind::ConnectionRefused,
|
libc::WSAEADDRNOTAVAIL => ErrorKind::AddrNotAvailable,
|
||||||
libc::WSAECONNABORTED => ErrorKind::ConnectionAborted,
|
libc::WSAECONNABORTED => ErrorKind::ConnectionAborted,
|
||||||
libc::WSAECONNREFUSED => ErrorKind::ConnectionRefused,
|
libc::WSAECONNREFUSED => ErrorKind::ConnectionRefused,
|
||||||
libc::WSAECONNRESET => ErrorKind::ConnectionReset,
|
libc::WSAECONNRESET => ErrorKind::ConnectionReset,
|
||||||
libc::WSAEINVAL => ErrorKind::InvalidInput,
|
libc::WSAEINVAL => ErrorKind::InvalidInput,
|
||||||
libc::WSAENOTCONN => ErrorKind::NotConnected,
|
libc::WSAENOTCONN => ErrorKind::NotConnected,
|
||||||
libc::WSAEWOULDBLOCK => ErrorKind::ResourceUnavailable,
|
libc::WSAEWOULDBLOCK => ErrorKind::WouldBlock,
|
||||||
|
|
||||||
_ => ErrorKind::Other,
|
_ => ErrorKind::Other,
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user