/commonlibrary/utils_lite/include/ |
H A D | utils_list.h | 17 * @defgroup utils_list Doubly linked list
46 * This API is used to initialize a doubly linked list.
52 * @param list [IN] Node in a doubly linked list.
59 static inline void UtilsListInit(UTILS_DL_LIST *list)
in UtilsListInit() argument 61 list->pstNext = list;
in UtilsListInit() 62 list->pstPrev = list;
in UtilsListInit() 78 * @param object [IN] Node in the doubly linked list 172 UtilsListAdd(UTILS_DL_LIST *list, UTILS_DL_LIST *node) UtilsListAdd() argument 199 UtilsListTailInsert(UTILS_DL_LIST *list, UTILS_DL_LIST *node) UtilsListTailInsert() argument 223 UtilsListHeadInsert(UTILS_DL_LIST *list, UTILS_DL_LIST *node) UtilsListHeadInsert() argument 276 UtilsListEmpty(UTILS_DL_LIST *list) UtilsListEmpty() argument 503 UtilsListDelInit(UTILS_DL_LIST *list) UtilsListDelInit() argument [all...] |
/commonlibrary/rust/ylong_json/src/ |
H A D | linked_list.rs | 20 /// Linked list implementation, provides two sets of methods for getting nodes and members. 40 /// Gets length of the list. 46 /// Determines whether the linked list is empty. 52 /// Inserts an element at the end of the list 72 /// Pops an element from the end of the list. 93 /// Gets an ordinary iterator for a linked list. 104 /// Gets a mutable iterator for the linked list. 115 /// Gets the normal cursor of the list and sets the starting point to the list header. 121 list 590 let mut list = LinkedList::new(); ut_linked_list_pop_back() variables 608 let mut list = LinkedList::new(); ut_linked_list_iter_mut() variables 630 let mut list = LinkedList::new(); ut_linked_list_back() variables 648 let mut list = LinkedList::new(); ut_linked_list_back_mut() variables 667 let mut list = LinkedList::new(); ut_linked_list_back_node() variables 686 let mut list = LinkedList::new(); ut_linked_list_back_node_mut() variables 762 let mut list = LinkedList::new(); ut_linked_list_fmt() variables 779 let mut list = LinkedList::new(); ut_cursor_index() variables 800 let mut list = LinkedList::new(); ut_cursor_move_next() variables 829 let mut list = LinkedList::new(); ut_cursor_move_prev() variables 857 let mut list = LinkedList::new(); ut_cursor_current_node() variables 878 let mut list = LinkedList::new(); ut_cursor_mut_index() variables 899 let mut list = LinkedList::new(); ut_cursor_mut_move_next() variables 924 let mut list = LinkedList::new(); ut_cursor_mut_move_prev() variables 949 let mut list = LinkedList::new(); ut_cursor_mut_current() variables 970 let mut list = LinkedList::new(); ut_cursor_mut_remove_current() variables [all...] |
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/task/ |
H A D | join_set.rs | 52 list: Arc<Mutex<JoinList<R>>>, 85 list: Arc<Mutex<JoinList<R>>>, 86 // A flag to indicate which list this task is in. 87 // `true` means the entry is in the done list. 95 list: Default::default(), in new() 116 // When waking a JoinEntry, the entry will get popped out of the wait list and 117 // pushed into the ready list. The corresponding in_done flag will also be 118 // changed. Safety: it will take the list's lock before moving the entry, so 121 let mut list = entry.list in wake_by_ref() variables 179 let mut list = self.list.lock().unwrap(); spawn_inner() variables 285 let mut list = self.list.lock().unwrap(); build_task() variables 315 let mut list = self.list.lock().unwrap(); global() variables 323 let mut list = self.list.lock().unwrap(); global() variables 425 let mut list = self.list.lock().unwrap(); drop() variables [all...] |
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/util/ |
H A D | linked_list.rs | 14 //! This linked list does not have ownership of nodes, and it treats the 17 //! ensure that the node is in any linked list held by a caller to ensure the 69 /// Defines the structure of a linked list node. 83 /// Constructs a new linked list. 93 /// Inserts an element to the front of the list. 108 /// Pops an element from the back of the list. 123 /// Deletes an element in list. 127 /// This method can be safely used when the node is in a guarded linked list 129 /// linked list. 135 /// Checks whether the list i 226 let mut list = LinkedList::<Entry>::new(); ut_link_list_is_empty() variables 242 let mut list = LinkedList::<Entry>::new(); ut_link_list_push_and_pop() variables 269 let mut list = LinkedList::<Entry>::new(); ut_link_list_remove() variables 328 let mut list = LinkedList::<Entry>::new(); ut_link_list_for_each_mut() variables [all...] |
/commonlibrary/rust/ylong_http/ylong_http/src/h3/ |
H A D | stream.rs | 29 list: Vec<FrameKind>, 56 iter: self.list.iter(), in iter() 62 self.list.len() in len() 73 Frames { list: vec![] } 76 self.list.push(frame) 116 into_iter: self.list.into_iter(), in into_iter()
|
/commonlibrary/ets_utils/js_concurrent_module/taskpool/ |
H A D | task_group.h | 19 #include <list> 56 std::list<GroupInfo*> pendingGroupInfos_ {}; 57 std::list<napi_ref> taskRefs_ {}; 58 std::list<uint64_t> taskIds_ {};
|
H A D | task_queue.h | 19 #include <list> 38 std::list<uint64_t> tasks_ {};
|
H A D | task.h | 19 #include <list> 176 std::list<TaskInfo*> pendingTaskInfos_ {}; // for a common task executes multiple times
|
/commonlibrary/rust/ylong_http/ylong_http_client/src/sync_impl/ |
H A D | pool.rs | 52 list: Arc<Mutex<Vec<ConnDispatcher<S>>>>, 58 list: Arc::new(Mutex::new(Vec::new())), in new() 66 list: self.list.clone(), in clone() 77 let mut list = self.list.lock().unwrap(); in conn() variables 79 let curr = take(&mut *list); in conn() 88 list.push(dispatcher); in conn() 99 list.push(dispatcher); in conn()
|
H A D | client.rs | 285 /// Adds a `Proxy` to the list of proxies the `Client` will use. 408 /// Sets the list of supported ciphers for protocols before `TLSv1.3`. 422 pub fn tls_cipher_list(mut self, list: &str) -> Self { in tls_cipher_list() 423 self.tls = self.tls.cipher_list(list); in tls_cipher_list()
|
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/executor/ |
H A D | queue.rs | 458 let mut list = self.globals.lock().unwrap(); variables 462 list.push_front(task.into_header()); 464 list.push_front(task.into_header()); 484 let mut list = self.globals.lock().unwrap(); variables 485 let first_task = unsafe { Task::from_raw(list.pop_back()?) }; 490 if let Some(task) = list.pop_back() { 502 drop(list); 519 let mut list = self.globals.lock().unwrap(); variables 520 let task = list 526 drop(list); 531 let mut list = self.globals.lock().unwrap(); global() variables [all...] |
/commonlibrary/rust/ylong_http/ylong_http/src/body/mime/common/ |
H A D | multi.rs | 130 pub(crate) list: Vec<XPart<'a>>, 143 list: vec![], 201 self.list.push(XPart::Part(part)); 205 self.list.push(XPart::Multi(multi)); 209 self.list.push(xpart); 257 /// Gets the reference of part list. 258 pub fn list(&self) -> &Vec<XPart> { in list() functions 259 &self.list in list() 262 /// Gets the mutable reference of part list. 264 &mut self.list in list_mut() [all...] |
/commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/ |
H A D | pool.rs | 90 list: Arc<Mutex<Vec<ConnDispatcher<S>>>>, 100 list: Arc::new(Mutex::new(Vec::new())), in new() 116 list: self.list.clone(), in clone() 329 let mut list = self.list.lock().unwrap(); in dispatch_h1_conn() variables 330 list.push(dispatcher); in dispatch_h1_conn() 361 let mut list = self.list.lock().unwrap(); in exist_h1_conn() variables 363 let curr = take(&mut *list); in exist_h1_conn() [all...] |
/commonlibrary/ets_utils/js_concurrent_module/utils/locks/ |
H A D | async_lock.h | 19 #include <list> 74 std::list<LockRequest *> pendingList_ {}; 75 std::list<LockRequest *> heldList_ {};
|
/commonlibrary/rust/ylong_http/ylong_http/src/body/mime/encode/ |
H A D | multi.rs | 120 encoder.push_list_to_stages(multi.boundary, multi.list); 133 fn push_list_to_stages(&mut self, boundary: Vec<u8>, list: Vec<XPart<'a>>) { in push_list_to_stages() 140 if list.is_empty() { 146 let len = list.len(); 148 for (idx, xpart) in list.into_iter().enumerate() { 168 self.push_list_to_stages(multi.boundary, multi.list);
|
/commonlibrary/c_utils/base/src/ |
H A D | event_reactor.h | 23 #include <list> 77 std::list<std::shared_ptr<TimerEventHandler>> timerEventHandlers_;
|
/commonlibrary/c_utils/base/include/ |
H A D | timer.h | 22 #include <list> 136 using TimerEntryList = std::list<TimerEntryPtr>;
|
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/sync/ |
H A D | wake_list.rs | 54 /// Pushes a waker into the list and return its index in the list. 56 let mut list = self.lock(); in insert() variables 58 list.wake_list.push_back(waker) in insert()
|
/commonlibrary/rust/ylong_http/ylong_http_client/src/util/c_openssl/ssl/ |
H A D | ctx.rs | 182 /// Sets the list of supported ciphers for protocols before `TLSv1.3`. 183 pub(crate) fn set_cipher_list(&mut self, list: &str) -> Result<(), ErrorStack> { 184 let list = match CString::new(list) { 190 check_ret(unsafe { SSL_CTX_set_cipher_list(ptr, list.as_ptr() as *const _) }).map(|_| ()) 305 let list = match CString::new(SUPPORT_SIGNATURE_ALGORITHMS) { 317 list.as_ptr() as *const c_void as *mut c_void, 323 SSL_CTX_set1_sigalgs_list(ptr, list.as_ptr() as *const c_void as *mut c_void)
|
/commonlibrary/ets_utils/js_concurrent_module/worker/ |
H A D | worker.cpp | 32 static std::list<Worker *> g_workers; 36 static std::list<Worker *> g_limitedworkers; 444 "the type of the transfer list must be an array."); in CommonPostMessage() 826 ErrorHelper::ThrowError(env, ErrorHelper::TYPE_ERROR, "Transfer list must be an Array"); in CommonPostMessageToHost() 1915 std::list<Worker*>::iterator it = std::find(g_workers.begin(), g_workers.end(), worker); in IsValidWorker() 1983 std::list<WorkerListener*>& listeners = iter->second; in HandleEventListeners() 1984 std::list<WorkerListener*>::iterator it = listeners.begin(); in HandleEventListeners() 2101 std::list<WorkerListener*> listeners; in AddListenerInner() 2105 std::list<WorkerListener*>& listenerList = iter->second; in AddListenerInner() 2106 std::list<WorkerListene in AddListenerInner() [all...] |
H A D | worker.h | 20 #include <list> 588 std::map<std::string, std::list<WorkerListener*>> eventListeners_ {}; 589 std::map<std::string, std::list<WorkerListener*>> parentPortEventListeners_ {};
|
/commonlibrary/rust/ylong_http/ylong_http_client/src/util/ |
H A D | proxy.rs | 26 /// `Proxies` is responsible for managing a list of proxies. 29 list: Vec<Proxy>, 34 self.list.push(proxy) 38 self.list.iter().find(|proxy| proxy.is_intercepted(uri))
|
/commonlibrary/rust/ylong_http/ylong_http_client/src/util/c_openssl/ |
H A D | adapter.rs | 135 /// Sets the list of supported ciphers for protocols before `TLSv1.3`. 149 pub fn cipher_list(mut self, list: &str) -> Self { in cipher_list() 152 .and_then(|mut builder| builder.set_cipher_list(list).map(|_| builder)); in cipher_list() 246 pub(crate) fn alpn_proto_list(mut self, list: AlpnProtocolList) -> Self { 249 .and_then(|mut builder| builder.set_alpn_protos(list.as_slice()).map(|_| builder)); 588 /// Deserializes a list of PEM-formatted certificates. 600 /// You can use `from_pem` to parse a `&[u8]` into a list of certificates. 623 /// Deserializes a list of PEM-formatted certificates. 635 /// Deserializes a list of PEM-formatted certificates.
|
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/net/ |
H A D | schedule_io.rs | 52 list: LinkedList<Waiter>, 268 waiters.list.drain_filtered(|waiter| { in wake0() 365 .list in poll_init() 455 .list in drop()
|
/commonlibrary/rust/ylong_http/ylong_http/src/h2/ |
H A D | decoder.rs | 66 list: Vec<FrameKind>, 94 iter: self.list.iter(), in iter() 100 self.list.len() in len() 146 into_iter: self.list.into_iter(), in into_iter() 306 Frames { list: vec![] } in new() 309 self.list.push(frame) in push()
|