Skip to content

Commit

Permalink
Overhaul the termios API.
Browse files Browse the repository at this point in the history 
Instead of defining `Termios` as a plain alias for the libc `termios` type,
define our own `Termios` struct with a libc-compatible layout, so that we
can use `bitflags` flags types, and have better overall ergonomics.

This encapsulates the `termios` vs. `termios2` difference on Linux, and
supports arbitrary I/O speeds on both Linux and BSDs with a consistent
interface.

This is a little higher-level than rustix typically aims for, but it doesn't
incur extra syscalls or even extra `Termios` struct copies, and the things it
hides are both awkward and uninteresting, such as the whole termios vs.
termios2 split which only happens on Linux, where you have to use termios2 to
support arbitrary speeds but you can't use termios2 with `cfmakeraw` etc.,
and also `c_ispeed`/`c_ospeed` work differently in termios2. And PowerPC
lacks termios2 but has a termios that acts like termios2. And MIPS adds
`TCSETS` to its `TCSANOW` etc. values.
  • Loading branch information
@sunfishcode
sunfishcode committed Jun 15, 2023
1 parent 3dfd62c commit 9cc626d
Show file tree
Hide file tree
Showing 20 changed files with 1,783 additions and 1,784 deletions.
4 changes: 2 additions & 2 deletions Cargo.toml
View file
Original file line number Diff line number Diff line change
Expand Up @@ -38,7 +38,7 @@ once_cell = { version = "1.5.2", optional = true }
# libc backend can be selected via adding `--cfg=rustix_use_libc` to
# `RUSTFLAGS` or enabling the `use-libc` cargo feature.
[target.'cfg(all(not(rustix_use_libc), not(miri), target_os = "linux", target_endian = "little", any(target_arch = "arm", all(target_arch = "aarch64", target_pointer_width = "64"), target_arch = "powerpc64", target_arch = "riscv64", target_arch = "mips", target_arch = "mips64", target_arch = "x86", all(target_arch = "x86_64", target_pointer_width = "64"))))'.dependencies]
linux-raw-sys = { version = "0.4.1", default-features = false, features = ["general", "errno", "ioctl", "no_std"] }
linux-raw-sys = { version = "0.4.3", default-features = false, features = ["general", "errno", "ioctl", "no_std"] }
libc_errno = { package = "errno", version = "0.3.1", default-features = false, optional = true }
libc = { version = "0.2.144", features = ["extra_traits"], optional = true }

Expand All @@ -55,7 +55,7 @@ libc = { version = "0.2.144", features = ["extra_traits"] }
# Some syscalls do not have libc wrappers, such as in `io_uring`. For these,
# the libc backend uses the linux-raw-sys ABI and `libc::syscall`.
[target.'cfg(all(any(target_os = "android", target_os = "linux"), any(rustix_use_libc, miri, not(all(target_os = "linux", target_endian = "little", any(target_arch = "arm", all(target_arch = "aarch64", target_pointer_width = "64"), target_arch = "powerpc64", target_arch = "riscv64", target_arch = "mips", target_arch = "mips64", target_arch = "x86", all(target_arch = "x86_64", target_pointer_width = "64")))))))'.dependencies]
linux-raw-sys = { version = "0.4.1", default-features = false, features = ["general", "ioctl", "no_std"] }
linux-raw-sys = { version = "0.4.3", default-features = false, features = ["general", "ioctl", "no_std"] }

