| /commonlibrary/rust/ylong_http/ylong_http/src/h2/ |
| H A D | parts.rs | 22 pub(crate) map: Headers,
30 map: Headers::new(), in new()
41 self.map = headers; in set_header_lines()
45 self.pseudo.is_empty() && self.map.is_empty()
55 Header::Other(header) => self.map.append(header.as_str(), value.as_str()).unwrap(),
60 (&self.pseudo, &self.map)
64 (self.pseudo, self.map)
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/tests/ |
| H A D | par_iter.rs | 30 .map(|x| *x + 1) in sdv_par_iter_test()
33 .map(|x| x.0 * (*x.1)) in sdv_par_iter_test()
46 .map(|x| (*x.0, *x.1)) in sdv_par_iter_test()
48 let sum = m.into_par_iter().map(|x| x.0 * x.1).sum().await.unwrap(); in sdv_par_iter_test()
53 .map(|x| x + 1) in sdv_par_iter_test()
56 .map(|x| x.0 * x.1) in sdv_par_iter_test()
|
| /commonlibrary/rust/ylong_http/ylong_http/src/h3/ |
| H A D | parts.rs | 22 pub(crate) map: Headers,
30 map: Headers::new(), in new()
41 self.map = headers; in set_header_lines()
46 self.pseudo.is_empty() && self.map.is_empty() in is_empty()
57 NameField::Other(header) => self.map.append(header.as_str(), value.as_str()).unwrap(), in update()
63 (&self.pseudo, &self.map) in parts()
68 (self.pseudo, self.map) in into_parts()
109 header.get("test-key").map(|v| v.to_string().unwrap()), in ut_h3_part_update()
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/iter/pariter/ |
| H A D | mod.rs | 21 mod map; modules
22 use map::Map;
59 fn map<F, B>(self, map_op: F) -> Map<Self, F> in map() functions
63 map::map(self, map_op) in map()
|
| H A D | map.rs | 18 pub fn map<P, F>(par_iter: P, map_op: F) -> Map<P, F> { in map() functions
55 right.map(|right| Map { in split()
63 self.base.iter().map(self.map_op) in iter()
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/util/c_openssl/ |
| H A D | adapter.rs | 87 .and_then(|mut builder| builder.set_ca_file(path).map(|_| builder)); in ca_file()
108 .map(|_| builder) in max_proto_version()
130 .map(|_| builder) in min_proto_version()
152 .and_then(|mut builder| builder.set_cipher_list(list).map(|_| builder)); in cipher_list()
174 .map(|_| builder) in certificate_file()
195 .and_then(|mut builder| builder.set_certificate_chain_file(path).map(|_| builder)); in certificate_chain_file()
237 .and_then(|mut builder| builder.set_alpn_protos(protocols).map(|_| builder));
249 .and_then(|mut builder| builder.set_alpn_protos(list.as_slice()).map(|_| builder));
263 .map(|_| builder) in build_in_root_certs()
292 .map(| in danger_accept_invalid_certs()
[all...] |
| /commonlibrary/c_utils/base/include/ |
| H A D | timer.h | 23 #include <map>
138 std::map<uint32_t, TimerEntryList> intervalToTimers_; // interval to TimerEntryList
139 std::map<uint32_t, TimerEntryPtr> timerToEntries_; // timer_id to TimerEntry
145 std::map<uint32_t, uint32_t> timers_; // timer_fd to interval
|
| H A D | safe_map.h | 19 #include <map>
25 * @brief Provides interfaces for thread-safe map operations.
65 * @brief Obtains the map size.
67 * In the multithread scenario, the map size returned is a tmp status,
78 * @brief Checks whether the map is empty.
84 * @return Returns <b>true</b> if the map is empty;
94 * @brief Inserts an element to the map.
109 * @brief Forcibly inserts an element to the map.
130 * @brief Searches for an element in the map.
189 * @brief Deletes all KV pairs from the map
[all...] |
| /commonlibrary/rust/ylong_json/src/value/object/ |
| H A D | vec.rs | 181 self.inner.iter().find(|(k, _)| k == key).map(|(_, v)| v) in iter()
201 .map(|(_, v)| v) in get_mut()
206 self.inner.last_mut().map(|(_, v)| v)
210 self.inner.get_mut(index).map(|(_, v)| v)
|
| H A D | linked_list.rs | 135 self.get_cursor_mut(key)?.remove_current().map(|(_, v)| v) in remove()
178 self.get_cursor(key)?.current().map(|(_, v)| v) in iter()
196 self.get_node_mut(key).map(|n| &mut n.get_element_mut().1) in get_mut()
|
| /commonlibrary/c_utils/base/src/ |
| H A D | event_demultiplexer.h | 22 #include <map>
51 std::map<int, std::shared_ptr<EventHandler>> eventHandlers_; // guard by mutex_
|
| /commonlibrary/ets_utils/platform/ohos/ |
| H A D | qos_helper.cpp | 18 #include <map>
30 static const std::map<Priority, QosLevel> WORKERPRIORITY_QOSLEVEL_MAP = {
|
| /commonlibrary/rust/ylong_http/ylong_http/src/h3/qpack/format/ |
| H A D | encoder.rs | 815 map: HeadersIntoIter,
834 map: parts.map.into_iter(),
866 .map in next()
868 .map(|(h, v)| (NameField::Other(h.to_string()), v.to_string().unwrap())); in next()
|
| /commonlibrary/ets_utils/js_sys_module/console/ |
| H A D | console.cpp | 24 thread_local std::map<std::string, int64_t> Console::timerMap;
25 thread_local std::map<std::string, uint32_t> Console::counterMap;
32 std::map<std::string, std::string> tableChars = {
423 napi_value GetKeyArray(napi_env env, napi_value map) in GetKeyArray() argument
426 napi_object_get_keys(env, map, &mapKeys); in GetKeyArray()
447 napi_value GetValueArray(napi_env env, napi_value map, const size_t& length, napi_value keyArray) in GetValueArray() argument
450 napi_object_get_keys(env, map, &mapKeys); in GetValueArray()
475 napi_get_named_property(env, map, innerKey, &valueNumber); in GetValueArray()
486 void SetPrimitive(napi_env env, napi_value map, const size_t& length, napi_value valuesKeyArray, in SetPrimitive() argument
490 napi_object_get_keys(env, map, in SetPrimitive()
506 ProcessNestedObject(napi_env env, napi_value item, napi_value& map, std::map<std::string, bool>& initialMap, size_t index) ProcessNestedObject() argument
558 napi_value map = nullptr; ProcessTabularData() local
[all...] |
| H A D | console.h | 18 #include <map>
81 static thread_local std::map<std::string, int64_t> timerMap;
82 static thread_local std::map<std::string, uint32_t> counterMap;
|
| /commonlibrary/ets_utils/js_sys_module/timer/test/ |
| H A D | test_timer.h | 31 static std::map<uint32_t, TimerCallbackInfo*>& create_timerTable();
56 std::map<uint32_t, TimerCallbackInfo*>& TimerTest::create_timerTable() in create_timerTable()
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/process/ |
| H A D | command.rs | 207 /// Clears the entire environment map for the child process.
337 .map(super::sys::stdio) in spawn()
339 .map(ChildStdin::new); in spawn()
343 .map(super::sys::stdio) in spawn()
345 .map(ChildStdout::new); in spawn()
349 .map(super::sys::stdio) in spawn()
351 .map(ChildStderr::new); in spawn()
|
| /commonlibrary/rust/ylong_runtime/ylong_io/src/sys/unix/uds/ |
| H A D | datagram.rs | 39 super::socket::data_gram_bind(path.as_ref()).map(Self::from_std) in bind()
68 super::socket::unbound().map(Self::from_std) in unbound()
99 .map(|(datagram1, datagram2)| (Self::from_std(datagram1), Self::from_std(datagram2))) in pair()
|
| H A D | listener.rs | 43 super::socket::bind(path.as_ref()).map(UnixListener::from_std) in bind()
75 .map(|socket| unsafe { net::UnixStream::from_raw_fd(socket) })? in accept()
84 .map(|socket| { in accept()
|
| /commonlibrary/ets_utils/js_sys_module/timer/ |
| H A D | timer.h | 19 #include <map>
84 static std::map<uint32_t, TimerCallbackInfo*> timerTable;
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/util/c_openssl/ssl/ |
| H A D | ctx.rs | 137 .map(|_| ());
143 .map(|_| ());
158 .map(|_| ());
163 .map(|_| ());
179 .map(|_| ())
190 check_ret(unsafe { SSL_CTX_set_cipher_list(ptr, list.as_ptr() as *const _) }).map(|_| ())
212 .map(|_| ())
227 .map(|_| ())
320 .map(|_| ());
325 .map(|
[all...] |
| /commonlibrary/rust/ylong_http/ylong_http_client/src/util/c_openssl/verify/ |
| H A D | pinning.rs | 29 /// The map key is server authority(host:port), value is Base64(sha256(Server's
219 let mut map = HashMap::new(); in ut_pubkey_pins_clone() variables
220 let _value = map.insert( in ut_pubkey_pins_clone()
224 let pins = PubKeyPins { pub_keys: map }; in ut_pubkey_pins_clone()
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/process/sys/unix/ |
| H A D | child.rs | 96 AsyncSource::new(pipe, None).map(|inner| ChildStdio { inner })
125 to_blocking_file(io).map(Stdio::from)
135 to_blocking_file(self).map(OwnedFd::from)
|
| /commonlibrary/ets_utils/js_api_module/xml/ |
| H A D | js_xml.h | 21 #include <map>
158 std::map<int, std::map<int, std::string>> multNsp;
415 std::map<std::string, std::string> documentEntities;
416 std::map<std::string, std::map<std::string, std::string>> defaultAttributes;
417 std::map<std::string, std::string> DEFAULT_ENTITIES = {
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/examples/ |
| H A D | ylong_runtime_par_iter.rs | 23 .map(fibbo) in main()
|