Lines Matching refs:core

1 use core::intrinsics::likely;
2 use core::ops::BitXor;
180 let termios = tty.core().termios(); in receive_buf_common()
225 if tty.core().flags().contains(TtyFlag::LDISC_CHANGING) { in receive_buf_common()
242 let termios = tty.core().termios(); in receive_buf()
252 } else if tty.core().is_closing() && !termios.local_mode.contains(LocalMode::EXTPROC) { in receive_buf()
266 tty.flush_chars(tty.core()); in receive_buf()
278 tty.core() in receive_buf()
325 let termios = tty.core().termios(); in flush_echoes()
346 let termios = tty.core().termios(); in receive_buf_standard()
405 let termios = tty.core().termios(); in receive_special_char()
429 let flow = tty.core().flow_irqsave(); in receive_special_char()
506 tty.core().read_wq().wakeup_any( in receive_special_char()
519 tty.core().read_wq().wakeup_any( in receive_special_char()
547 tty.core().read_wq().wakeup_any( in receive_special_char()
737 let termios = tty.core().termios(); in is_flow_ctrl_char()
788 let mut ctrl_info = tty.core().contorl_info_irqsave(); in input_signal()
803 let _ = tty.flush_buffer(tty.core()); in input_signal()
815 if tty.core().link().is_some() { in input_signal()
816 self.packet_mode_flush(tty.core()); in input_signal()
822 let termios = tty.core().termios(); in receive_char()
839 if c == 0o377 && tty.core().termios().input_mode.contains(InputMode::PARMRK) { in receive_char()
886 tty.flush_chars(tty.core()); in commit_echoes()
1164 core: &TtyCoreData, in process_output_block()
1171 let space = tty.write_room(tty.core()); in process_output_block()
1236 return tty.write(core, buf, cnt); in process_output_block()
1248 tty.flush_chars(tty.core()); in process_echoes()
1254 let mut space = tty.write_room(tty.core()); in echoes()
1256 let termios = tty.core().termios(); in echoes()
1257 let core = tty.core(); in echoes() localVariable
1279 .put_char(tty.core(), EchoOperation::Start.to_u8()) in echoes()
1282 tty.write(core, &[EchoOperation::Start.to_u8()], 1)?; in echoes()
1328 if tty.put_char(tty.core(), 8).is_err() { in echoes()
1329 tty.write(core, &[8], 1)?; in echoes()
1343 if tty.put_char(tty.core(), 8).is_err() { in echoes()
1344 tty.write(core, &[8], 1)?; in echoes()
1346 if tty.put_char(tty.core(), b' ').is_err() { in echoes()
1347 tty.write(core, b" ", 1)?; in echoes()
1359 if tty.put_char(tty.core(), b'^').is_err() { in echoes()
1360 tty.write(core, b"^", 1)?; in echoes()
1363 if tty.put_char(tty.core(), ch ^ 0o100).is_err() { in echoes()
1364 tty.write(core, &[ch ^ 0o100], 1)?; in echoes()
1387 if tty.put_char(tty.core(), c).is_err() { in echoes()
1388 tty.write(core, &[c], 1)?; in echoes()
1415 let space = tty.write_room(tty.core()); in process_output()
1435 let termios = tty.core().termios(); in do_output_char()
1436 let core = tty.core(); in do_output_char() localVariable
1443 if tty.put_char(tty.core(), c).is_err() { in do_output_char()
1444 tty.write(core, &[c], 1)?; in do_output_char()
1463 tty.write(core, "\r\n".as_bytes(), 2)?; in do_output_char()
1501 tty.write(core, " ".as_bytes(), spaces)?; in do_output_char()
1523 if tty.put_char(tty.core(), c).is_err() { in do_output_char()
1524 tty.write(core, &[c], 1)?; in do_output_char()
1531 if link.core().contorl_info_irqsave().packet { in packet_mode_flush()
1536 link.core().read_wq().wakeup_all(); in packet_mode_flush()
1555 let core = tty.core(); in flush_buffer() localVariable
1556 let _ = core.termios(); in flush_buffer()
1570 if core.link().is_some() { in flush_buffer()
1571 ldata.packet_mode_flush(core); in flush_buffer()
1597 let core = tty.core(); in read() localVariable
1598 let termios = core.termios(); in read()
1631 let core = tty.core(); in read() localVariable
1632 let termios = core.termios(); in read()
1639 let packet = core.contorl_info_irqsave().packet; in read()
1647 let link = core.link().unwrap(); in read()
1648 let link = link.core(); in read()
1666 let core = tty.core(); in read() localVariable
1667 if !ldata.input_available(core.termios(), false) { in read()
1668 if core.flags().contains(TtyFlag::OTHER_CLOSED) { in read()
1673 if core.flags().contains(TtyFlag::HUPPED) || core.flags().contains(TtyFlag::HUPPING) in read()
1679 || core.flags().contains(TtyFlag::LDISC_CHANGING) in read()
1702 core.read_wq() in read()
1707 if ldata.icanon && !core.termios().local_mode.contains(LocalMode::EXTPROC) { in read()
1722 if ldata.copy_from_read_buf(core.termios(), buf, &mut nr, &mut offset)? in read()
1758 let core = binding.core(); in write() localVariable
1759 let termios = *core.termios(); in write()
1771 if core.flags().contains(TtyFlag::HUPPED) { in write()
1778 let ret = ldata.process_output_block(core, core.termios(), &buf[offset..], nr); in write()
1805 tty.flush_chars(core); in write()
1808 let write = tty.write(core, &buf[offset..], nr)?; in write()
1821 if mode.contains(FileMode::O_NONBLOCK) || core.flags().contains(TtyFlag::LDISC_CHANGING) in write()
1829 core.write_wq() in write()
1846 core::mem::size_of::<i32>(), in ioctl()
1856 let termios = tty.core().termios(); in ioctl()
1886 core::mem::size_of::<i32>(), in ioctl()
1905 let core = tty.core(); in set_termios() localVariable
1906 let termios = core.termios(); in set_termios()
2042 && (core in set_termios()
2053 core.read_wq().wakeup_all(); in set_termios()
2054 core.write_wq().wakeup_all(); in set_termios()
2059 let core = tty.core(); in poll() localVariable
2063 if ldata.input_available(core.termios(), true) { in poll()
2067 if core.contorl_info_irqsave().packet { in poll()
2068 let link = core.link(); in poll()
2072 .core() in poll()
2085 if core.flags().contains(TtyFlag::OTHER_CLOSED) { in poll()
2089 if core.driver().driver_funcs().chars_in_buffer() < 256 in poll()
2090 && core.driver().driver_funcs().write_room(core) > 0 in poll()