|
@@ -0,0 +1,727 @@
|
|
|
+use libc;
|
|
|
+use types::{in_addr, sockaddr, socklen_t};
|
|
|
+use RawLineBuffer;
|
|
|
+use core::ptr::null;
|
|
|
+use core::{mem, str};
|
|
|
+use alloc::vec::IntoIter;
|
|
|
+use alloc::string::ToString;
|
|
|
+use alloc::{Vec, String};
|
|
|
+use alloc::str::SplitWhitespace;
|
|
|
+use alloc::boxed::Box;
|
|
|
+use dns::{Dns, DnsQuery};
|
|
|
+use syscall::{self, Result, EINVAL, Error};
|
|
|
+use libc::c_char;
|
|
|
+
|
|
|
+const MAXADDRS: usize = 35;
|
|
|
+const MAXALIASES: usize = 35;
|
|
|
+
|
|
|
+struct LookupHost(IntoIter<in_addr>);
|
|
|
+
|
|
|
+impl Iterator for LookupHost {
|
|
|
+ type Item = in_addr;
|
|
|
+ fn next(&mut self) -> Option<Self::Item> {
|
|
|
+ self.0.next()
|
|
|
+ }
|
|
|
+}
|
|
|
+
|
|
|
+#[repr(C)]
|
|
|
+pub struct hostent {
|
|
|
+ h_name: *const libc::c_char,
|
|
|
+ h_aliases: *const *const libc::c_char,
|
|
|
+ h_addrtype: libc::c_int,
|
|
|
+ h_length: libc::c_int,
|
|
|
+ h_addr_list: *const *const libc::c_char,
|
|
|
+}
|
|
|
+
|
|
|
+/*
|
|
|
+ *#[repr(C)]
|
|
|
+ *pub struct netent {
|
|
|
+ * n_name: *const libc::c_char, [> official name of net <]
|
|
|
+ * n_aliases: *const *const libc::c_char, [> alias list <]
|
|
|
+ * n_addrtype: libc::c_int, [> net address type <]
|
|
|
+ * n_net: libc::c_ulong, [> network # <]
|
|
|
+ *}
|
|
|
+ */
|
|
|
+
|
|
|
+#[repr(C)]
|
|
|
+pub struct servent {
|
|
|
+ s_name: *const libc::c_char, /* official service name */
|
|
|
+ s_aliases: *const *const libc::c_char, /* alias list */
|
|
|
+ s_port: libc::c_int, /* port # */
|
|
|
+ s_proto: *const libc::c_char, /* protocol to use */
|
|
|
+}
|
|
|
+
|
|
|
+#[repr(C)]
|
|
|
+pub struct protoent {
|
|
|
+ p_name: *const libc::c_char, /* official protocol name */
|
|
|
+ p_aliases: *const *const libc::c_char, /* alias list */
|
|
|
+ p_proto: libc::c_int, /* protocol # */
|
|
|
+}
|
|
|
+
|
|
|
+#[repr(C)]
|
|
|
+pub struct addrinfo {
|
|
|
+ ai_flags: libc::c_int, /* AI_PASSIVE, AI_CANONNAME, AI_NUMERICHOST */
|
|
|
+ ai_family: libc::c_int, /* PF_xxx */
|
|
|
+ ai_socktype: libc::c_int, /* SOCK_xxx */
|
|
|
+ ai_protocol: libc::c_int, /* 0 or IPPROTO_xxx for IPv4 and IPv6 */
|
|
|
+ ai_addrlen: libc::size_t, /* length of ai_addr */
|
|
|
+ ai_canonname: *const libc::c_char, /* canonical name for hostname */
|
|
|
+ ai_addr: *const sockaddr, /* binary address */
|
|
|
+ ai_next: *const addrinfo, /* next structure in linked list */
|
|
|
+}
|
|
|
+
|
|
|
+static mut HOSTDB: usize = 0;
|
|
|
+//static mut NETDB: usize = 0;
|
|
|
+static mut PROTODB: usize = 0;
|
|
|
+static mut SERVDB: usize = 0;
|
|
|
+
|
|
|
+/*
|
|
|
+ *static mut NET_ENTRY: netent = netent {
|
|
|
+ * n_name: 0 as *const libc::c_char,
|
|
|
+ * n_aliases: 0 as *const *const libc::c_char,
|
|
|
+ * n_addrtype: 0,
|
|
|
+ * n_net: 0 as u64,
|
|
|
+ *};
|
|
|
+ *static mut NET_NAME: Option<Vec<u8>> = None;
|
|
|
+ *static mut NET_ALIASES: [*const c_char; MAXALIASES] = [null(); MAXALIASES];
|
|
|
+ *static mut NET_NUM: Option<u64> = None;
|
|
|
+ */
|
|
|
+
|
|
|
+static mut HOST_ENTRY: hostent = hostent {
|
|
|
+ h_name: 0 as *const libc::c_char,
|
|
|
+ h_aliases: 0 as *const *const libc::c_char,
|
|
|
+ h_addrtype: 0,
|
|
|
+ h_length: 0,
|
|
|
+ h_addr_list: 0 as *const *const libc::c_char,
|
|
|
+};
|
|
|
+static mut HOST_NAME: Option<Vec<u8>> = None;
|
|
|
+static mut HOST_ALIASES: Option<Vec<Vec<u8>>> = None;
|
|
|
+static mut HOST_ADDR: Option<in_addr> = None;
|
|
|
+static mut HOST_ADDR_LIST: [*const c_char; 2] = [null(); 2];
|
|
|
+static mut H_LINE: RawLineBuffer = RawLineBuffer {
|
|
|
+ fd: 0,
|
|
|
+ cur: 0,
|
|
|
+ read: 0,
|
|
|
+ buf: [0; 8 * 1024],
|
|
|
+};
|
|
|
+
|
|
|
+static mut PROTO_ENTRY: protoent = protoent {
|
|
|
+ p_name: 0 as *const libc::c_char,
|
|
|
+ p_aliases: 0 as *const *const libc::c_char,
|
|
|
+ p_proto: 0 as libc::c_int,
|
|
|
+};
|
|
|
+static mut PROTO_NAME: Option<Vec<u8>> = None;
|
|
|
+static mut PROTO_ALIASES: Option<Vec<Vec<u8>>> = None;
|
|
|
+static mut PROTO_NUM: Option<libc::c_int> = None;
|
|
|
+static mut P_LINE: RawLineBuffer = RawLineBuffer {
|
|
|
+ fd: 0,
|
|
|
+ cur: 0,
|
|
|
+ read: 0,
|
|
|
+ buf: [0; 8 * 1024],
|
|
|
+};
|
|
|
+
|
|
|
+static mut SERV_ENTRY: servent = servent {
|
|
|
+ s_name: 0 as *const libc::c_char,
|
|
|
+ s_aliases: 0 as *const *const libc::c_char,
|
|
|
+ s_port: 0 as libc::c_int,
|
|
|
+ s_proto: 0 as *const libc::c_char,
|
|
|
+};
|
|
|
+static mut SERV_NAME: Option<Vec<u8>> = None;
|
|
|
+static mut SERV_ALIASES: Option<Vec<Vec<u8>>> = None;
|
|
|
+static mut SERV_PORT: Option<libc::c_int> = None;
|
|
|
+static mut SERV_PROTO: Option<Vec<u8>> = None;
|
|
|
+static mut S_LINE: RawLineBuffer = RawLineBuffer {
|
|
|
+ fd: 0,
|
|
|
+ cur: 0,
|
|
|
+ read: 0,
|
|
|
+ buf: [0; 8 * 1024],
|
|
|
+};
|
|
|
+
|
|
|
+
|
|
|
+fn lookup_host(host: &str) -> Result<LookupHost> {
|
|
|
+ // XXX better error handling
|
|
|
+ let ip_string = String::from_utf8(::file_read_all("/etc/net/ip")?).or(Err(
|
|
|
+ Error::new(syscall::EIO),
|
|
|
+ ))?;
|
|
|
+ let ip: Vec<u8> = ip_string
|
|
|
+ .trim()
|
|
|
+ .split(".")
|
|
|
+ .map(|part| part.parse::<u8>().unwrap_or(0))
|
|
|
+ .collect();
|
|
|
+
|
|
|
+ let dns_string = String::from_utf8(::file_read_all("/etc/net/dns")?).or(Err(
|
|
|
+ Error::new(syscall::EIO),
|
|
|
+ ))?;
|
|
|
+ let dns: Vec<u8> = dns_string
|
|
|
+ .trim()
|
|
|
+ .split(".")
|
|
|
+ .map(|part| part.parse::<u8>().unwrap_or(0))
|
|
|
+ .collect();
|
|
|
+
|
|
|
+ if ip.len() == 4 && dns.len() == 4 {
|
|
|
+ let mut timespec = syscall::TimeSpec::default();
|
|
|
+ syscall::clock_gettime(syscall::CLOCK_REALTIME, &mut timespec).unwrap();
|
|
|
+ let tid = (timespec.tv_nsec >> 16) as u16;
|
|
|
+
|
|
|
+ let packet = Dns {
|
|
|
+ transaction_id: tid,
|
|
|
+ flags: 0x0100,
|
|
|
+ queries: vec![
|
|
|
+ DnsQuery {
|
|
|
+ name: host.to_string(),
|
|
|
+ q_type: 0x0001,
|
|
|
+ q_class: 0x0001,
|
|
|
+ },
|
|
|
+ ],
|
|
|
+ answers: vec![],
|
|
|
+ };
|
|
|
+
|
|
|
+ let packet_data = packet.compile();
|
|
|
+
|
|
|
+ let fd = ::RawFile::open(
|
|
|
+ format!("udp:/{}.{}.{}.{}:0", ip[0], ip[1], ip[2], ip[3]).as_bytes(),
|
|
|
+ syscall::O_RDWR,
|
|
|
+ )?;
|
|
|
+
|
|
|
+ let timeout = syscall::TimeSpec {
|
|
|
+ tv_sec: 5,
|
|
|
+ tv_nsec: 0,
|
|
|
+ };
|
|
|
+ let rt = fd.dup(b"read_timeout")?;
|
|
|
+ syscall::write(*rt, &timeout)?;
|
|
|
+ drop(rt);
|
|
|
+ let wt = fd.dup(b"write_timeout")?;
|
|
|
+ syscall::write(*wt, &timeout)?;
|
|
|
+ drop(wt);
|
|
|
+
|
|
|
+ let sendrecvfd = fd.dup(
|
|
|
+ format!("{}.{}.{}.{}:53", dns[0], dns[1], dns[2], dns[3])
|
|
|
+ .as_bytes(),
|
|
|
+ )?;
|
|
|
+ syscall::write(*sendrecvfd, &packet_data)?;
|
|
|
+ let mut buf = [0; 65536];
|
|
|
+ let count = syscall::read(*sendrecvfd, &mut buf)?;
|
|
|
+ drop(sendrecvfd);
|
|
|
+ drop(fd);
|
|
|
+
|
|
|
+ match Dns::parse(&buf[..count]) {
|
|
|
+ Ok(response) => {
|
|
|
+ let mut addrs = vec![];
|
|
|
+ for answer in response.answers.iter() {
|
|
|
+ if answer.a_type == 0x0001 && answer.a_class == 0x0001 &&
|
|
|
+ answer.data.len() == 4
|
|
|
+ {
|
|
|
+ let addr = in_addr {
|
|
|
+ s_addr: [
|
|
|
+ answer.data[0],
|
|
|
+ answer.data[1],
|
|
|
+ answer.data[2],
|
|
|
+ answer.data[3],
|
|
|
+ ],
|
|
|
+ };
|
|
|
+ addrs.push(addr);
|
|
|
+ }
|
|
|
+ }
|
|
|
+ Ok(LookupHost(addrs.into_iter()))
|
|
|
+ }
|
|
|
+ Err(_err) => Err(Error::new(EINVAL)),
|
|
|
+ }
|
|
|
+ } else {
|
|
|
+ Err(Error::new(EINVAL))
|
|
|
+ }
|
|
|
+}
|
|
|
+
|
|
|
+unsafe fn lookup_addr(addr: in_addr) -> Result<Vec<Vec<u8>>> {
|
|
|
+ // XXX better error handling
|
|
|
+ let ip_string = String::from_utf8(::file_read_all("/etc/net/ip")?).or(Err(
|
|
|
+ Error::new(syscall::EIO),
|
|
|
+ ))?;
|
|
|
+ let ip: Vec<u8> = ip_string
|
|
|
+ .trim()
|
|
|
+ .split(".")
|
|
|
+ .map(|part| part.parse::<u8>().unwrap_or(0))
|
|
|
+ .collect();
|
|
|
+
|
|
|
+ let dns_string = String::from_utf8(::file_read_all("/etc/net/dns")?).or(Err(
|
|
|
+ Error::new(syscall::EIO),
|
|
|
+ ))?;
|
|
|
+ let dns: Vec<u8> = dns_string
|
|
|
+ .trim()
|
|
|
+ .split(".")
|
|
|
+ .map(|part| part.parse::<u8>().unwrap_or(0))
|
|
|
+ .collect();
|
|
|
+
|
|
|
+ let mut addr_vec: Vec<u8> = addr.s_addr.to_vec();
|
|
|
+ addr_vec.reverse();
|
|
|
+ let mut name: Vec<u8> = vec![];
|
|
|
+ for octet in addr_vec {
|
|
|
+ for ch in format!("{}", octet).as_bytes() {
|
|
|
+ name.push(*ch);
|
|
|
+ }
|
|
|
+ name.push(b"."[0]);
|
|
|
+ }
|
|
|
+ name.pop();
|
|
|
+ for ch in b".IN-ADDR.ARPA" {
|
|
|
+ name.push(*ch);
|
|
|
+ }
|
|
|
+ let _ = syscall::write(2, name.as_slice());
|
|
|
+ let _ = syscall::write(2, "\n".as_bytes());
|
|
|
+
|
|
|
+ if ip.len() == 4 && dns.len() == 4 {
|
|
|
+ let mut timespec = syscall::TimeSpec::default();
|
|
|
+ syscall::clock_gettime(syscall::CLOCK_REALTIME, &mut timespec).unwrap();
|
|
|
+ let tid = (timespec.tv_nsec >> 16) as u16;
|
|
|
+
|
|
|
+ let packet = Dns {
|
|
|
+ transaction_id: tid,
|
|
|
+ flags: 0x0100,
|
|
|
+ queries: vec![
|
|
|
+ DnsQuery {
|
|
|
+ name: String::from_utf8(name).unwrap(),
|
|
|
+ q_type: 0x000C,
|
|
|
+ q_class: 0x0001,
|
|
|
+ },
|
|
|
+ ],
|
|
|
+ answers: vec![],
|
|
|
+ };
|
|
|
+
|
|
|
+ let packet_data = packet.compile();
|
|
|
+
|
|
|
+ let fd = ::RawFile::open(
|
|
|
+ format!("udp:/{}.{}.{}.{}:0", ip[0], ip[1], ip[2], ip[3]).as_bytes(),
|
|
|
+ syscall::O_RDWR,
|
|
|
+ )?;
|
|
|
+
|
|
|
+ let timeout = syscall::TimeSpec {
|
|
|
+ tv_sec: 5,
|
|
|
+ tv_nsec: 0,
|
|
|
+ };
|
|
|
+ let rt = fd.dup(b"read_timeout")?;
|
|
|
+ syscall::write(*rt, &timeout)?;
|
|
|
+ drop(rt);
|
|
|
+ let wt = fd.dup(b"write_timeout")?;
|
|
|
+ syscall::write(*wt, &timeout)?;
|
|
|
+ drop(wt);
|
|
|
+
|
|
|
+ let sendrecvfd = fd.dup(
|
|
|
+ format!("{}.{}.{}.{}:53", dns[0], dns[1], dns[2], dns[3])
|
|
|
+ .as_bytes(),
|
|
|
+ )?;
|
|
|
+ syscall::write(*sendrecvfd, &packet_data)?;
|
|
|
+ let mut buf = [0; 65536];
|
|
|
+ let count = syscall::read(*sendrecvfd, &mut buf)?;
|
|
|
+ drop(sendrecvfd);
|
|
|
+ drop(fd);
|
|
|
+
|
|
|
+ match Dns::parse(&buf[..count]) {
|
|
|
+ Ok(response) => {
|
|
|
+ let _ = syscall::write(2, format!("{:?}", response).as_bytes());
|
|
|
+ let _ = syscall::write(2, "\n".as_bytes());
|
|
|
+ let mut names = vec![];
|
|
|
+ for answer in response.answers.iter() {
|
|
|
+
|
|
|
+ if answer.a_type == 0x000C && answer.a_class == 0x0001
|
|
|
+ {
|
|
|
+ // answer.data is encoded kinda weird.
|
|
|
+ // Basically length-prefixed strings for each
|
|
|
+ // subsection of the domain.
|
|
|
+ // We need to parse this to insert periods where
|
|
|
+ // they belong (ie at the end of each string)
|
|
|
+ let data = parse_data(answer.data.clone());
|
|
|
+ names.push(data);
|
|
|
+ }
|
|
|
+ }
|
|
|
+ Ok(names)
|
|
|
+ }
|
|
|
+ Err(_err) => Err(Error::new(EINVAL)),
|
|
|
+ }
|
|
|
+ } else {
|
|
|
+ Err(Error::new(EINVAL))
|
|
|
+ }
|
|
|
+}
|
|
|
+
|
|
|
+fn parse_data(mut data: Vec<u8>) -> Vec<u8> {
|
|
|
+ let mut cursor = 0;
|
|
|
+ let mut offset = 0;
|
|
|
+ let mut index = 0;
|
|
|
+ let mut output = data.clone();
|
|
|
+ while index < data.len() - 1 {
|
|
|
+ offset = data[index] as usize;
|
|
|
+ index = cursor + offset + 1;
|
|
|
+ output[index] = '.' as u8;
|
|
|
+ cursor = index;
|
|
|
+ }
|
|
|
+ //we don't want an extra period at the end
|
|
|
+ output.pop();
|
|
|
+ return output
|
|
|
+}
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+libc_fn!(unsafe endhostent() {
|
|
|
+ let _ = syscall::close(HOSTDB);
|
|
|
+});
|
|
|
+
|
|
|
+/*
|
|
|
+ *libc_fn!(unsafe endnetent() {
|
|
|
+ * let _ = syscall::close(NETDB);
|
|
|
+ *});
|
|
|
+ */
|
|
|
+
|
|
|
+libc_fn!(unsafe endprotoent() {
|
|
|
+ let _ = syscall::close(PROTODB);
|
|
|
+});
|
|
|
+
|
|
|
+libc_fn!(unsafe endservent() {
|
|
|
+ let _ = syscall::close(SERVDB);
|
|
|
+});
|
|
|
+
|
|
|
+
|
|
|
+libc_fn!(unsafe gethostbyaddr(v: *const libc::c_void, length: socklen_t, format: libc::c_int) -> Result <*const hostent> {
|
|
|
+ let mut addr: in_addr = *(v as *mut in_addr);
|
|
|
+ match lookup_addr(addr) {
|
|
|
+ Ok(s) => {
|
|
|
+ HOST_ADDR_LIST = [addr.s_addr.as_mut_ptr() as *const c_char, null()];
|
|
|
+ let host_name = s[0].to_vec();
|
|
|
+ HOST_ENTRY = hostent {
|
|
|
+ h_name: host_name.as_ptr() as *const c_char,
|
|
|
+ h_aliases: [null();2].as_mut_ptr(),
|
|
|
+ h_addrtype: format,
|
|
|
+ h_length: length as i32,
|
|
|
+ h_addr_list: HOST_ADDR_LIST.as_ptr()
|
|
|
+ };
|
|
|
+ HOST_NAME = Some(host_name);
|
|
|
+ return Ok(&HOST_ENTRY)
|
|
|
+ }
|
|
|
+ Err(err) => Err(err)
|
|
|
+ }
|
|
|
+});
|
|
|
+
|
|
|
+libc_fn!(unsafe gethostbyname(name: *const c_char) -> Result<*const hostent> {
|
|
|
+ // XXX h_errno
|
|
|
+ let mut addr = mem::uninitialized();
|
|
|
+ let mut host_addr = if ::socket::inet_aton(name, &mut addr) == 1 {
|
|
|
+ addr
|
|
|
+ } else {
|
|
|
+ // XXX
|
|
|
+ let mut host = lookup_host(str::from_utf8_unchecked(::cstr_to_slice(name)))?;
|
|
|
+ host.next().ok_or(Error::new(syscall::ENOENT))? // XXX
|
|
|
+ };
|
|
|
+
|
|
|
+ let host_name: Vec<u8> = ::cstr_to_slice(name).to_vec();
|
|
|
+ HOST_ADDR_LIST = [host_addr.s_addr.as_mut_ptr() as *const c_char, null()];
|
|
|
+ HOST_ADDR = Some(host_addr);
|
|
|
+
|
|
|
+ HOST_ENTRY = hostent {
|
|
|
+ h_name: host_name.as_ptr() as *const c_char,
|
|
|
+ h_aliases: [null();2].as_mut_ptr(),
|
|
|
+ h_addrtype: ::socket::AF_INET,
|
|
|
+ h_length: 4,
|
|
|
+ h_addr_list: HOST_ADDR_LIST.as_ptr()
|
|
|
+ };
|
|
|
+
|
|
|
+ HOST_NAME = Some(host_name);
|
|
|
+
|
|
|
+ Ok(&HOST_ENTRY as *const hostent)
|
|
|
+});
|
|
|
+
|
|
|
+libc_fn!(unsafe gethostent() -> *const hostent {
|
|
|
+ if HOSTDB == 0 {
|
|
|
+ HOSTDB = syscall::open("/etc/hosts", syscall::O_RDONLY).unwrap();
|
|
|
+ H_LINE = RawLineBuffer::new(HOSTDB);
|
|
|
+ }
|
|
|
+
|
|
|
+ let mut r: Box<str> = Box::default();
|
|
|
+ while r.is_empty() || r.split_whitespace().next() == None || r.starts_with("#") {
|
|
|
+ r = match H_LINE.next() {
|
|
|
+ Some(Ok(s)) => s,
|
|
|
+ Some(Err(_)) => return null(),
|
|
|
+ None => return null(),
|
|
|
+ };
|
|
|
+ }
|
|
|
+
|
|
|
+
|
|
|
+ let mut iter: SplitWhitespace = r.split_whitespace();
|
|
|
+
|
|
|
+ let mut addr_vec = iter.next().unwrap().as_bytes().to_vec();
|
|
|
+ addr_vec.push(b'\0');
|
|
|
+ let addr_cstr = addr_vec.as_slice().as_ptr() as *const i8;
|
|
|
+ let mut addr = mem::uninitialized();
|
|
|
+ ::socket::inet_aton(addr_cstr, &mut addr);
|
|
|
+ HOST_ADDR_LIST = [addr.s_addr.as_mut_ptr() as *const c_char, null()];
|
|
|
+ HOST_ADDR = Some(addr);
|
|
|
+
|
|
|
+ let mut host_name = iter.next().unwrap().as_bytes().to_vec();
|
|
|
+ host_name.push(b'\0');
|
|
|
+
|
|
|
+ let mut host_aliases: Vec<Vec<u8>> = Vec::new();
|
|
|
+
|
|
|
+ loop {
|
|
|
+ let mut alias = match iter.next() {
|
|
|
+ Some(s) => s.as_bytes().to_vec(),
|
|
|
+ None => break
|
|
|
+ };
|
|
|
+ alias.push(b'\0');
|
|
|
+ host_aliases.push(alias);
|
|
|
+ }
|
|
|
+
|
|
|
+ //push a 0 so c doesn't segfault when it tries to read the next entry
|
|
|
+ host_aliases.push(vec![b'\0']);
|
|
|
+
|
|
|
+ HOST_ENTRY = hostent {
|
|
|
+ h_name: host_name.as_ptr() as *const c_char,
|
|
|
+ h_aliases: host_aliases.as_slice().as_ptr() as *const *const i8,
|
|
|
+ h_addrtype: ::socket::AF_INET,
|
|
|
+ h_length: 4,
|
|
|
+ h_addr_list: HOST_ADDR_LIST.as_ptr()
|
|
|
+ };
|
|
|
+ HOST_ALIASES = Some(host_aliases);
|
|
|
+ HOST_NAME = Some(host_name);
|
|
|
+ &HOST_ENTRY as *const hostent
|
|
|
+});
|
|
|
+
|
|
|
+/*
|
|
|
+ *libc_fn!(getnetbyaddr(net: libc::uint32_t, net_type: libc::c_int) -> Result<*const netent> {
|
|
|
+ * if NETDB == 0 {
|
|
|
+ * NETDB = syscall::open("/etc/networks", syscall::O_RDONLY).unwrap();
|
|
|
+ * }
|
|
|
+ *});
|
|
|
+ *
|
|
|
+ *libc_fn!(getnetbyname(name: *const libc::c_char) -> Result<*const netent> {
|
|
|
+ * if NETDB == 0 {
|
|
|
+ * NETDB = syscall::open("/etc/networks", syscall::O_RDONLY).unwrap();
|
|
|
+ * }
|
|
|
+ *});
|
|
|
+ *
|
|
|
+ */
|
|
|
+
|
|
|
+
|
|
|
+/*
|
|
|
+ *libc_fn!(getnetent() -> Result<*const netent> {
|
|
|
+ * if NETDB == 0 {
|
|
|
+ * NETDB = syscall::open("/etc/networks", syscall::O_RDONLY).unwrap();
|
|
|
+ * }
|
|
|
+ *
|
|
|
+ *});
|
|
|
+ */
|
|
|
+
|
|
|
+libc_fn!(unsafe getprotobyname(name: *const libc::c_char) -> Result<*const protoent> {
|
|
|
+ setprotoent(0);
|
|
|
+ let mut p: *const protoent;
|
|
|
+ while {p=getprotoent();
|
|
|
+ p!=null()} {
|
|
|
+ if libc::strcmp((*p).p_name, name) == 0 {
|
|
|
+ return Ok(p);
|
|
|
+ }
|
|
|
+ loop {
|
|
|
+ let mut cp = (*p).p_aliases;
|
|
|
+ if cp == null() {
|
|
|
+ break;
|
|
|
+ }
|
|
|
+ if libc::strcmp(*cp, name) == 0 {
|
|
|
+ return Ok(p);
|
|
|
+ }
|
|
|
+ cp = cp.offset(1);
|
|
|
+ }
|
|
|
+ }
|
|
|
+ endprotoent();
|
|
|
+ Err(Error::new(syscall::ENOENT))
|
|
|
+});
|
|
|
+
|
|
|
+libc_fn!(unsafe getprotobynumber(number: libc::c_int) -> Result<*const protoent> {
|
|
|
+ setprotoent(0);
|
|
|
+ let mut p: *const protoent;
|
|
|
+ while {p=getprotoent();
|
|
|
+ p!=null()} {
|
|
|
+ if (*p).p_proto == number {
|
|
|
+ return Ok(p);
|
|
|
+ }
|
|
|
+ }
|
|
|
+ endprotoent();
|
|
|
+ Err(Error::new(syscall::ENOENT))
|
|
|
+ });
|
|
|
+
|
|
|
+libc_fn!(unsafe getprotoent() -> *const protoent {
|
|
|
+ if PROTODB == 0 {
|
|
|
+ PROTODB = syscall::open("/etc/protocols", syscall::O_RDONLY).unwrap();
|
|
|
+ P_LINE = RawLineBuffer::new(PROTODB);
|
|
|
+ }
|
|
|
+
|
|
|
+ let mut r: Box<str> = Box::default();
|
|
|
+ while r.is_empty() || r.split_whitespace().next() == None || r.starts_with("#") {
|
|
|
+ r = match P_LINE.next() {
|
|
|
+ Some(Ok(s)) => s,
|
|
|
+ Some(Err(_)) => return null(),
|
|
|
+ None => return null(),
|
|
|
+ };
|
|
|
+ }
|
|
|
+
|
|
|
+ let mut iter: SplitWhitespace = r.split_whitespace();
|
|
|
+ let mut proto_name: Vec<u8> = iter.next().unwrap().as_bytes().to_vec();
|
|
|
+ proto_name.push(b'\0');
|
|
|
+
|
|
|
+ let mut num = iter.next().unwrap().as_bytes().to_vec();
|
|
|
+ num.push(b'\0');
|
|
|
+ PROTO_NUM = Some(libc::atoi(num.as_slice().as_ptr() as *mut i8));
|
|
|
+
|
|
|
+ let mut proto_aliases: Vec<Vec<u8>> = Vec::new();
|
|
|
+ loop {
|
|
|
+ let mut alias = match iter.next() {
|
|
|
+ Some(s) => s.as_bytes().to_vec(),
|
|
|
+ None => break
|
|
|
+ };
|
|
|
+ alias.push(b'\0');
|
|
|
+ proto_aliases.push(alias);
|
|
|
+ }
|
|
|
+ //push a 0 so c doesn't segfault when it tries to read the next entry
|
|
|
+ proto_aliases.push(vec![b'\0']);
|
|
|
+
|
|
|
+ PROTO_ENTRY = protoent {
|
|
|
+ p_name: proto_name.as_slice().as_ptr() as *const c_char,
|
|
|
+ p_aliases: proto_aliases.iter().map(|x| x.as_ptr() as *const i8).collect::<Vec<*const i8>>().as_ptr(),
|
|
|
+ p_proto: PROTO_NUM.unwrap()
|
|
|
+ };
|
|
|
+ PROTO_ALIASES = Some(proto_aliases);
|
|
|
+ PROTO_NAME = Some(proto_name);
|
|
|
+ &PROTO_ENTRY as *const protoent
|
|
|
+});
|
|
|
+
|
|
|
+libc_fn!(unsafe getservbyname(name: *const libc::c_char, proto: *const libc::c_char) -> Result<*const servent> {
|
|
|
+ setservent(0);
|
|
|
+ let mut p: *const servent;
|
|
|
+ while {p=getservent();
|
|
|
+ p!=null()} {
|
|
|
+ if libc::strcmp((*p).s_name, name) == 0 && libc::strcmp((*p).s_proto, proto) == 0 {
|
|
|
+ return Ok(p);
|
|
|
+ }
|
|
|
+ loop {
|
|
|
+ let mut cp = (*p).s_aliases;
|
|
|
+ if cp == null() {
|
|
|
+ break;
|
|
|
+ }
|
|
|
+ if libc::strcmp(*cp, name) == 0 && libc::strcmp((*p).s_proto, proto) == 0 {
|
|
|
+ return Ok(p);
|
|
|
+ }
|
|
|
+ cp = cp.offset(1);
|
|
|
+ }
|
|
|
+ }
|
|
|
+ Err(Error::new(syscall::ENOENT))
|
|
|
+});
|
|
|
+
|
|
|
+libc_fn!(unsafe getservbyport(port: libc::c_int, proto: *const libc::c_char) -> Result<*const servent> {
|
|
|
+ setprotoent(0);
|
|
|
+ let mut p: *const servent;
|
|
|
+ while {p=getservent();
|
|
|
+ p!=null()} {
|
|
|
+ if (*p).s_port == port && libc::strcmp((*p).s_proto, proto) == 0 {
|
|
|
+ return Ok(p);
|
|
|
+ }
|
|
|
+ }
|
|
|
+ endprotoent();
|
|
|
+ Err(Error::new(syscall::ENOENT))
|
|
|
+
|
|
|
+});
|
|
|
+
|
|
|
+libc_fn!(unsafe getservent() -> *const servent {
|
|
|
+ if SERVDB == 0 {
|
|
|
+ SERVDB = syscall::open("/etc/services", syscall::O_RDONLY).unwrap();
|
|
|
+ S_LINE = RawLineBuffer::new(SERVDB);
|
|
|
+ }
|
|
|
+
|
|
|
+ let mut r: Box<str> = Box::default();
|
|
|
+ while r.is_empty() || r.split_whitespace().next() == None || r.starts_with("#") {
|
|
|
+ r = match S_LINE.next() {
|
|
|
+ Some(Ok(s)) => s,
|
|
|
+ Some(Err(_)) => return null(),
|
|
|
+ None => return null(),
|
|
|
+ };
|
|
|
+ }
|
|
|
+ let mut iter: SplitWhitespace = r.split_whitespace();
|
|
|
+
|
|
|
+ let mut serv_name: Vec<u8> = iter.next().unwrap().as_bytes().to_vec();
|
|
|
+ serv_name.push(b'\0');
|
|
|
+
|
|
|
+ let port_proto = iter.next().unwrap();
|
|
|
+ let mut split = port_proto.split("/");
|
|
|
+ let port = libc::atoi(split.next().unwrap().as_ptr() as *const i8);
|
|
|
+ SERV_PORT = Some(port);
|
|
|
+ let proto = split.next().unwrap().as_bytes().to_vec();
|
|
|
+
|
|
|
+ let mut serv_aliases: Vec<Vec<u8>> = Vec::new();
|
|
|
+ loop {
|
|
|
+ let mut alias = match iter.next() {
|
|
|
+ Some(s) => s.as_bytes().to_vec(),
|
|
|
+ None => break
|
|
|
+ };
|
|
|
+ alias.push(b'\0');
|
|
|
+ serv_aliases.push(alias);
|
|
|
+ }
|
|
|
+ //push a 0 so c doesn't segfault when it tries to read the next entry
|
|
|
+ serv_aliases.push(vec![b'\0']);
|
|
|
+
|
|
|
+ SERV_ENTRY = servent {
|
|
|
+ s_name: serv_name.as_slice().as_ptr() as *const c_char,
|
|
|
+ s_aliases: serv_aliases.iter().map(|x| x.as_ptr() as *const i8).collect::<Vec<*const i8>>().as_ptr(),
|
|
|
+ s_port: SERV_PORT.unwrap(),
|
|
|
+ s_proto: proto.as_slice().as_ptr() as *const c_char
|
|
|
+ };
|
|
|
+
|
|
|
+ SERV_ALIASES = Some(serv_aliases);
|
|
|
+ SERV_NAME = Some(serv_name);
|
|
|
+ SERV_PROTO = Some(proto);
|
|
|
+ &SERV_ENTRY as *const servent
|
|
|
+
|
|
|
+});
|
|
|
+
|
|
|
+libc_fn!(unsafe sethostent(stayopen: libc::c_int) {
|
|
|
+ if HOSTDB == 0 {
|
|
|
+ HOSTDB = syscall::open("/etc/hosts", syscall::O_RDONLY).unwrap();
|
|
|
+ } else {
|
|
|
+ let _ = syscall::lseek(HOSTDB, 0, syscall::SEEK_SET);
|
|
|
+ }
|
|
|
+ H_LINE = RawLineBuffer::new(HOSTDB);
|
|
|
+});
|
|
|
+
|
|
|
+/*
|
|
|
+ *libc_fn!(unsafe setnetent(stayopen: libc::c_int) {
|
|
|
+ * if NETDB == 0 {
|
|
|
+ * NETDB = syscall::open("/etc/networks", syscall::O_RDONLY).unwrap();
|
|
|
+ * } else {
|
|
|
+ * let _ = syscall::lseek(NETDB, 0, syscall::SEEK_SET);
|
|
|
+ * }
|
|
|
+ *});
|
|
|
+ */
|
|
|
+
|
|
|
+libc_fn!(unsafe setprotoent(stayopen: libc::c_int) {
|
|
|
+ if PROTODB == 0 {
|
|
|
+ PROTODB = syscall::open("/etc/protocols", syscall::O_RDONLY).unwrap();
|
|
|
+ } else {
|
|
|
+ let _ = syscall::lseek(PROTODB, 0, syscall::SEEK_SET);
|
|
|
+ }
|
|
|
+ P_LINE = RawLineBuffer::new(PROTODB);
|
|
|
+});
|
|
|
+
|
|
|
+libc_fn!(unsafe setservent(stayopen: libc::c_int) {
|
|
|
+ if SERVDB == 0 {
|
|
|
+ SERVDB = syscall::open("/etc/services", syscall::O_RDONLY).unwrap();
|
|
|
+ } else {
|
|
|
+ let _ = syscall::lseek(SERVDB, 0, syscall::SEEK_SET);
|
|
|
+ }
|
|
|
+ S_LINE = RawLineBuffer::new(SERVDB);
|
|
|
+});
|
|
|
+
|
|
|
+//libc_fn!(getaddrinfo(node: *const libc::c_char, service: *const libc::c_char, hints: *const addrinfo, res: *mut *mut addrinfo) -> libc::c_int {
|
|
|
+
|
|
|
+//});
|
|
|
+
|
|
|
+//libc_fn!(getnameinfo(addr: *const sockaddr, addrlen: socklen_t, host: *mut libc::c_char, hostlen: socklen_t, serv: *mut libc::c_char, servlen: socklen_t, flags: libc::c_int) -> libc::c_int {
|
|
|
+
|
|
|
+//});
|
|
|
+
|
|
|
+//libc_fn!(freeaddrinfo(res: *mut addrinfo) {
|
|
|
+
|
|
|
+//});
|
|
|
+
|
|
|
+//libc_fn!(gai_strerror(errcode: libc::c_int) -> *const libc::c_char {
|
|
|
+
|
|
|
+//});
|