Searched refs:rsock (Results 1 – 8 of 8) sorted by relevance
| /external/rust/crates/nix/test/sys/ |
| D | test_sockopt.rs | 104 let rsock = socket( in test_so_tcp_maxseg() localVariable
111 bind(rsock, &sock_addr).unwrap(); in test_so_tcp_maxseg()
112 listen(rsock, 10).unwrap(); in test_so_tcp_maxseg()
113 let initial = getsockopt(rsock, sockopt::TcpMaxSeg).unwrap(); in test_so_tcp_maxseg()
121 setsockopt(rsock, sockopt::TcpMaxSeg, &segsize).unwrap(); in test_so_tcp_maxseg()
136 let rsess = accept(rsock).unwrap(); in test_so_tcp_maxseg()
150 close(rsock).unwrap(); in test_so_tcp_maxseg()
|
| D | test_socket.rs | 92 let rsock = socket( in test_timestamping() localVariable
99 nix::sys::socket::bind(rsock, &sock_addr).unwrap(); in test_timestamping()
101 setsockopt(rsock, Timestamping, &TimestampingFlag::all()).unwrap(); in test_timestamping()
111 let recv = recvmsg::<()>(rsock, &mut iov2, Some(&mut cmsg), flags).unwrap(); in test_timestamping()
323 rsock: RawFd, in sendrecv()
344 let (len, from_) = recvfrom(rsock, &mut buf[l..]).unwrap(); in sendrecv()
371 let rsock = socket( in udp() localVariable
378 bind(rsock, &sock_addr).unwrap(); in udp()
387 rsock, in udp()
415 let rsock = socket( in gso() localVariable
[all …]
|
| /external/python/cpython3/Lib/test/test_asyncio/ |
| D | test_unix_events.py | 1800 lambda: asyncio.Protocol(), sock=rsock)
1806 self.loop.add_reader(rsock, cb)
1808 self.loop.add_reader(rsock.fileno(), cb)
1811 self.loop.remove_reader(rsock)
1813 self.loop.remove_reader(rsock.fileno())
1816 self.loop.add_writer(rsock, cb)
1818 self.loop.add_writer(rsock.fileno(), cb)
1821 self.loop.remove_writer(rsock)
1823 self.loop.remove_writer(rsock.fileno())
1828 rsock, wsock = socket.socketpair()
[all …]
|
| D | test_events.py | 1474 rsock, wsock = socket.socketpair()
1475 rsock.setblocking(False)
1486 data = self.loop.run_until_complete(self.loop.sock_recv(rsock, 1024))
1489 rsock.close()
|
| /external/python/cpython3/Doc/library/ |
| D | asyncio-stream.rst | 458 rsock, wsock = socket.socketpair()
461 reader, writer = await asyncio.open_connection(sock=rsock)
|
| D | asyncio-eventloop.rst | 1644 rsock, wsock = socketpair()
1649 data = rsock.recv(100)
1653 loop.remove_reader(rsock)
1659 loop.add_reader(rsock, reader)
1669 rsock.close()
|
| D | asyncio-protocol.rst | 961 rsock, wsock = socket.socketpair()
965 lambda: MyProtocol(on_con_lost), sock=rsock)
|
| /external/rust/crates/nix/src/sys/socket/ |
| D | mod.rs | 1841 let rsock = socket( localVariable
1848 crate::sys::socket::bind(rsock, &sock_addr)?;
1850 setsockopt(rsock, Timestamping, &TimestampingFlag::all())?;
1878 let recv = super::recvmmsg(rsock, &mut data, recv_iovs.iter(), flags, Some(t))?;
|