Lines Matching refs:lock
75 SocketType::UdpSocket => self.udp_port_table.lock(), in get_ephemeral_port()
76 SocketType::TcpSocket => self.tcp_port_table.lock(), in get_ephemeral_port()
99 SocketType::UdpSocket => self.udp_port_table.lock(), in get_port()
100 SocketType::TcpSocket => self.tcp_port_table.lock(), in get_port()
115 SocketType::UdpSocket => self.udp_port_table.lock(), in unbind_port()
116 SocketType::TcpSocket => self.tcp_port_table.lock(), in unbind_port()
149 let mut socket_set_guard = SOCKET_SET.lock(); in drop()
264 GlobalSocketHandle::new(SOCKET_SET.lock().add(socket)); in new()
287 let mut socket_set_guard = SOCKET_SET.lock(); in read()
317 let mut socket_set_guard = SOCKET_SET.lock(); in write()
331 let mut socket_set_guard = SOCKET_SET.lock(); in write()
340 iface.inner_iface().lock().ipv4_addr(); in write()
441 GlobalSocketHandle::new(SOCKET_SET.lock().add(socket)); in new()
485 let mut socket_set_guard = SOCKET_SET.lock(); in read()
520 let mut socket_set_guard = SOCKET_SET.lock(); in write()
565 let mut sockets = SOCKET_SET.lock(); in bind()
572 let sockets = SOCKET_SET.lock(); in poll()
606 let sockets = SOCKET_SET.lock(); in endpoint()
663 GlobalSocketHandle::new(SOCKET_SET.lock().add(socket)); in new()
714 let mut socket_set_guard = SOCKET_SET.lock(); in read()
761 let mut socket_set_guard = SOCKET_SET.lock(); in write()
787 let mut socket_set_guard = SOCKET_SET.lock(); in poll()
810 let mut sockets = SOCKET_SET.lock(); in connect()
817 let mut inner_iface = iface.inner_iface().lock(); in connect()
829 let mut sockets = SOCKET_SET.lock(); in connect()
869 let mut sockets = SOCKET_SET.lock(); in listen()
897 let mut sockets = SOCKET_SET.lock(); in shutdown()
909 let mut sockets = SOCKET_SET.lock(); in accept()
966 let sockets = SOCKET_SET.lock(); in endpoint()
976 let sockets = SOCKET_SET.lock(); in peer_endpoint()
1132 return self.0.lock(); in inner()
1149 let socket = self.0.lock(); in close()
1163 return self.0.lock().read(&mut buf[0..len]).0; in read_at()
1173 return self.0.lock().write(&buf[0..len], None); in write_at()
1177 let (read, write, error) = self.0.lock().poll(); in poll()