src/libstd/sys/common/net.rs

   1 // Copyright 2013-2014 The Rust Project Developers. See the COPYRIGHT
   2 // file at the top-level directory of this distribution and at
   3 // http://rust-lang.org/COPYRIGHT.
   4 //
   5 // Licensed under the Apache License, Version 2.0 <LICENSE-APACHE or
   6 // http://www.apache.org/licenses/LICENSE-2.0> or the MIT license
   7 // <LICENSE-MIT or http://opensource.org/licenses/MIT>, at your
   8 // option. This file may not be copied, modified, or distributed
   9 // except according to those terms.
  10
  11 use cmp;
  12 use ffi::CString;
  13 use fmt;
  14 use io::{self, Error, ErrorKind};
  15 use libc::{c_int, c_void};
  16 use mem;
  17 use net::{SocketAddr, Shutdown, Ipv4Addr, Ipv6Addr};
  18 use ptr;
  19 use sys::net::{cvt, cvt_r, cvt_gai, Socket, init, wrlen_t};
  20 use sys::net::netc as c;
  21 use sys_common::{AsInner, FromInner, IntoInner};
  22 use time::Duration;
  23
  24 #[cfg(any(target_os = "dragonfly", target_os = "freebsd",
  25           target_os = "ios", target_os = "macos",
  26           target_os = "openbsd", target_os = "netbsd",
  27           target_os = "solaris"))]
  28 use sys::net::netc::IPV6_JOIN_GROUP as IPV6_ADD_MEMBERSHIP;
  29 #[cfg(not(any(target_os = "dragonfly", target_os = "freebsd",
  30               target_os = "ios", target_os = "macos",
  31               target_os = "openbsd", target_os = "netbsd",
  32               target_os = "solaris")))]
  33 use sys::net::netc::IPV6_ADD_MEMBERSHIP;
  34 #[cfg(any(target_os = "dragonfly", target_os = "freebsd",
  35           target_os = "ios", target_os = "macos",
  36           target_os = "openbsd", target_os = "netbsd",
  37           target_os = "solaris"))]
  38 use sys::net::netc::IPV6_LEAVE_GROUP as IPV6_DROP_MEMBERSHIP;
  39 #[cfg(not(any(target_os = "dragonfly", target_os = "freebsd",
  40               target_os = "ios", target_os = "macos",
  41               target_os = "openbsd", target_os = "netbsd",
  42               target_os = "solaris")))]
  43 use sys::net::netc::IPV6_DROP_MEMBERSHIP;
  44
  45 ////////////////////////////////////////////////////////////////////////////////
  46 // sockaddr and misc bindings
  47 ////////////////////////////////////////////////////////////////////////////////
  48
  49 pub fn setsockopt<T>(sock: &Socket, opt: c_int, val: c_int,
  50                      payload: T) -> io::Result<()> {
  51     unsafe {
  52         let payload = &payload as *const T as *const c_void;
  53         cvt(c::setsockopt(*sock.as_inner(), opt, val, payload,
  54                           mem::size_of::<T>() as c::socklen_t))?;
  55         Ok(())
  56     }
  57 }
  58
  59 pub fn getsockopt<T: Copy>(sock: &Socket, opt: c_int,
  60                        val: c_int) -> io::Result<T> {
  61     unsafe {
  62         let mut slot: T = mem::zeroed();
  63         let mut len = mem::size_of::<T>() as c::socklen_t;
  64         cvt(c::getsockopt(*sock.as_inner(), opt, val,
  65                           &mut slot as *mut _ as *mut _,
  66                           &mut len))?;
  67         assert_eq!(len as usize, mem::size_of::<T>());
  68         Ok(slot)
  69     }
  70 }
  71
  72 fn sockname<F>(f: F) -> io::Result<SocketAddr>
  73     where F: FnOnce(*mut c::sockaddr, *mut c::socklen_t) -> c_int
  74 {
  75     unsafe {
  76         let mut storage: c::sockaddr_storage = mem::zeroed();
  77         let mut len = mem::size_of_val(&storage) as c::socklen_t;
  78         cvt(f(&mut storage as *mut _ as *mut _, &mut len))?;
  79         sockaddr_to_addr(&storage, len as usize)
  80     }
  81 }
  82
  83 fn sockaddr_to_addr(storage: &c::sockaddr_storage,
  84                     len: usize) -> io::Result<SocketAddr> {
  85     match storage.ss_family as c_int {
  86         c::AF_INET => {
  87             assert!(len as usize >= mem::size_of::<c::sockaddr_in>());
  88             Ok(SocketAddr::V4(FromInner::from_inner(unsafe {
  89                 *(storage as *const _ as *const c::sockaddr_in)
  90             })))
  91         }
  92         c::AF_INET6 => {
  93             assert!(len as usize >= mem::size_of::<c::sockaddr_in6>());
  94             Ok(SocketAddr::V6(FromInner::from_inner(unsafe {
  95                 *(storage as *const _ as *const c::sockaddr_in6)
  96             })))
  97         }
  98         _ => {
  99             Err(Error::new(ErrorKind::InvalidInput, "invalid argument"))
 100         }
 101     }
 102 }
 103
 104 #[cfg(target_os = "android")]
 105 fn to_ipv6mr_interface(value: u32) -> c_int {
 106     value as c_int
 107 }
 108
 109 #[cfg(not(target_os = "android"))]
 110 fn to_ipv6mr_interface(value: u32) -> ::libc::c_uint {
 111     value as ::libc::c_uint
 112 }
 113
 114 ////////////////////////////////////////////////////////////////////////////////
 115 // get_host_addresses
 116 ////////////////////////////////////////////////////////////////////////////////
 117
 118 pub struct LookupHost {
 119     original: *mut c::addrinfo,
 120     cur: *mut c::addrinfo,
 121 }
 122
 123 impl Iterator for LookupHost {
 124     type Item = SocketAddr;
 125     fn next(&mut self) -> Option<SocketAddr> {
 126         loop {
 127             unsafe {
 128                 let cur = match self.cur.as_ref() {
 129                     None => return None,
 130                     Some(c) => c,
 131                 };
 132                 self.cur = cur.ai_next;
 133                 match sockaddr_to_addr(mem::transmute(cur.ai_addr),
 134                                        cur.ai_addrlen as usize)
 135                 {
 136                     Ok(addr) => return Some(addr),
 137                     Err(_) => continue,
 138                 }
 139             }
 140         }
 141     }
 142 }
 143
 144 unsafe impl Sync for LookupHost {}
 145 unsafe impl Send for LookupHost {}
 146
 147 impl Drop for LookupHost {
 148     fn drop(&mut self) {
 149         unsafe { c::freeaddrinfo(self.original) }
 150     }
 151 }
 152
 153 pub fn lookup_host(host: &str) -> io::Result<LookupHost> {
 154     init();
 155
 156     let c_host = CString::new(host)?;
 157     let hints = c::addrinfo {
 158         ai_flags: 0,
 159         ai_family: 0,
 160         ai_socktype: c::SOCK_STREAM,
 161         ai_protocol: 0,
 162         ai_addrlen: 0,
 163         ai_addr: ptr::null_mut(),
 164         ai_canonname: ptr::null_mut(),
 165         ai_next: ptr::null_mut()
 166     };
 167     let mut res = ptr::null_mut();
 168     unsafe {
 169         cvt_gai(c::getaddrinfo(c_host.as_ptr(), ptr::null(), &hints,
 170                                &mut res))?;
 171         Ok(LookupHost { original: res, cur: res })
 172     }
 173 }
 174
 175 ////////////////////////////////////////////////////////////////////////////////
 176 // TCP streams
 177 ////////////////////////////////////////////////////////////////////////////////
 178
 179 pub struct TcpStream {
 180     inner: Socket,
 181 }
 182
 183 impl TcpStream {
 184     pub fn connect(addr: &SocketAddr) -> io::Result<TcpStream> {
 185         init();
 186
 187         let sock = Socket::new(addr, c::SOCK_STREAM)?;
 188
 189         let (addrp, len) = addr.into_inner();
 190         cvt_r(|| unsafe { c::connect(*sock.as_inner(), addrp, len) })?;
 191         Ok(TcpStream { inner: sock })
 192     }
 193
 194     pub fn socket(&self) -> &Socket { &self.inner }
 195
 196     pub fn into_socket(self) -> Socket { self.inner }
 197
 198     pub fn set_read_timeout(&self, dur: Option<Duration>) -> io::Result<()> {
 199         self.inner.set_timeout(dur, c::SO_RCVTIMEO)
 200     }
 201
 202     pub fn set_write_timeout(&self, dur: Option<Duration>) -> io::Result<()> {
 203         self.inner.set_timeout(dur, c::SO_SNDTIMEO)
 204     }
 205
 206     pub fn read_timeout(&self) -> io::Result<Option<Duration>> {
 207         self.inner.timeout(c::SO_RCVTIMEO)
 208     }
 209
 210     pub fn write_timeout(&self) -> io::Result<Option<Duration>> {
 211         self.inner.timeout(c::SO_SNDTIMEO)
 212     }
 213
 214     pub fn read(&self, buf: &mut [u8]) -> io::Result<usize> {
 215         self.inner.read(buf)
 216     }
 217
 218     pub fn read_to_end(&self, buf: &mut Vec<u8>) -> io::Result<usize> {
 219         self.inner.read_to_end(buf)
 220     }
 221
 222     pub fn write(&self, buf: &[u8]) -> io::Result<usize> {
 223         let len = cmp::min(buf.len(), <wrlen_t>::max_value() as usize) as wrlen_t;
 224         let ret = cvt(unsafe {
 225             c::send(*self.inner.as_inner(),
 226                     buf.as_ptr() as *const c_void,
 227                     len,
 228                     0)
 229         })?;
 230         Ok(ret as usize)
 231     }
 232
 233     pub fn peer_addr(&self) -> io::Result<SocketAddr> {
 234         sockname(|buf, len| unsafe {
 235             c::getpeername(*self.inner.as_inner(), buf, len)
 236         })
 237     }
 238
 239     pub fn socket_addr(&self) -> io::Result<SocketAddr> {
 240         sockname(|buf, len| unsafe {
 241             c::getsockname(*self.inner.as_inner(), buf, len)
 242         })
 243     }
 244
 245     pub fn shutdown(&self, how: Shutdown) -> io::Result<()> {
 246         self.inner.shutdown(how)
 247     }
 248
 249     pub fn duplicate(&self) -> io::Result<TcpStream> {
 250         self.inner.duplicate().map(|s| TcpStream { inner: s })
 251     }
 252
 253     pub fn set_nodelay(&self, nodelay: bool) -> io::Result<()> {
 254         self.inner.set_nodelay(nodelay)
 255     }
 256
 257     pub fn nodelay(&self) -> io::Result<bool> {
 258         self.inner.nodelay()
 259     }
 260
 261     pub fn set_ttl(&self, ttl: u32) -> io::Result<()> {
 262         setsockopt(&self.inner, c::IPPROTO_IP, c::IP_TTL, ttl as c_int)
 263     }
 264
 265     pub fn ttl(&self) -> io::Result<u32> {
 266         let raw: c_int = getsockopt(&self.inner, c::IPPROTO_IP, c::IP_TTL)?;
 267         Ok(raw as u32)
 268     }
 269
 270     pub fn take_error(&self) -> io::Result<Option<io::Error>> {
 271         self.inner.take_error()
 272     }
 273
 274     pub fn set_nonblocking(&self, nonblocking: bool) -> io::Result<()> {
 275         self.inner.set_nonblocking(nonblocking)
 276     }
 277 }
 278
 279 impl FromInner<Socket> for TcpStream {
 280     fn from_inner(socket: Socket) -> TcpStream {
 281         TcpStream { inner: socket }
 282     }
 283 }
 284
 285 impl fmt::Debug for TcpStream {
 286     fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
 287         let mut res = f.debug_struct("TcpStream");
 288
 289         if let Ok(addr) = self.socket_addr() {
 290             res.field("addr", &addr);
 291         }
 292
 293         if let Ok(peer) = self.peer_addr() {
 294             res.field("peer", &peer);
 295         }
 296
 297         let name = if cfg!(windows) {"socket"} else {"fd"};
 298         res.field(name, &self.inner.as_inner())
 299             .finish()
 300     }
 301 }
 302
 303 ////////////////////////////////////////////////////////////////////////////////
 304 // TCP listeners
 305 ////////////////////////////////////////////////////////////////////////////////
 306
 307 pub struct TcpListener {
 308     inner: Socket,
 309 }
 310
 311 impl TcpListener {
 312     pub fn bind(addr: &SocketAddr) -> io::Result<TcpListener> {
 313         init();
 314
 315         let sock = Socket::new(addr, c::SOCK_STREAM)?;
 316
 317         // On platforms with Berkeley-derived sockets, this allows
 318         // to quickly rebind a socket, without needing to wait for
 319         // the OS to clean up the previous one.
 320         if !cfg!(windows) {
 321             setsockopt(&sock, c::SOL_SOCKET, c::SO_REUSEADDR,
 322                        1 as c_int)?;
 323         }
 324
 325         // Bind our new socket
 326         let (addrp, len) = addr.into_inner();
 327         cvt(unsafe { c::bind(*sock.as_inner(), addrp, len) })?;
 328
 329         // Start listening
 330         cvt(unsafe { c::listen(*sock.as_inner(), 128) })?;
 331         Ok(TcpListener { inner: sock })
 332     }
 333
 334     pub fn socket(&self) -> &Socket { &self.inner }
 335
 336     pub fn into_socket(self) -> Socket { self.inner }
 337
 338     pub fn socket_addr(&self) -> io::Result<SocketAddr> {
 339         sockname(|buf, len| unsafe {
 340             c::getsockname(*self.inner.as_inner(), buf, len)
 341         })
 342     }
 343
 344     pub fn accept(&self) -> io::Result<(TcpStream, SocketAddr)> {
 345         let mut storage: c::sockaddr_storage = unsafe { mem::zeroed() };
 346         let mut len = mem::size_of_val(&storage) as c::socklen_t;
 347         let sock = self.inner.accept(&mut storage as *mut _ as *mut _,
 348                                      &mut len)?;
 349         let addr = sockaddr_to_addr(&storage, len as usize)?;
 350         Ok((TcpStream { inner: sock, }, addr))
 351     }
 352
 353     pub fn duplicate(&self) -> io::Result<TcpListener> {
 354         self.inner.duplicate().map(|s| TcpListener { inner: s })
 355     }
 356
 357     pub fn set_ttl(&self, ttl: u32) -> io::Result<()> {
 358         setsockopt(&self.inner, c::IPPROTO_IP, c::IP_TTL, ttl as c_int)
 359     }
 360
 361     pub fn ttl(&self) -> io::Result<u32> {
 362         let raw: c_int = getsockopt(&self.inner, c::IPPROTO_IP, c::IP_TTL)?;
 363         Ok(raw as u32)
 364     }
 365
 366     pub fn set_only_v6(&self, only_v6: bool) -> io::Result<()> {
 367         setsockopt(&self.inner, c::IPPROTO_IPV6, c::IPV6_V6ONLY, only_v6 as c_int)
 368     }
 369
 370     pub fn only_v6(&self) -> io::Result<bool> {
 371         let raw: c_int = getsockopt(&self.inner, c::IPPROTO_IPV6, c::IPV6_V6ONLY)?;
 372         Ok(raw != 0)
 373     }
 374
 375     pub fn take_error(&self) -> io::Result<Option<io::Error>> {
 376         self.inner.take_error()
 377     }
 378
 379     pub fn set_nonblocking(&self, nonblocking: bool) -> io::Result<()> {
 380         self.inner.set_nonblocking(nonblocking)
 381     }
 382 }
 383
 384 impl FromInner<Socket> for TcpListener {
 385     fn from_inner(socket: Socket) -> TcpListener {
 386         TcpListener { inner: socket }
 387     }
 388 }
 389
 390 impl fmt::Debug for TcpListener {
 391     fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
 392         let mut res = f.debug_struct("TcpListener");
 393
 394         if let Ok(addr) = self.socket_addr() {
 395             res.field("addr", &addr);
 396         }
 397
 398         let name = if cfg!(windows) {"socket"} else {"fd"};
 399         res.field(name, &self.inner.as_inner())
 400             .finish()
 401     }
 402 }
 403
 404 ////////////////////////////////////////////////////////////////////////////////
 405 // UDP
 406 ////////////////////////////////////////////////////////////////////////////////
 407
 408 pub struct UdpSocket {
 409     inner: Socket,
 410 }
 411
 412 impl UdpSocket {
 413     pub fn bind(addr: &SocketAddr) -> io::Result<UdpSocket> {
 414         init();
 415
 416         let sock = Socket::new(addr, c::SOCK_DGRAM)?;
 417         let (addrp, len) = addr.into_inner();
 418         cvt(unsafe { c::bind(*sock.as_inner(), addrp, len) })?;
 419         Ok(UdpSocket { inner: sock })
 420     }
 421
 422     pub fn socket(&self) -> &Socket { &self.inner }
 423
 424     pub fn into_socket(self) -> Socket { self.inner }
 425
 426     pub fn socket_addr(&self) -> io::Result<SocketAddr> {
 427         sockname(|buf, len| unsafe {
 428             c::getsockname(*self.inner.as_inner(), buf, len)
 429         })
 430     }
 431
 432     pub fn recv_from(&self, buf: &mut [u8]) -> io::Result<(usize, SocketAddr)> {
 433         let mut storage: c::sockaddr_storage = unsafe { mem::zeroed() };
 434         let mut addrlen = mem::size_of_val(&storage) as c::socklen_t;
 435         let len = cmp::min(buf.len(), <wrlen_t>::max_value() as usize) as wrlen_t;
 436
 437         let n = cvt(unsafe {
 438             c::recvfrom(*self.inner.as_inner(),
 439                         buf.as_mut_ptr() as *mut c_void,
 440                         len, 0,
 441                         &mut storage as *mut _ as *mut _, &mut addrlen)
 442         })?;
 443         Ok((n as usize, sockaddr_to_addr(&storage, addrlen as usize)?))
 444     }
 445
 446     pub fn send_to(&self, buf: &[u8], dst: &SocketAddr) -> io::Result<usize> {
 447         let len = cmp::min(buf.len(), <wrlen_t>::max_value() as usize) as wrlen_t;
 448         let (dstp, dstlen) = dst.into_inner();
 449         let ret = cvt(unsafe {
 450             c::sendto(*self.inner.as_inner(),
 451                       buf.as_ptr() as *const c_void, len,
 452                       0, dstp, dstlen)
 453         })?;
 454         Ok(ret as usize)
 455     }
 456
 457     pub fn duplicate(&self) -> io::Result<UdpSocket> {
 458         self.inner.duplicate().map(|s| UdpSocket { inner: s })
 459     }
 460
 461     pub fn set_read_timeout(&self, dur: Option<Duration>) -> io::Result<()> {
 462         self.inner.set_timeout(dur, c::SO_RCVTIMEO)
 463     }
 464
 465     pub fn set_write_timeout(&self, dur: Option<Duration>) -> io::Result<()> {
 466         self.inner.set_timeout(dur, c::SO_SNDTIMEO)
 467     }
 468
 469     pub fn read_timeout(&self) -> io::Result<Option<Duration>> {
 470         self.inner.timeout(c::SO_RCVTIMEO)
 471     }
 472
 473     pub fn write_timeout(&self) -> io::Result<Option<Duration>> {
 474         self.inner.timeout(c::SO_SNDTIMEO)
 475     }
 476
 477     pub fn set_broadcast(&self, broadcast: bool) -> io::Result<()> {
 478         setsockopt(&self.inner, c::SOL_SOCKET, c::SO_BROADCAST, broadcast as c_int)
 479     }
 480
 481     pub fn broadcast(&self) -> io::Result<bool> {
 482         let raw: c_int = getsockopt(&self.inner, c::SOL_SOCKET, c::SO_BROADCAST)?;
 483         Ok(raw != 0)
 484     }
 485
 486     pub fn set_multicast_loop_v4(&self, multicast_loop_v4: bool) -> io::Result<()> {
 487         setsockopt(&self.inner, c::IPPROTO_IP, c::IP_MULTICAST_LOOP, multicast_loop_v4 as c_int)
 488     }
 489
 490     pub fn multicast_loop_v4(&self) -> io::Result<bool> {
 491         let raw: c_int = getsockopt(&self.inner, c::IPPROTO_IP, c::IP_MULTICAST_LOOP)?;
 492         Ok(raw != 0)
 493     }
 494
 495     pub fn set_multicast_ttl_v4(&self, multicast_ttl_v4: u32) -> io::Result<()> {
 496         setsockopt(&self.inner, c::IPPROTO_IP, c::IP_MULTICAST_TTL, multicast_ttl_v4 as c_int)
 497     }
 498
 499     pub fn multicast_ttl_v4(&self) -> io::Result<u32> {
 500         let raw: c_int = getsockopt(&self.inner, c::IPPROTO_IP, c::IP_MULTICAST_TTL)?;
 501         Ok(raw as u32)
 502     }
 503
 504     pub fn set_multicast_loop_v6(&self, multicast_loop_v6: bool) -> io::Result<()> {
 505         setsockopt(&self.inner, c::IPPROTO_IPV6, c::IPV6_MULTICAST_LOOP, multicast_loop_v6 as c_int)
 506     }
 507
 508     pub fn multicast_loop_v6(&self) -> io::Result<bool> {
 509         let raw: c_int = getsockopt(&self.inner, c::IPPROTO_IPV6, c::IPV6_MULTICAST_LOOP)?;
 510         Ok(raw != 0)
 511     }
 512
 513     pub fn join_multicast_v4(&self, multiaddr: &Ipv4Addr, interface: &Ipv4Addr)
 514                          -> io::Result<()> {
 515         let mreq = c::ip_mreq {
 516             imr_multiaddr: *multiaddr.as_inner(),
 517             imr_interface: *interface.as_inner(),
 518         };
 519         setsockopt(&self.inner, c::IPPROTO_IP, c::IP_ADD_MEMBERSHIP, mreq)
 520     }
 521
 522     pub fn join_multicast_v6(&self, multiaddr: &Ipv6Addr, interface: u32)
 523                          -> io::Result<()> {
 524         let mreq = c::ipv6_mreq {
 525             ipv6mr_multiaddr: *multiaddr.as_inner(),
 526             ipv6mr_interface: to_ipv6mr_interface(interface),
 527         };
 528         setsockopt(&self.inner, c::IPPROTO_IPV6, IPV6_ADD_MEMBERSHIP, mreq)
 529     }
 530
 531     pub fn leave_multicast_v4(&self, multiaddr: &Ipv4Addr, interface: &Ipv4Addr)
 532                           -> io::Result<()> {
 533         let mreq = c::ip_mreq {
 534             imr_multiaddr: *multiaddr.as_inner(),
 535             imr_interface: *interface.as_inner(),
 536         };
 537         setsockopt(&self.inner, c::IPPROTO_IP, c::IP_DROP_MEMBERSHIP, mreq)
 538     }
 539
 540     pub fn leave_multicast_v6(&self, multiaddr: &Ipv6Addr, interface: u32)
 541                           -> io::Result<()> {
 542         let mreq = c::ipv6_mreq {
 543             ipv6mr_multiaddr: *multiaddr.as_inner(),
 544             ipv6mr_interface: to_ipv6mr_interface(interface),
 545         };
 546         setsockopt(&self.inner, c::IPPROTO_IPV6, IPV6_DROP_MEMBERSHIP, mreq)
 547     }
 548
 549     pub fn set_ttl(&self, ttl: u32) -> io::Result<()> {
 550         setsockopt(&self.inner, c::IPPROTO_IP, c::IP_TTL, ttl as c_int)
 551     }
 552
 553     pub fn ttl(&self) -> io::Result<u32> {
 554         let raw: c_int = getsockopt(&self.inner, c::IPPROTO_IP, c::IP_TTL)?;
 555         Ok(raw as u32)
 556     }
 557
 558     pub fn take_error(&self) -> io::Result<Option<io::Error>> {
 559         self.inner.take_error()
 560     }
 561
 562     pub fn set_nonblocking(&self, nonblocking: bool) -> io::Result<()> {
 563         self.inner.set_nonblocking(nonblocking)
 564     }
 565
 566     pub fn recv(&self, buf: &mut [u8]) -> io::Result<usize> {
 567         self.inner.read(buf)
 568     }
 569
 570     pub fn send(&self, buf: &[u8]) -> io::Result<usize> {
 571         let len = cmp::min(buf.len(), <wrlen_t>::max_value() as usize) as wrlen_t;
 572         let ret = cvt(unsafe {
 573             c::send(*self.inner.as_inner(),
 574                     buf.as_ptr() as *const c_void,
 575                     len,
 576                     0)
 577         })?;
 578         Ok(ret as usize)
 579     }
 580
 581     pub fn connect(&self, addr: &SocketAddr) -> io::Result<()> {
 582         let (addrp, len) = addr.into_inner();
 583         cvt_r(|| unsafe { c::connect(*self.inner.as_inner(), addrp, len) }).map(|_| ())
 584     }
 585 }
 586
 587 impl FromInner<Socket> for UdpSocket {
 588     fn from_inner(socket: Socket) -> UdpSocket {
 589         UdpSocket { inner: socket }
 590     }
 591 }
 592
 593 impl fmt::Debug for UdpSocket {
 594     fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
 595         let mut res = f.debug_struct("UdpSocket");
 596
 597         if let Ok(addr) = self.socket_addr() {
 598             res.field("addr", &addr);
 599         }
 600
 601         let name = if cfg!(windows) {"socket"} else {"fd"};
 602         res.field(name, &self.inner.as_inner())
 603             .finish()
 604     }
 605 }
 606
 607 #[cfg(test)]
 608 mod tests {
 609     use super::*;
 610     use collections::HashMap;
 611
 612     #[test]
 613     fn no_lookup_host_duplicates() {
 614         let mut addrs = HashMap::new();
 615         let lh = match lookup_host("localhost") {
 616             Ok(lh) => lh,
 617             Err(e) => panic!("couldn't resolve `localhost': {}", e)
 618         };
 619         let _na = lh.map(|sa| *addrs.entry(sa).or_insert(0) += 1).count();
 620         assert!(addrs.values().filter(|&&v| v > 1).count() == 0);
 621     }
 622 }