Lines Matching refs:socket

16     net::socket::{AddressFamily, SOL_SOCKET},
22 socket::{new_socket, PosixSocketType, Socket, SocketInode},
36 pub fn socket( in socket() method
45 let socket = new_socket(address_family, socket_type, protocol)?; in socket() localVariable
47 let socketinode: Arc<SocketInode> = SocketInode::new(socket); in socket()
115 let socket: SpinLockGuard<Box<dyn Socket>> = socket_inode.inner(); in setsockopt() localVariable
116 return socket.setsockopt(level, optname, optval).map(|_| 0); in setsockopt()
140 let socket = binding.inner(); in getsockopt() localVariable
149 *optval = socket.metadata().tx_buf_size as u32; in getsockopt()
157 *optval = socket.metadata().rx_buf_size as u32; in getsockopt()
167 drop(socket); in getsockopt()
199 let socket: Arc<SocketInode> = ProcessManager::current_pcb() in connect() localVariable
202 let mut socket = unsafe { socket.inner_no_preempt() }; in connect() localVariable
203 socket.connect(endpoint)?; in connect()
216 let socket: Arc<SocketInode> = ProcessManager::current_pcb() in bind() localVariable
219 let mut socket = unsafe { socket.inner_no_preempt() }; in bind() localVariable
220 socket.bind(endpoint)?; in bind()
246 let socket: Arc<SocketInode> = ProcessManager::current_pcb() in sendto() localVariable
249 let socket = unsafe { socket.inner_no_preempt() }; in sendto() localVariable
250 return socket.write(buf, endpoint); in sendto()
269 let socket: Arc<SocketInode> = ProcessManager::current_pcb() in recvfrom() localVariable
272 let socket = unsafe { socket.inner_no_preempt() }; in recvfrom() localVariable
274 let (n, endpoint) = socket.read(buf); in recvfrom()
275 drop(socket); in recvfrom()
300 let socket: Arc<SocketInode> = ProcessManager::current_pcb() in recvmsg() localVariable
303 let socket = unsafe { socket.inner_no_preempt() }; in recvmsg() localVariable
307 let (n, endpoint) = socket.read(&mut buf); in recvmsg()
308 drop(socket); in recvmsg()
329 let socket: Arc<SocketInode> = ProcessManager::current_pcb() in listen() localVariable
332 let mut socket = unsafe { socket.inner_no_preempt() }; in listen() localVariable
333 socket.listen(backlog)?; in listen()
344 let socket: Arc<SocketInode> = ProcessManager::current_pcb() in shutdown() localVariable
347 let mut socket = unsafe { socket.inner_no_preempt() }; in shutdown() localVariable
348 socket.shutdown(ShutdownType::from_bits_truncate((how + 1) as u8))?; in shutdown()
404 let socket: Arc<SocketInode> = ProcessManager::current_pcb() in do_accept() localVariable
408 let mut socket = unsafe { socket.inner_no_preempt() }; in do_accept() localVariable
410 let (new_socket, remote_endpoint) = socket.accept()?; in do_accept()
411 drop(socket); in do_accept()
459 let socket: Arc<SocketInode> = ProcessManager::current_pcb() in getsockname() localVariable
462 let socket = socket.inner(); in getsockname() localVariable
463 let endpoint: Endpoint = socket.endpoint().ok_or(SystemError::EINVAL)?; in getsockname()
464 drop(socket); in getsockname()
489 let socket: Arc<SocketInode> = ProcessManager::current_pcb() in getpeername() localVariable
492 let socket = socket.inner(); in getpeername() localVariable
493 let endpoint: Endpoint = socket.peer_endpoint().ok_or(SystemError::EINVAL)?; in getpeername()
494 drop(socket); in getpeername()