Home
last modified time | relevance | path

Searched refs:expect (Results 1 - 25 of 59) sorted by relevance

123

/commonlibrary/c_utils/base/test/unittest/rust/
H A Drust_utils_ashmem_test.rs26 let c_name = CString::new(MEMORY_NAME).expect("CString::new Failed!"); in test_ashmem_ffi_write_read_001()
40 let c_name = CString::new(MEMORY_NAME).expect("CString::new Failed!"); in test_ashmem_ffi_write_read_002()
46 let c_content = CString::new(MEMORY_CONTENT).expect("CString::new Failed!"); in test_ashmem_ffi_write_read_002()
50 assert!(ashmem.WriteToAshmem(c_content_ptr, MEMORY_CONTENT.len().try_into().expect("Invalid content size."), 0)); in test_ashmem_ffi_write_read_002()
51 assert!(ashmem.WriteToAshmem(c_content_ptr, MEMORY_CONTENT.len().try_into().expect("Invalid content size."), in test_ashmem_ffi_write_read_002()
52 MEMORY_CONTENT.len().try_into().expect("Invalid content size."))); in test_ashmem_ffi_write_read_002()
56 readout_ptr = ashmem::ffi::AsCharPtr(ashmem.ReadFromAshmem(MEMORY_CONTENT.len().try_into().expect("Invalid content size."), 0)); in test_ashmem_ffi_write_read_002()
62 let readout_str: &str = readout_c_str.to_str().expect("Bad encoding."); in test_ashmem_ffi_write_read_002()
64 let mut expect = String::from(MEMORY_CONTENT); in test_ashmem_ffi_write_read_002() variables
65 expect in test_ashmem_ffi_write_read_002()
335 let mut expect = String::from(MEMORY_CONTENT); test_ashmem_write_read_002() variables
[all...]
/commonlibrary/rust/ylong_http/ylong_http_client/tests/
H A Dsdv_async_http2.rs83 .expect("build hyper response failed");
103 std::net::TcpListener::bind("127.0.0.1:0").expect("server bind port failed !");
106 .expect("get server local address failed!");
110 .expect("build hyper server from tcp listener failed !");
121 .expect("Start channel (Client-Half) be closed unexpectedly");
125 .expect("Client channel (Client-Half) be closed unexpectedly");
128 .expect("Start server failed");
132 .expect("Server channel (Client-Half) be closed unexpectedly");
150 .expect("init runtime failed !"); in sdv_async_h2_client_send_request()
160 .expect("rec in sdv_async_h2_client_send_request()
[all...]
H A Dsdv_async_http_proxy.rs58 let handle = handles_vec.pop().expect("No more handles !"); in sdv_async_client_send_request()
65 .expect("Http proxy build failed"), in sdv_async_client_send_request()
68 .expect("Client build failed!"); in sdv_async_client_send_request()
82 let mut response = client.request(request).await.expect("Request send failed"); in sdv_async_client_send_request()
118 .expect("Response body read failed"); in sdv_async_client_send_request()
133 .expect("server send order failed !"); in sdv_async_client_send_request()
135 ylong_runtime::block_on(shutdown_handle).expect("Runtime wait for server shutdown failed"); in sdv_async_client_send_request()
H A Dsdv_async_https_pinning.rs72 let handle = handles_vec.pop().expect("No more handles !"); in sdv_client_public_key_pinning()
109 .expect("Runtime block on server shutdown failed"); in sdv_client_public_key_pinning()
120 let handle = handles_vec.pop().expect("No more handles !"); in sdv_client_public_key_pinning()
158 .expect("Runtime block on server shutdown failed"); in sdv_client_public_key_pinning()
169 let handle = handles_vec.pop().expect("No more handles !"); in sdv_client_public_key_pinning()
207 .expect("Runtime block on server shutdown failed"); in sdv_client_public_key_pinning()
250 let handle = handles_vec.pop().expect("No more handles !"); in sdv_client_public_key_pinning_error()
277 .expect("Request build failed"); in sdv_client_public_key_pinning_error()
282 format!("{:?}", response.expect("response is not an error")), in sdv_client_public_key_pinning_error()
290 .expect("Runtim
[all...]
H A Dsdv_async_custom_dns_resolver.rs58 let handle = handles_vec.pop().expect("No more handles !"); in sdv_client_custom_dns_resolver()
85 .expect("server send order failed !"); in sdv_client_custom_dns_resolver()
87 ylong_runtime::block_on(shutdown_handle).expect("Runtime wait for server shutdown failed"); in sdv_client_custom_dns_resolver()
/commonlibrary/rust/ylong_runtime/ylong_runtime/tests/
H A Dudp_test.rs32 let sender = UdpSocket::bind(ADDR).await.expect("Bind Socket Failed"); in sdv_udp_send_recv()
33 let receiver = UdpSocket::bind(ADDR).await.expect("Bind Socket Failed"); in sdv_udp_send_recv()
40 .expect("Connect Socket Failed"); in sdv_udp_send_recv()
44 .expect("Connect Socket Failed"); in sdv_udp_send_recv()
49 .expect("Sender Send Failed"); in sdv_udp_send_recv()
57 ylong_runtime::block_on(handle).expect("block_on failed"); in sdv_udp_send_recv()
70 let sender = UdpSocket::bind(ADDR).await.expect("Bind Socket Failed"); in sdv_udp_send_to_recv_from()
71 let receiver = UdpSocket::bind(ADDR).await.expect("Bind Socket Failed"); in sdv_udp_send_to_recv_from()
78 .expect("Sender Send Failed"); in sdv_udp_send_to_recv_from()
86 ylong_runtime::block_on(handle).expect("block_o in sdv_udp_send_to_recv_from()
[all...]
H A Dselect.rs56 ylong_runtime::block_on(handle).expect("select! fail"); in sdv_new_select_basic()
95 ylong_runtime::block_on(handle).expect("select! fail"); in sdv_new_select_channel()
135 ylong_runtime::block_on(handle).expect("select! fail"); in sdv_new_select_biased()
178 ylong_runtime::block_on(handle).expect("select! fail"); in sdv_new_select_match()
207 ylong_runtime::block_on(handle).expect("select! fail"); in sdv_new_select_precondition()
228 ylong_runtime::block_on(handle).expect("select! fail"); in sdv_new_select_panic()
H A Dtcp_test.rs175 let len = stream.peek(&mut buf).await.expect("peek failed!"); in sdv_tcp_stream_peek()
192 let listener = TcpListener::bind(ADDR).await.expect("Bind Listener Failed"); in sdv_tcp_global_runtime()
206 .expect("client send failed"); in sdv_tcp_global_runtime()
213 .expect("client recv failed"); in sdv_tcp_global_runtime()
221 let (mut socket, _) = listener.accept().await.expect("Bind accept Failed"); in sdv_tcp_global_runtime()
224 match socket.read(&mut buf).await.expect("recv Failed") { in sdv_tcp_global_runtime()
238 .expect("failed to write to socket"); in sdv_tcp_global_runtime()
242 ylong_runtime::block_on(handle).expect("block_on failed"); in sdv_tcp_global_runtime()
308 let n = read_half.read(&mut buf).await.expect("server read err"); in sdv_tcp_split_borrow_half()
316 let n = read_half.read(&mut buf).await.expect("serve in sdv_tcp_split_borrow_half()
[all...]
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/net/sys/
H A Dudp.rs402 /// sock.peek_from(&mut buf).await.expect("Didn't receive data");
429 /// sock.try_peek_from(&mut buf).expect("Didn't receive data");
645 /// socket.set_ttl(100).expect("set_ttl call failed");
665 /// socket.set_ttl(100).expect("set_ttl call failed");
687 /// .expect("couldn't bind to address");
896 /// connect_socket.set_ttl(100).expect("set_ttl call failed");
918 /// connect_socket.set_ttl(100).expect("set_ttl call failed");
1202 /// .expect("connect function failed");
1235 /// .expect("connect function failed");
1326 /// .expect("could
[all...]
/commonlibrary/rust/ylong_http/ylong_http_client/tests/common/
H A Dmod.rs67 .expect("Failed to send the handle to the test thread.");
71 .expect("Runtime start server coroutine failed");
74 .expect("Handle send channel (Server-Half) be closed unexpectedly");
96 .expect("Start channel (Server-Half) be closed unexpectedly");
98 .expect("Failed to send the handle to the test thread.");
102 .expect("Runtime start server coroutine failed");
105 .expect("Handle send channel (Server-Half) be closed unexpectedly");
125 let tcp_listener = std::net::TcpListener::bind("127.0.0.1:0").expect("server bind port failed !");
126 let addr = tcp_listener.local_addr().expect("get server local address failed!");
128 let server = hyper::Server::from_tcp(tcp_listener).expect("buil
[all...]
H A Dasync_utils.rs103 runtime.block_on(shutdown_handle).expect("Runtime wait for server shutdown failed");
191 runtime.block_on(shutdown_handle).expect("Runtime wait for server shutdown failed");
230 let handle = $handle_vec.pop().expect("No more handles !");
284 let mut handle = $handle_vec.pop().expect("No more handles !");
342 .expect("Request build failed");
347 .expect("Request send failed");
355 .expect(format!("Get response header \"{}\" failed", $resp_n).as_str())
357 .expect(format!("Convert response header \"{}\"into string failed", $resp_n).as_str()),
366 .expect("Response body read failed");
H A Dsync_utils.rs102 runtime.block_on(shutdown_handle).expect("Runtime wait for server shutdown failed");
189 runtime.block_on(shutdown_handle).expect("Runtime wait for server shutdown failed");
228 let handle = $handle_vec.pop().expect("No more handles !");
282 let mut handle = $handle_vec.pop().expect("No more handles !");
349 .expect("Request send failed");
356 .expect(format!("Get response header \"{}\" failed", $resp_n).as_str())
358 .expect(format!("Convert response header \"{}\"into string failed", $resp_n).as_str()),
368 .expect("Response body read failed");
/commonlibrary/rust/ylong_http/ylong_http_client/src/util/
H A Dtest_utils.rs51 .expect("Request build failed")
82 let server = TcpListener::bind("127.0.0.1:0").await.expect("server is failed to bind a address !");
83 let addr = server.local_addr().expect("failed to get server address !");
88 tx2.send(handle).expect("send TcpHandle out coroutine failed !");
90 let (mut stream, _client) = server.accept().await.expect("failed to build a tcp stream");
93 let _size = stream.read(&mut buf).await.expect("tcp stream read error !");
98 let tmp_size = stream.read(&mut buf[total..]).await.expect("tcp stream read error !");
113 stream.write_all(resp_str.as_bytes()).await.expect("server write response failed");
117 stream.shutdown($shutdown).expect("server shutdown failed");
120 tx.send(()).expect("serve
[all...]
H A Dnormalizer.rs321 let uri = Uri::from_bytes(b"https://www.example.com:80").expect("Uri parse failed"); in ut_format_host_value()
323 let uri = Uri::from_bytes(b"https://www.example.com:443").expect("Uri parse failed"); in ut_format_host_value()
325 let uri = Uri::from_bytes(b"http://www.example.com:80").expect("Uri parse failed"); in ut_format_host_value()
327 let uri = Uri::from_bytes(b"http://www.example.com:443").expect("Uri parse failed"); in ut_format_host_value()
329 let uri = Uri::from_bytes(b"www.example.com:443").expect("Uri parse failed"); in ut_format_host_value()
331 let uri = Uri::from_bytes(b"www.example.com:80").expect("Uri parse failed"); in ut_format_host_value()
333 let uri = Uri::from_bytes(b"www.example.com").expect("Uri parse failed"); in ut_format_host_value()
/commonlibrary/rust/ylong_http/ylong_http_client/tests/tcp_server/
H A Dmod.rs76 let server = TcpListener::bind("127.0.0.1:0").await.expect("server is failed to bind a address !");
77 let addr = server.local_addr().expect("failed to get server address !");
82 rx2.send(handle).expect("send TcpHandle out coroutine failed !");
84 let (mut stream, _client) = server.accept().await.expect("failed to build a tcp stream");
90 let size = stream.read(&mut buf).await.expect("tcp stream read error !");
117 let size2 = stream.read(&mut buf).await.expect("tcp stream read error2 !");
133 stream.write_all(resp_str.as_bytes()).await.expect("server write response failed");
139 stream.shutdown($shutdown).expect("server shutdown failed");
141 rx.send(()).expect("server send order failed !");
145 let handle = tx2.recv().expect("rec
[all...]
H A Dasync_utils.rs96 ylong_runtime::block_on(shutdown_handle).expect("Runtime wait for server shutdown failed");
130 let handle = $handle_vec.pop().expect("No more handles !");
154 handle.server_shutdown.recv().expect("server send order failed !");
202 .expect("Request send failed");
210 .expect(format!("Get response header \"{}\" failed", $resp_n).as_str())
212 .expect(format!("Convert response header \"{}\"into string failed", $resp_n).as_str()),
221 .expect("Response body read failed");
H A Dsync_utils.rs91 shutdown_handle.join().expect("join to wait client thread finish failed !");
124 let handle = $handle_vec.pop().expect("No more handles !");
147 handle.server_shutdown.recv().expect("server send order failed !");
191 .expect("Request send failed");
199 .expect(format!("Get response header \"{}\" failed", $resp_n).as_str())
201 .expect(format!("Convert response header \"{}\"into string failed", $resp_n).as_str()),
211 .expect("Response body read failed");
/commonlibrary/rust/ylong_http/ylong_http/src/body/
H A Dtext.rs501 let size = body.data(&mut buf).expect("First read failed."); in ut_text_body_from_bytes_syn_data()
505 let size = body.data(&mut buf).expect("Second read failed."); in ut_text_body_from_bytes_syn_data()
509 let size = body.data(&mut buf).expect("Third read failed."); in ut_text_body_from_bytes_syn_data()
537 let size = body.data(&mut buf).await.expect("First read failed.");
541 let size = body.data(&mut buf).await.expect("Second read failed.");
545 let size = body.data(&mut buf).await.expect("Third read failed.");
563 let size = body.data(&mut buf).expect("First read failed."); in ut_text_body_from_reader_syn_data()
567 let size = body.data(&mut buf).expect("Second read failed."); in ut_text_body_from_reader_syn_data()
571 let size = body.data(&mut buf).expect("Third read failed."); in ut_text_body_from_reader_syn_data()
600 let size = body.data(&mut buf).await.expect("Firs
[all...]
/commonlibrary/rust/ylong_http/ylong_http/src/response/
H A Dmod.rs165 headers.insert("age", "270646").expect(ERROR_HEADER); in ut_response_headers()
168 .expect(ERROR_HEADER); in ut_response_headers()
171 .expect(ERROR_HEADER); in ut_response_headers()
246 headers.insert("age", "270646").expect(ERROR_HEADER); in ut_response_from_raw_parts()
249 .expect(ERROR_HEADER); in ut_response_from_raw_parts()
252 .expect(ERROR_HEADER); in ut_response_from_raw_parts()
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/net/sys/tcp/
H A Dsplit.rs148 let n = read_half.read(&mut buf).await.expect("server read err"); in poll_flush()
158 let n = stream.read(&mut buf).await.expect("server read err"); in poll_flush()
195 let n = read_half.read(&mut buf).await.expect("server read err"); in poll_flush()
205 let n = stream.read(&mut buf).await.expect("server read err"); in poll_flush()
247 let n = read_half.read(&mut buf).await.expect("server read err"); in poll_flush()
254 let n = stream.read(&mut buf).await.expect("server read err"); in poll_flush()
297 let n = read_half.read(&mut buf).await.expect("server read err"); in poll_flush()
304 let n = stream.read(&mut buf).await.expect("server read err"); in poll_flush()
/commonlibrary/rust/ylong_http/ylong_http/src/h2/
H A Ddecoder.rs924 pseudo.method().expect("pseudo.method get failed !"),
930 pseudo.scheme().expect("pseudo.scheme get failed !"),
938 .expect("pseudo.authority get failed !"),
944 pseudo.path().expect("pseudo.path get failed !"),
950 pseudo.status().expect("pseudo.status get failed !"),
1027 let frame_bytes = decode($frame_hex).expect("convert frame hex to bytes failed !");
1028 let decoded_frames = decoder.decode(frame_bytes.as_slice()).expect("decode frame bytes failed !");
1034 FrameKind: frames_iter.next().expect("take next frame from iterator failed !"),
1058 let frame_bytes = decode($frame_hex).expect("convert frame hex to bytes failed !");
1059 let decoded_frames = decoder.decode(frame_bytes.as_slice()).expect("decod
[all...]
/commonlibrary/rust/ylong_http/ylong_http_client/src/util/c_openssl/
H A Dadapter.rs467 .expect("TlsConfig build error!") in default()
747 .expect("Sets certs error."); in ut_add_root_certificates()
828 .expect("TlsConfig build error."); in ut_tls_ssl()
831 .expect("Ssl build error.") in ut_tls_ssl()
855 .expect("TlsConfig build error."); in ut_tls_ssl_verify_hostname()
860 .expect("Ssl build error.") in ut_tls_ssl_verify_hostname()
862 let stream = TcpStream::connect("huawei.com:443").expect("Tcp stream error."); in ut_tls_ssl_verify_hostname()
863 let mut tls_stream = ssl.connect(stream).expect("Tls stream error."); in ut_tls_ssl_verify_hostname()
867 .expect("Stream write error."); in ut_tls_ssl_verify_hostname()
871 .expect("Strea in ut_tls_ssl_verify_hostname()
[all...]
/commonlibrary/rust/ylong_http/ylong_http/src/body/mime/
H A Dmime_test_macro.rs34 .expect("MimePart build failed")
76 let size = sync_impl::Body::data(&mut part_encoder, &mut buf).expect("MimePart encode failed");
123 let size = async_impl::Body::data(&mut part_encoder, &mut buf).await.expect("MimePart encode failed");
/commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/dns/
H A Dresolver.rs126 .expect("dns resolver resolve domain occurs err"); in ut_resolver_std_dns_resolver_resolve()
150 .expect("Build runtime failed."); in ut_resolver_std_dns_resolver_resolve()
156 .expect("dns resolver resolve domain occurs err"); in ut_resolver_std_dns_resolver_resolve()
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/time/
H A Ddriver.rs82 .expect("waker taken from the clock is none")
93 .expect("driver's start time is later than the current time")
124 .expect("waker taken from the clock is none")

Completed in 15 milliseconds

123