# For the libc backend on Windows, use the Winsock2 API in windows-sys.
[target.'cfg(windows)'.dependencies.windows-sys]
Expand Down
165 changes: 82 additions & 83 deletions examples/stdio.rs
View file
Original file line number Diff line number Diff line change
Expand Up @@ -36,7 +36,7 @@ fn main() -> io::Result<()> {
#[cfg(all(not(windows), feature = "stdio"))]
fn show<Fd: AsFd>(fd: Fd) -> io::Result<()> {
let fd = fd.as_fd();
println!(" - ready: {:?}", rustix::io::ioctl_fionread(fd)?);
println!(" - ready bytes: {:?}", rustix::io::ioctl_fionread(fd)?);

#[cfg(feature = "termios")]
if isatty(fd) {
Expand All @@ -58,57 +58,53 @@ fn show<Fd: AsFd>(fd: Fd) -> io::Result<()> {
use rustix::termios::*;
let term = tcgetattr(fd)?;

if let Some(speed) = speed_value(cfgetispeed(&term)) {
println!(" - ispeed: {}", speed);
}
if let Some(speed) = speed_value(cfgetospeed(&term)) {
println!(" - ospeed: {}", speed);
}
println!(" - input_speed: {}", term.input_speed());
println!(" - output_speed: {}", term.output_speed());

print!(" - in flags:");
if (term.c_iflag & IGNBRK) != 0 {
if term.input_modes.contains(InputModes::IGNBRK) {
print!(" IGNBRK");
}
if (term.c_iflag & BRKINT) != 0 {
if term.input_modes.contains(InputModes::BRKINT) {
print!(" BRKINT");
}
if (term.c_iflag & IGNPAR) != 0 {
if term.input_modes.contains(InputModes::IGNPAR) {
print!(" IGNPAR");
}
if (term.c_iflag & PARMRK) != 0 {
if term.input_modes.contains(InputModes::PARMRK) {
print!(" PARMRK");
}
if (term.c_iflag & INPCK) != 0 {
if term.input_modes.contains(InputModes::INPCK) {
print!(" INPCK");
}
if (term.c_iflag & ISTRIP) != 0 {
if term.input_modes.contains(InputModes::ISTRIP) {
print!(" ISTRIP");
}
if (term.c_iflag & INLCR) != 0 {
if term.input_modes.contains(InputModes::INLCR) {
print!(" INLCR");
}
if (term.c_iflag & IGNCR) != 0 {
if term.input_modes.contains(InputModes::IGNCR) {
print!(" IGNCR");
}
if (term.c_iflag & ICRNL) != 0 {
if term.input_modes.contains(InputModes::ICRNL) {
print!(" ICRNL");
}
#[cfg(any(linux_raw, all(libc, any(solarish, target_os = "haiku"))))]
if (term.c_iflag & IUCLC) != 0 {
#[cfg(any(linux_kernel, solarish, target_os = "haiku"))]
if term.input_modes.contains(InputModes::IUCLC) {
print!(" IUCLC");
}
if (term.c_iflag & IXON) != 0 {
if term.input_modes.contains(InputModes::IXON) {
print!(" IXON");
}
#[cfg(not(target_os = "redox"))]
if (term.c_iflag & IXANY) != 0 {
if term.input_modes.contains(InputModes::IXANY) {
print!(" IXANY");
}
if (term.c_iflag & IXOFF) != 0 {
if term.input_modes.contains(InputModes::IXOFF) {
print!(" IXOFF");
}
#[cfg(not(any(target_os = "haiku", target_os = "redox")))]
if (term.c_iflag & IMAXBEL) != 0 {
if term.input_modes.contains(InputModes::IMAXBEL) {
print!(" IMAXBEL");
}
#[cfg(not(any(
Expand All @@ -120,13 +116,13 @@ fn show<Fd: AsFd>(fd: Fd) -> io::Result<()> {
target_os = "haiku",
target_os = "redox",
)))]
if (term.c_iflag & IUTF8) != 0 {
if term.input_modes.contains(InputModes::IUTF8) {
print!(" IUTF8");
}
println!();

print!(" - out flags:");
if (term.c_oflag & OPOST) != 0 {
if term.output_modes.contains(OutputModes::OPOST) {
print!(" OPOST");
}
#[cfg(not(any(
Expand All @@ -136,58 +132,58 @@ fn show<Fd: AsFd>(fd: Fd) -> io::Result<()> {
target_os = "netbsd",
target_os = "redox"
)))]
if (term.c_oflag & OLCUC) != 0 {
if term.output_modes.contains(OutputModes::OLCUC) {
print!(" OLCUC");
}
if (term.c_oflag & ONLCR) != 0 {
if term.output_modes.contains(OutputModes::ONLCR) {
print!(" ONLCR");
}
if (term.c_oflag & OCRNL) != 0 {
if term.output_modes.contains(OutputModes::OCRNL) {
print!(" OCRNL");
}
if (term.c_oflag & ONOCR) != 0 {
if term.output_modes.contains(OutputModes::ONOCR) {
print!(" ONOCR");
}
if (term.c_oflag & ONLRET) != 0 {
if term.output_modes.contains(OutputModes::ONLRET) {
print!(" ONLRET");
}
#[cfg(not(bsd))]
if (term.c_oflag & OFILL) != 0 {
if term.output_modes.contains(OutputModes::OFILL) {
print!(" OFILL");
}
#[cfg(not(bsd))]
if (term.c_oflag & OFDEL) != 0 {
if term.output_modes.contains(OutputModes::OFDEL) {
print!(" OFDEL");
}
#[cfg(not(any(bsd, solarish, target_os = "redox")))]
if (term.c_oflag & NLDLY) != 0 {
if term.output_modes.contains(OutputModes::NLDLY) {
print!(" NLDLY");
}
#[cfg(not(any(bsd, solarish, target_os = "aix", target_os = "redox")))]
if (term.c_oflag & CRDLY) != 0 {
if term.output_modes.contains(OutputModes::CRDLY) {
print!(" CRDLY");
}
#[cfg(not(any(netbsdlike, solarish, target_os = "dragonfly", target_os = "redox")))]
if (term.c_oflag & TABDLY) != 0 {
if term.output_modes.contains(OutputModes::TABDLY) {
print!(" TABDLY");
}
#[cfg(not(any(bsd, solarish, target_os = "redox")))]
if (term.c_oflag & BSDLY) != 0 {
if term.output_modes.contains(OutputModes::BSDLY) {
print!(" BSDLY");
}
#[cfg(not(any(all(libc, target_env = "musl"), bsd, solarish, target_os = "redox")))]
if (term.c_oflag & VTDLY) != 0 {
#[cfg(not(any(bsd, solarish, target_os = "redox")))]
if term.output_modes.contains(OutputModes::VTDLY) {
print!(" VTDLY");
}
#[cfg(not(any(all(libc, target_env = "musl"), bsd, solarish, target_os = "redox")))]
if (term.c_oflag & FFDLY) != 0 {
#[cfg(not(any(bsd, solarish, target_os = "redox")))]
if term.output_modes.contains(OutputModes::FFDLY) {
print!(" FFDLY");
}
println!();

print!(" - control flags:");
#[cfg(not(any(bsd, target_os = "haiku", target_os = "redox")))]
if (term.c_cflag & CBAUD) != 0 {
if term.control_modes.contains(ControlModes::CBAUD) {
print!(" CBAUD");
}
#[cfg(not(any(
Expand All @@ -197,28 +193,28 @@ fn show<Fd: AsFd>(fd: Fd) -> io::Result<()> {
target_os = "haiku",
target_os = "redox"
)))]
if (term.c_cflag & CBAUDEX) != 0 {
if term.control_modes.contains(ControlModes::CBAUDEX) {
print!(" CBAUDEX");
}
if (term.c_cflag & CSIZE) != 0 {
if term.control_modes.contains(ControlModes::CSIZE) {
print!(" CSIZE");
}
if (term.c_cflag & CSTOPB) != 0 {
if term.control_modes.contains(ControlModes::CSTOPB) {
print!(" CSTOPB");
}
if (term.c_cflag & CREAD) != 0 {
if term.control_modes.contains(ControlModes::CREAD) {
print!(" CREAD");
}
if (term.c_cflag & PARENB) != 0 {
if term.control_modes.contains(ControlModes::PARENB) {
print!(" PARENB");
}
if (term.c_cflag & PARODD) != 0 {
if term.control_modes.contains(ControlModes::PARODD) {
print!(" PARODD");
}
if (term.c_cflag & HUPCL) != 0 {
if term.control_modes.contains(ControlModes::HUPCL) {
print!(" HUPCL");
}
if (term.c_cflag & CLOCAL) != 0 {
if term.control_modes.contains(ControlModes::CLOCAL) {
print!(" CLOCAL");
}
#[cfg(not(any(
Expand All @@ -227,7 +223,7 @@ fn show<Fd: AsFd>(fd: Fd) -> io::Result<()> {
target_os = "haiku",
target_os = "redox",
)))]
if (term.c_cflag & CIBAUD) != 0 {
if term.control_modes.contains(ControlModes::CIBAUD) {
print!(" CIBAUD");
}
#[cfg(not(any(
Expand All @@ -237,99 +233,102 @@ fn show<Fd: AsFd>(fd: Fd) -> io::Result<()> {
target_os = "haiku",
target_os = "redox",
)))]
if (term.c_cflag & CMSPAR) != 0 {
if term.control_modes.contains(ControlModes::CMSPAR) {
print!(" CMSPAR");
}
#[cfg(not(any(target_os = "aix", target_os = "redox")))]
if (term.c_cflag & CRTSCTS) != 0 {
if term.control_modes.contains(ControlModes::CRTSCTS) {
print!(" CRTSCTS");
}
println!();

print!(" - local flags:");
if (term.c_lflag & ISIG) != 0 {
if term.local_modes.contains(LocalModes::ISIG) {
print!(" ISIG");
}
if (term.c_lflag & ICANON) != 0 {
if term.local_modes.contains(LocalModes::ICANON) {
print!(" ICANON");
}
#[cfg(any(linux_raw, all(libc, any(target_arch = "s390x", target_os = "haiku"))))]
if (term.c_lflag & XCASE) != 0 {
#[cfg(any(linux_kernel, target_arch = "s390x", target_os = "haiku"))]
if term.local_modes.contains(LocalModes::XCASE) {
print!(" XCASE");
}
if (term.c_lflag & ECHO) != 0 {
if term.local_modes.contains(LocalModes::ECHO) {
print!(" ECHO");
}
if (term.c_lflag & ECHOE) != 0 {
if term.local_modes.contains(LocalModes::ECHOE) {
print!(" ECHOE");
}
if (term.c_lflag & ECHOK) != 0 {
if term.local_modes.contains(LocalModes::ECHOK) {
print!(" ECHOK");
}
if (term.c_lflag & ECHONL) != 0 {
if term.local_modes.contains(LocalModes::ECHONL) {
print!(" ECHONL");
}
#[cfg(not(any(target_os = "redox")))]
if (term.c_lflag & ECHOCTL) != 0 {
if term.local_modes.contains(LocalModes::ECHOCTL) {
print!(" ECHOCTL");
}
#[cfg(not(any(target_os = "redox")))]
if (term.c_lflag & ECHOPRT) != 0 {
if term.local_modes.contains(LocalModes::ECHOPRT) {
print!(" ECHOPRT");
}
#[cfg(not(any(target_os = "redox")))]
if (term.c_lflag & ECHOKE) != 0 {
if term.local_modes.contains(LocalModes::ECHOKE) {
print!(" ECHOKE");
}
#[cfg(not(any(target_os = "redox")))]
if (term.c_lflag & FLUSHO) != 0 {
if term.local_modes.contains(LocalModes::FLUSHO) {
print!(" FLUSHO");
}
if (term.c_lflag & NOFLSH) != 0 {
if term.local_modes.contains(LocalModes::NOFLSH) {
print!(" NOFLSH");
}
if (term.c_lflag & TOSTOP) != 0 {
if term.local_modes.contains(LocalModes::TOSTOP) {
print!(" TOSTOP");
}
#[cfg(not(any(target_os = "redox")))]
if (term.c_lflag & PENDIN) != 0 {
if term.local_modes.contains(LocalModes::PENDIN) {
print!(" PENDIN");
}
if (term.c_lflag & IEXTEN) != 0 {
if term.local_modes.contains(LocalModes::IEXTEN) {
print!(" IEXTEN");
}
println!();

println!(
" - keys: INTR={} QUIT={} ERASE={} KILL={} EOF={} TIME={} MIN={} ",
key(term.c_cc[VINTR]),
key(term.c_cc[VQUIT]),
key(term.c_cc[VERASE]),
key(term.c_cc[VKILL]),
key(term.c_cc[VEOF]),
term.c_cc[VTIME],
term.c_cc[VMIN]
key(term.special_codes[SpecialCodeIndex::VINTR]),
key(term.special_codes[SpecialCodeIndex::VQUIT]),
key(term.special_codes[SpecialCodeIndex::VERASE]),
key(term.special_codes[SpecialCodeIndex::VKILL]),
key(term.special_codes[SpecialCodeIndex::VEOF]),
term.special_codes[SpecialCodeIndex::VTIME],
term.special_codes[SpecialCodeIndex::VMIN]
);
println!(
" START={} STOP={} SUSP={} EOL={}",
key(term.c_cc[VSTART]),
key(term.c_cc[VSTOP]),
key(term.c_cc[VSUSP]),
key(term.c_cc[VEOL]),
key(term.special_codes[SpecialCodeIndex::VSTART]),
key(term.special_codes[SpecialCodeIndex::VSTOP]),
key(term.special_codes[SpecialCodeIndex::VSUSP]),
key(term.special_codes[SpecialCodeIndex::VEOL]),
);
#[cfg(not(target_os = "haiku"))]
println!(
" REPRINT={} DISCARD={}",
key(term.c_cc[VREPRINT]),
key(term.c_cc[VDISCARD])
key(term.special_codes[SpecialCodeIndex::VREPRINT]),
key(term.special_codes[SpecialCodeIndex::VDISCARD])
);
#[cfg(not(target_os = "haiku"))]
println!(
" WERASE={} VLNEXT={}",
key(term.c_cc[VWERASE]),
key(term.c_cc[VLNEXT]),
key(term.special_codes[SpecialCodeIndex::VWERASE]),
key(term.special_codes[SpecialCodeIndex::VLNEXT]),
);
println!(
" EOL2={}",
key(term.special_codes[SpecialCodeIndex::VEOL2])
);
println!(" EOL2={}", key(term.c_cc[VEOL2]));
}
} else {
println!(" - is not a tty");
Expand Down
Loading

0 comments on commit 9cc626d

Please sign in to comment.