| 7 | }; |
| 8 | |
| 9 | pub fn bind_dev_log() -> LinuxResult<()> { |
| 10 | let server = UnixSocket::new(DgramTransport::new(1)); |
| 11 | server.bind(SocketAddrEx::Unix(UnixSocketAddr::Path("/dev/log".into())))?; |
| 12 | axtask::spawn_with_name( |
| 13 | move || { |
| 14 | let mut buf = [0u8; 65536]; |
| 15 | loop { |
| 16 | match server.recv(&mut buf[..], RecvOptions::default()) { |
| 17 | Ok(read) => { |
| 18 | let msg = ByteStr::new(buf[..read].trim_ascii_end()); |
| 19 | info!("{msg}"); |
| 20 | } |
| 21 | Err(err) => { |
| 22 | warn!("Failed to receive logs from client: {err:?}"); |
| 23 | break; |
| 24 | } |
| 25 | } |
| 26 | } |
| 27 | }, |
| 28 | "dev-log-server".into(), |
| 29 | ); |
| 30 | Ok(()) |
| 31 | } |