Home
last modified time | relevance | path

Searched refs:push (Results 1 - 25 of 107) sorted by relevance

12345

/commonlibrary/rust/ylong_http/ylong_http_client/src/util/
H A Dbase64.rs20 output.push(BASE64_TABLE[((chunk[0] >> 2) & 0x3f) as usize]);
22 output.push(BASE64_TABLE[(((chunk[0] & 0x3) << 4) | ((chunk[1] >> 4) & 0xf)) as usize]);
23 output.push(BASE64_TABLE[(((chunk[1] & 0xf) << 2) | ((chunk[2] >> 6) & 0x3)) as usize]);
24 output.push(BASE64_TABLE[(chunk[2] & 0x3f) as usize]);
26 output.push(BASE64_TABLE[(((chunk[0] & 0x3) << 4) | ((chunk[1] >> 4) & 0xf)) as usize]);
27 output.push(BASE64_TABLE[((chunk[1] & 0xf) << 2) as usize]);
28 output.push(b'=');
30 output.push(BASE64_TABLE[((chunk[0] & 0x3) << 4) as usize]);
31 output.push(b'=');
32 output.push(
[all...]
/commonlibrary/rust/ylong_runtime/ylong_runtime/benches/
H A Dylong_tokio_rwlock.rs57 handlers.push(rt.spawn(tokio_rwlock_task(lock.clone()))); in tokio_rwlock_read()
82 handlers.push(ylong_runtime::spawn(ylong_rwlock_task(lock.clone()))); in ylong_rwlock_read()
106 handlers.push(rt.spawn(tokio_rwlock_write_task(lock.clone()))); in tokio_rwlock_write()
131 handlers.push(ylong_runtime::spawn(ylong_rwlock_write_task(lock.clone()))); in ylong_rwlock_write()
158 handlers.push(rt.spawn(tokio_rwlock_write_task(lock_in))); in tokio_rwlock_write_read()
163 handlers.push(rt.spawn(tokio_rwlock_task(lock_in))); in tokio_rwlock_write_read()
190 handlers.push(ylong_runtime::spawn(ylong_rwlock_write_task(lock_in))); in ylong_rwlock_write_read()
195 handlers.push(ylong_runtime::spawn(ylong_rwlock_task(lock_in))); in ylong_rwlock_write_read()
H A Dylong_tokio_bounded_mpsc.rs38 handlers.push(handle);
47 handlers.push(handle);
72 handlers.push(handle);
81 handlers.push(handle);
H A Dylong_tokio_task_creation.rs31 handlers.push(runtime.spawn(async move { 1 }));
47 handlers.push(ylong_runtime::spawn(async move { 1 }));
64 handlers.push(tokio::spawn(async move { 1 }));
83 handlers.push(ylong_runtime::spawn(async move { 1 }));
H A Dylong_tokio_unbounded_mpsc.rs38 handlers.push(handle);
47 handlers.push(handle);
72 handlers.push(handle);
81 handlers.push(handle);
H A Dylong_tokio_spawn_blocking.rs32 handlers.push(runtime.spawn_blocking(|| {
53 handlers.push(ylong_runtime::spawn_blocking(|| {
H A Dylong_tokio_tcp.rs63 handlers.push(runtime.spawn($server(addr.clone())));
64 handlers.push(runtime.spawn($client(addr.clone())));
117 handlers.push(ylong_runtime::spawn($server(addr)));
118 handlers.push(ylong_runtime::spawn($client(addr)));
H A Dylong_tokio_udp.rs98 handlers.push(ylong_runtime::spawn(async move { in ylong_udp_send_recv()
139 handlers.push(runtime.spawn(async move { in tokio_udp_send_recv()
185 handlers.push(ylong_runtime::spawn(async move { in ylong_udp_send_to_recv_from()
222 handlers.push(runtime.spawn(async move { in tokio_udp_send_to_recv_from()
H A Dylong_tokio_uds.rs62 handlers.push(runtime.spawn($server(addr.clone())));
63 handlers.push(runtime.spawn($client(addr.clone())));
116 handlers.push(ylong_runtime::spawn($server(addr.clone())));
117 handlers.push(ylong_runtime::spawn($client(addr.clone())));
H A Dylong_tokio_process.rs31 handlers.push(runtime.spawn(async {
56 handlers.push(ylong_runtime::spawn(async {
/commonlibrary/rust/ylong_runtime/ylong_runtime/tests/
H A Dspawn.rs36 handles.push(ylong_runtime::spawn(test_future(i))); in sdv_one_core_test()
53 handles.push(ylong_runtime::spawn(test_future(i))); in sdv_two_core_test()
70 handles.push(ylong_runtime::spawn(test_future(i))); in sdv_three_core_test()
87 handles.push(ylong_runtime::spawn(test_future(i))); in sdv_four_core_test()
104 handles.push(ylong_runtime::spawn(test_future(i))); in sdv_eight_core_test()
121 handles.push(ylong_runtime::spawn(test_future(i))); in sdv_max_core_test()
138 handles.push(ylong_runtime::spawn(test_multi_future_in_async(i, i + 1))); in sdv_multi_future_in_async()
156 handles.push(ylong_runtime::spawn(test_async_in_async(i, i + 1))); in sdv_multi_async_in_async()
H A Dsingleton_runtime.rs50 handles.push(ylong_runtime::spawn(test_async_in_async(i, i + 1))); in sdv_concurrently_runtime_spawn_async_in_async_task()
57 thread_handlers.push(thread_handler); in sdv_concurrently_runtime_spawn_async_in_async_task()
78 handles.push(ylong_runtime::spawn(test_async_in_async(i, i + 1))); in sdv_concurrently_spawn_async_in_async_task()
85 thread_handlers.push(thread_handler); in sdv_concurrently_spawn_async_in_async_task()
107 handles.push(task_builder.spawn(test_async_in_async(i, i + 1))); in sdv_concurrently_task_builder_spawn_async_in_async_task()
114 thread_handlers.push(thread_handler); in sdv_concurrently_task_builder_spawn_async_in_async_task()
H A Dspawn_blocking.rs29 handles.push(ylong_runtime::spawn_blocking(move || { in ffrt_spawn_blocking_test()
43 handles.push(task_builder.spawn_blocking(move || { in ffrt_spawn_blocking_test()
70 handles.push(runtime.spawn_blocking(move || { in test_spawn()
82 handles.push(ylong_runtime::spawn_blocking(move || { in test_spawn()
96 handles.push(task_builder.spawn_blocking(move || { in test_spawn()
/commonlibrary/rust/ylong_runtime/ylong_runtime/examples/
H A Dylong_tokio_schedule.rs37 handlers.push(ylong_runtime::spawn(async move { in ylong_schedule_task()
54 handlers.push(runtime.spawn(async move { in tokio_schedule_task()
67 handlers.push(ylong_runtime::spawn(async move { in ylong_schedule_fibbo_task()
85 handlers.push(runtime.spawn(async move { in tokio_schedule_fibbo_task()
H A Dylong_timer_latency.rs30 handlers.push(handle); in main()
52 handlers.push(handle); in main()
/commonlibrary/rust/ylong_http/ylong_http/src/request/uri/
H A Dpercent_encoding.rs74 self.normalized.push(char.to_ascii_lowercase()) in parse_scheme()
77 self.normalized.push(char); in parse_scheme()
94 self.normalized.push('/');
141 self.normalized.push(':')
147 self.normalized.push('@');
165 self.normalized.push(c); in parse_authority()
183 self.normalized.push(ch); in parse_path()
203 self.normalized.push('?'); in parse_query_and_fragment()
208 self.normalized.push('#'); in parse_query_and_fragment()
222 self.normalized.push('#'); in parse_query()
[all...]
/commonlibrary/rust/ylong_http/ylong_http/src/body/mime/
H A Dsimple.rs70 self.parts.push(part); in part()
140 states.push(MultiPartState::bytes(
143 states.push(MultiPartState::bytes(
148 states.push(MultiPartState::bytes(
154 states.push(MultiPartState::bytes(
159 states.push(MultiPartState::bytes(b"\r\n".to_vec()));
162 states.push(MultiPartState::bytes(
167 states.push(MultiPartState::bytes(b"\r\n".to_vec()));
170 states.push(body);
173 states.push(MultiPartStat
[all...]
/commonlibrary/rust/ylong_runtime/ylong_runtime/benches/bin/
H A Dylong_tokio_spawn.rs55 handles.push(handle); in ylong_spawn()
73 handles.push(handle); in tokio_spawn()
90 handles.push(handle); in std_spawn()
/commonlibrary/rust/ylong_http/ylong_http/src/h3/
H A Ddecoder.rs401 // TODO enable push in decode_push_id()
455 frames.push(FrameKind::Partial); in decode_frame_type()
499 frames.push(FrameKind::Partial); in decode_payload_len()
518 frames.push(FrameKind::Complete(Box::from(frame))); in decode_data_payload()
519 frames.push(FrameKind::Partial); in decode_data_payload()
526 frames.push(FrameKind::Complete(Box::from(frame))); in decode_data_payload()
570 frames.push(FrameKind::Complete(Box::from(frame))); in get_qpack_decoded_header()
594 frames.push(FrameKind::Blocked); in decode_headers_payload()
596 frames.push(FrameKind::Partial); in decode_headers_payload()
607 frames.push(FrameKin in decode_headers_payload()
[all...]
H A Dstream.rs20 /// HTTP3 push stream type code.
75 pub(crate) fn push(&mut self, frame: FrameKind) {
76 self.list.push(frame)
/commonlibrary/rust/ylong_http/ylong_http_client/tests/
H A Dsdv_sync_https_c_ssl.rs34 path.push("tests/file/root-ca.pem"); in sdv_synchronized_client_send_request()
60 path.push("tests/file/root-ca.pem"); in sdv_synchronized_client_send_request_repeatedly()
H A Dsdv_async_https_c_ssl.rs33 path.push("tests/file/root-ca.pem"); in sdv_async_client_send_request()
137 path.push("tests/file/root-ca.pem"); in sdv_client_send_request_repeatedly()
175 path.push("tests/file/root-ca.pem"); in sdv_client_making_multiple_connections()
/commonlibrary/c_utils/base/include/
H A Dsafe_block_queue.h38 * The interfaces can be used to perform blocking and non-blocking push and
51 * If the queue is full, the thread of the push operation will be blocked
53 * If the queue is not full, the push operation can be performed and one of the
67 queueT_.push(elem); in Push()
77 * element of the queue is returned, and one of the push threads (blocked
99 * If the queue is not full, the push operation can be performed, one of the
112 queueT_.push(elem); in PushNoWait()
122 * push threads (blocked when the queue is full) is woken up, and <b>true</b>
187 * If the queue is full, the thread of the push operation will be blocked
189 * If the queue is not full, the push operatio
[all...]
/commonlibrary/rust/ylong_http/ylong_http/src/body/
H A Dchunk.rs786 fn push<'a: 'b>(&mut self, chunk: Chunk<'a>) { in push() functions
787 self.chunks.push(chunk) in push()
1002 results.push(chunk); in match_decode_result()
1008 results.push(chunk); in match_decode_result()
1013 results.push(chunk); in match_decode_result()
1019 results.push(chunk); in match_decode_result()
1619 chunks.push(Chunk { in ut_chunk_body_decode_0()
1631 chunks.push(Chunk { in ut_chunk_body_decode_0()
1643 chunks.push(Chunk { in ut_chunk_body_decode_0()
1655 chunks.push(Chun in ut_chunk_body_decode_0()
[all...]
/commonlibrary/ets_utils/js_concurrent_module/worker/
H A Dmessage_queue.cpp23 queue_.push(data); in EnQueue()
64 queue_.push({id, data}); in Push()

Completed in 10 milliseconds

12345