Home
last modified time | relevance | path

Searched refs:get (Results 1 - 25 of 86) sorted by relevance

1234

/commonlibrary/rust/ylong_runtime/ylong_runtime/src/task/
H A Djoin_set.rs29 /// A collection of tasks get spawned on a Ylong runtime
103 unsafe { (*(self.handle.get())).raw.eq(&(*(other.handle.get())).raw) } in eq()
111 unsafe { (*self.handle.get()).raw.hash(state) } in hash()
116 // When waking a JoinEntry, the entry will get popped out of the wait list and
185 (*entry.handle.get()).set_waker(&waker); in spawn_inner()
245 unsafe { (*item.handle.get()).cancel() } in cancel_all()
248 unsafe { (*item.handle.get()).cancel() } in cancel_all()
309 // by a ManuallyDrop. It will only get dropped when the task returns
313 match Pin::new(&mut **(entry.handle.get()))
[all...]
H A Dtask_handle.rs118 let waker = self.inner().waker.get(); in set_waker_inner()
124 let waker = self.inner().waker.get(); in set_waker_inner()
135 let waker = self.inner().waker.get();
305 let ffrt_task = unsafe { (*self.inner().task.get()).as_ref().unwrap() };
334 let ffrt_task = unsafe { (*self.inner().task.get()).as_ref().unwrap() };
348 let ffrt_task = unsafe { (*self.inner().task.get()).as_ref().unwrap() };
H A Draw.rs211 if (*self.task.get()).is_none() {
212 (*self.task.get()).replace(FfrtTaskCtx::get_current());
218 let stage = self.stage.get(); in turning_to_executed()
225 let stage = self.stage.get();
232 let stage = self.stage.get(); in turning_to_store_data()
239 let stage = self.stage.get();
248 let stage = self.stage.get();
269 let waker = self.waker.get();
/commonlibrary/rust/ylong_runtime/ylong_io/src/
H A Dinterest.rs33 Interest(unsafe { NonZeroU8::new_unchecked(self.0.get() | other.0.get()) })
38 (self.0.get() & READABLE) != 0
43 (self.0.get() & WRITABLE) != 0
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/builder/
H A Dmulti_thread_builder.rs326 let num = builder.thread_num_by_qos.get(&UserInteractive).unwrap(); in ut_set_max_worker()
330 let num = builder.thread_num_by_qos.get(&UserInteractive).unwrap(); in ut_set_max_worker()
334 let num = builder.thread_num_by_qos.get(&Default).unwrap(); in ut_set_max_worker()
356 .get(&UserInitiated) in ut_set_stack_size()
365 .get(&UserInteractive) in ut_set_stack_size()
371 let num = builder.common.stack_size_by_qos.get(&Default).unwrap(); in ut_set_stack_size()
379 .get(&UserInteractive) in ut_set_stack_size()
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/util/
H A Dslab.rs180 /// 2. Before allocating each page of the container, we will try to get lock
212 /// Used to get the reference stored at the given address
213 pub fn get(&mut self, addr: Address) -> Option<&T> { in get() functions
347 (*slot.value.get()).value.reset(); in allocate()
546 /// UT test cases for Slab::get()
549 /// 1. Allocate container space and deposit data, get the data address,and
558 assert!(slab.get(addr).is_some()); in ut_slab_get()
561 assert!(slab.get(un_addr).is_none()); in ut_slab_get()
584 assert_eq!(slab.get(address[32].0).unwrap().id.load(SeqCst), 32); in ut_slab_compact()
623 slab.get(addr in ut_slab_insert_move()
[all...]
/commonlibrary/c_utils/base/test/benchmarktest/event_benchmark_test/
H A Devent_benchmark_test.cpp186 handler->Start(reactor.get()); in BENCHMARK_F()
187 AssertEqual(reactor->FindHandler(handler.get()), EVENT_SYS_ERR_OK, in BENCHMARK_F()
188 "reactor->FindHandler(handler.get()) did not equal EVENT_SYS_ERR_OK as expected.", state); in BENCHMARK_F()
192 AssertTrue((handler->Update(reactor.get())), in BENCHMARK_F()
193 "handler->Update(reactor.get()) did not equal true as expected.", state); in BENCHMARK_F()
196 handler->Stop(reactor.get()); in BENCHMARK_F()
197 AssertEqual(reactor->FindHandler(handler.get()), EVENT_SYS_ERR_NOT_FOUND, in BENCHMARK_F()
198 "reactor->FindHandler(handler.get()) did not equal EVENT_SYS_ERR_NOT_FOUND as expected.", state); in BENCHMARK_F()
201 AssertTrue((handler->Start(reactor.get())), in BENCHMARK_F()
202 "handler->Start(reactor.get()) di in BENCHMARK_F()
[all...]
/commonlibrary/c_utils/base/test/unittest/common/
H A Dutils_singleton_test.cpp122 EXPECT_EQ(sp1.get(), sp2.get()); in HWTEST_F()
158 EXPECT_EQ(sp1.get(), sp2.get()); in HWTEST_F()
H A Dutils_event_test.cpp149 handler->Start(reactor.get()); in HWTEST_F()
150 EXPECT_EQ(reactor->FindHandler(handler.get()), EVENT_SYS_ERR_OK); in HWTEST_F()
154 EXPECT_TRUE(handler->Update(reactor.get())); in HWTEST_F()
157 handler->Stop(reactor.get()); in HWTEST_F()
158 EXPECT_EQ(reactor->FindHandler(handler.get()), EVENT_SYS_ERR_NOT_FOUND); in HWTEST_F()
161 ASSERT_TRUE(handler->Start(reactor.get())); in HWTEST_F()
187 EXPECT_EQ(reactor->AddHandler(handler1.get()), EVENT_SYS_ERR_OK); in HWTEST_F()
188 EXPECT_EQ(reactor->AddHandler(handler2.get()), EVENT_SYS_ERR_OK); in HWTEST_F()
189 EXPECT_NE(reactor->AddHandler(handler3.get()), EVENT_SYS_ERR_OK); in HWTEST_F()
193 EXPECT_NE(handler1->Start(reactor.get()), EVENT_SYS_ERR_O in HWTEST_F()
[all...]
/commonlibrary/rust/ylong_http/ylong_http_client/src/util/
H A Dpool.rs36 pub(crate) fn get<F>(&self, key: K, create_fn: F) -> V
42 Entry::Occupied(conns) => conns.get().clone(),
63 /// UT test cases for `Pool::get`.
67 /// 2. Uses `pool::get` to get connection.
79 let res = pool.get(key, consume_and_return_data); in ut_pool_get()
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/signal/unix/
H A Dregistry.rs113 .get(event_id)
121 .get(event_id)
128 if let Some(event) = self.events.get(event_id) {
/commonlibrary/rust/ylong_http/ylong_http_client/src/util/c_openssl/
H A Dmod.rs52 Err(ErrorStack::get())
61 Err(ErrorStack::get())
/commonlibrary/c_utils/base/test/benchmarktest/singleton_benchmark_test/
H A Dsingleton_benchmark_test.cpp133 AssertEqual(sp1.get(), sp2.get(), "sp1.get() did not equal sp2.get() as expected.", state); in BENCHMARK_F()
175 AssertEqual(sp1.get(), sp2.get(), "sp1.get() did not equal sp2.get() as expected.", state); in BENCHMARK_F()
/commonlibrary/rust/ylong_http/ylong_http_client/src/util/c_openssl/ssl/
H A Dctx.rs186 Err(_) => return Err(ErrorStack::get()),
236 None => return Err(ErrorStack::get()),
240 Err(_) => Err(ErrorStack::get()),
253 _ => Err(ErrorStack::get()),
307 Err(_) => return Err(ErrorStack::get()),
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/executor/
H A Dqueue.rs232 let task = self.buffer[(pos & MASK) as usize].get();
278 let ptr = self.buffer[idx].get();
302 // get the number of tasks the worker has stolen
321 let task_ptr = self.buffer[src_idx].get();
324 ptr::write((*dst_ptr.get()).as_mut_ptr(), task);
351 // get the number of tasks the worker has stolen
389 let task_ptr = self.buffer[src_idx].get();
392 let ptr = dst.inner.buffer[des_idx].get();
403 let task_ptr = self.buffer[src_idx].get();
461 let task = unsafe { ptr::read(task_ptr.get())
[all...]
H A Dworker.rs68 let val = ctx.get();
81 let val = ctx.get();
106 let prev_ctx = cur.get();
110 let prev_handle = handle.get();
208 /// We can't get Inner with `RefCell::borrow()`, because the worker will
209 /// always hold the borrow_mut until drop. So we can only get Inner by ptr.
/commonlibrary/rust/ylong_json/src/value/object/
H A Dbtree.rs169 /// assert_eq!(object.get("test"), Some(&JsonValue::Number(Number::from(123)))); in iter()
170 /// assert_eq!(object.get("no_such_key"), None); in iter()
172 pub fn get(&self, key: &str) -> Option<&JsonValue> { in iter() functions
173 self.inner.get(key) in iter()
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/sync/
H A Dwake_list.rs156 unsafe { &*self.waker_set.inner.get() } in deref()
162 unsafe { &mut *self.waker_set.inner.get() } in deref_mut()
188 assert_eq!((*wakelist.inner.get()).wake_list.len, 0); in ut_wakelist_new_01()
/commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/conn/
H A Dhttp1.rs103 .get("Content-Length")
111 .get("Transfer-Encoding")
182 match part.headers.get("Connection") { in decode_response()
269 // When using `Uploader`, here we can get `UserAborted` error. in read_body_result()
/commonlibrary/rust/ylong_http/ylong_http_client/src/util/c_openssl/verify/
H A Dpinning.rs151 self.pub_keys.get(&String::from(domain)).cloned()
181 internal: Some(InternalError::Ssl(ErrorStack::get())),
189 internal: Some(InternalError::Ssl(ErrorStack::get())),
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/sync/mpsc/bounded/
H A Darray.rs84 let node = self.data.get(index).unwrap(); in prepare_send()
107 let node = self.data.get(index).unwrap();
146 let node = self.data.get(index).unwrap();
218 let node = self.data.get(index).unwrap(); in drop()
245 let node = self.array.data.get(index).unwrap();
/commonlibrary/ets_utils/js_concurrent_module/utils/locks/
H A Dgraph.h73 auto fromVertexPtr = std::get<0>(edef); in Graph()
79 auto toVertexPtr = std::get<1>(edef); in Graph()
95 auto fromVertexPtr = std::get<0>(edef); in Graph()
96 auto toVertexPtr = std::get<1>(edef); in Graph()
97 auto edgeDataPtr = std::get<2>(edef); in Graph()
/commonlibrary/rust/ylong_http/ylong_http_client/examples/
H A Dsync_proxy_http.rs27 let request = Request::get("http://127.0.0.1:3000") in main()
H A Dsync_redirect_http.rs26 let request = Request::get("127.0.0.1:3000") in main()
H A Dsync_http.rs26 let request = Request::get("127.0.0.1:3000") in main()

Completed in 12 milliseconds

1234