Home
last modified time | relevance | path

Searched refs:take_error (Results 1 - 19 of 19) sorted by relevance

/commonlibrary/rust/ylong_runtime/ylong_runtime/src/net/sys/tcp/
H A Dlistener.rs184 /// let ret = server.take_error().unwrap();
188 pub fn take_error(&self) -> io::Result<Option<io::Error>> { in take_error() functions
189 self.source.take_error() in take_error()
264 /// 2. Call set_ttl(), ttl(), take_error().
274 assert!(server.take_error().unwrap().is_none()); in ut_tcp_listener_basic()
H A Dstream.rs112 if let Some(e) = stream.source.take_error()? { in fmt()
548 /// match stream.take_error() { in fmt()
551 /// Err(error) => println!("TcpStream.take_error failed: {error:?}"), in fmt()
556 pub fn take_error(&self) -> io::Result<Option<io::Error>> { in fmt() functions
557 self.source.take_error() in fmt()
680 /// nodelay(), take_error().
706 assert!(stream.take_error().unwrap().is_none()); in ut_tcp_stream_basic()
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/net/sys/unix/
H A Dstream.rs66 if let Some(e) = stream.source.take_error()? {
321 /// if let Ok(Some(err)) = socket.take_error() {
327 pub fn take_error(&self) -> Result<Option<Error>> { in take_error() functions
328 self.source.take_error() in take_error()
418 assert!(stream.take_error().is_ok()); in ut_uds_stream_baisc_test()
H A Dlistener.rs100 /// if let Ok(Some(err)) = listener.take_error() {
106 pub fn take_error(&self) -> Result<Option<Error>> { in take_error() functions
107 self.source.take_error() in take_error()
H A Ddatagram.rs405 /// if let Ok(Some(err)) = socket.take_error() {
411 pub fn take_error(&self) -> Result<Option<Error>> { in take_error() functions
412 self.source.take_error() in take_error()
477 assert!(datagram.take_error().is_ok()); in ut_uds_datagram_baisc_test()
/commonlibrary/rust/ylong_runtime/ylong_io/src/sys/windows/tcp/
H A Dlistener.rs137 /// let ret = server.take_error().unwrap();
139 pub fn take_error(&self) -> io::Result<Option<io::Error>> { in take_error() functions
140 self.inner.take_error() in take_error()
H A Dstream.rs235 /// stream.take_error().expect("No error was expected...");
237 pub fn take_error(&self) -> io::Result<Option<io::Error>> { in take_error() functions
238 self.inner.take_error() in take_error()
/commonlibrary/rust/ylong_runtime/ylong_io/src/sys/unix/udp/
H A Dudp_socket.rs324 /// match socket.take_error() {
327 /// Err(error) => println!("UdpSocket.take_error failed: {error:?}"),
330 pub fn take_error(&self) -> io::Result<Option<io::Error>> { in take_error() functions
331 self.inner.take_error() in take_error()
733 /// match connected_sender.take_error() {
736 /// Err(error) => println!("ConnectedUdpSocket.take_error failed: {error:?}"),
739 pub fn take_error(&self) -> io::Result<Option<io::Error>> { in take_error() functions
740 self.inner.take_error() in take_error()
/commonlibrary/rust/ylong_runtime/ylong_io/src/sys/windows/udp/
H A Dudp_socket.rs236 /// match socket.take_error() {
239 /// Err(error) => println!("UdpSocket.take_error failed: {error:?}"),
242 pub fn take_error(&self) -> io::Result<Option<io::Error>> { in take_error() functions
243 self.inner.take_error() in take_error()
613 /// match connected_sender.take_error() {
616 /// Err(error) => println!("ConnectedUdpSocket.take_error failed: {error:?}"),
619 pub fn take_error(&self) -> io::Result<Option<io::Error>> { in take_error() functions
620 self.inner.take_error() in take_error()
/commonlibrary/rust/ylong_runtime/ylong_io/src/sys/unix/tcp/
H A Dstream.rs190 pub fn take_error(&self) -> io::Result<Option<io::Error>> { in take_error() functions
191 self.inner.take_error() in take_error()
H A Dlistener.rs153 /// let ret = server.take_error().unwrap();
155 pub fn take_error(&self) -> io::Result<Option<io::Error>> { in take_error() functions
156 self.inner.take_error() in take_error()
/commonlibrary/rust/ylong_runtime/ylong_io/src/sys/unix/uds/
H A Ddatagram.rs233 /// if let Ok(Some(err)) = socket.take_error() {
239 pub fn take_error(&self) -> io::Result<Option<io::Error>> { in take_error() functions
240 self.inner.take_error() in take_error()
H A Dstream.rs133 /// if let Ok(Some(err)) = socket.take_error() {
139 pub fn take_error(&self) -> io::Result<Option<io::Error>> { in take_error() functions
140 self.inner.take_error() in take_error()
H A Dlistener.rs154 /// if let Ok(Some(err)) = listener.take_error() {
160 pub fn take_error(&self) -> io::Result<Option<io::Error>> { in take_error() functions
161 self.inner.take_error() in take_error()
/commonlibrary/rust/ylong_runtime/ylong_runtime/tests/
H A Duds_test.rs122 assert!(stream.take_error().is_ok()); in sdv_uds_stream_baisc_test()
144 assert!(datagram.take_error().is_ok()); in sdv_uds_datagram_baisc_test()
H A Duds_cargo_test.rs40 assert!(listener.take_error().is_ok()); in sdv_uds_listener_baisc_test()
H A Dtcp_test.rs57 /// 2. Call local_addr(), set_ttl(), ttl(), take_error().
67 assert!(server.take_error().unwrap().is_none()); in sdv_tcp_listener_interface()
112 /// nodelay(), take_error().
144 assert!(stream.take_error().unwrap().is_none()); in sdv_tcp_stream_basic()
H A Dudp_test.rs479 /// 2. Call set_ttl(), ttl(), take_error(), set_multicast_loop_v4(),
493 assert!(sender.take_error().unwrap().is_none()); in sdv_udp_basic_v4()
521 assert!(connected_sender.take_error().unwrap().is_none()); in sdv_udp_basic_v4()
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/net/sys/
H A Dudp.rs688 /// match socket.take_error() {
691 /// Err(error) => println!("UdpSocket.take_error failed: {error:?}"),
696 pub fn take_error(&self) -> io::Result<Option<io::Error>> { in take_error() functions
697 self.source.take_error() in take_error()
1334 /// match connected_sock.take_error() {
1337 /// Err(error) => println!("UdpSocket.take_error failed: {error:?}"),
1342 pub fn take_error(&self) -> io::Result<Option<io::Error>> { in take_error() functions
1343 self.source.take_error() in take_error()
1489 /// 2. Call set_ttl(), ttl(), take_error(), set_multicast_loop_v4(),
1502 assert!(sender.take_error() in ut_udp_basic_v4()
[all...]

Completed in 11 milliseconds