Home
last modified time | relevance | path

Searched refs:builder (Results 1 - 25 of 83) sorted by relevance

1234

/commonlibrary/memory_utils/libpurgeablemem/c/src/
H A Dpurgeable_mem_builder_c.c28 /* purgeable mem builder */
36 /* append a guest builder @newcomer to @head */
43 struct PurgMemBuilder *builder = NULL; in PurgMemBuilderCreate() local
44 builder = (struct PurgMemBuilder *)malloc(sizeof(struct PurgMemBuilder)); in PurgMemBuilderCreate()
45 if (!builder) { in PurgMemBuilderCreate()
49 builder->Build = func; in PurgMemBuilderCreate()
50 builder->nextBuilder = NULL; in PurgMemBuilderCreate()
51 builder->param = param; in PurgMemBuilderCreate()
52 builder->name = name; in PurgMemBuilderCreate()
53 return builder; in PurgMemBuilderCreate()
56 PurgMemBuilderDestroy(struct PurgMemBuilder *builder) PurgMemBuilderDestroy() argument
72 PurgMemBuilderAppendFunc(struct PurgMemBuilder *builder, PurgMemBuilderFunc func, void *param, const char *name) PurgMemBuilderAppendFunc() argument
86 PurgMemBuilderBuildAll(struct PurgMemBuilder *builder, void *data, size_t size) PurgMemBuilderBuildAll() argument
106 PurgMemBuilderAppendBuilder(struct PurgMemBuilder *builder, struct PurgMemBuilder *newcomer) PurgMemBuilderAppendBuilder() argument
[all...]
H A Dpurgeable_mem_c.c36 struct PurgMemBuilder *builder; member
51 (unsigned long)(obj->builder), (unsigned long)(obj->uxPageTable)); in LogPurgMemInfo()
70 static struct PurgMem *PurgMemCreate_(size_t len, struct PurgMemBuilder *builder) in PurgMemCreate_() argument
72 /* PurgMemObj allow no builder temporaily */ in PurgMemCreate_()
104 pugObj->builder = builder; in PurgMemCreate_()
133 /* a PurgMemObj must have builder */ in PurgMemCreate()
145 /* append func fail meas create builder failed */ in PurgMemCreate()
165 /* destroy builder */ in PurgMemDestroy()
166 if (purgObj->builder) { in PurgMemDestroy()
419 struct PurgMemBuilder *builder = PurgMemBuilderCreate(func, funcPara, NULL); PurgMemAppendModify() local
[all...]
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/builder/
H A Dmulti_thread_builder.rs23 use crate::builder::ScheduleAlgo;
27 use crate::builder::common_builder::impl_common;
28 use crate::builder::CommonBuilder;
34 /// Runtime builder that configures a multi-threaded runtime, or the global
65 let mut builder = GLOBAL_BUILDER.lock().unwrap(); in build_global() variables
66 if builder.is_some() { in build_global()
81 *builder = Some(self); in build_global()
124 /// use crate::ylong_runtime::builder::RuntimeBuilder;
229 use crate::builder::initialize_async_spawner; in build()
247 /// use crate::ylong_runtime::builder
[all...]
H A Dcurrent_thread_builder.rs16 use crate::builder::common_builder::impl_common;
17 use crate::builder::CommonBuilder;
/commonlibrary/rust/ylong_http/ylong_http_client/src/util/c_openssl/
H A Dadapter.rs60 /// let builder = TlsConfigBuilder::new();
64 inner: SslContext::builder(SslMethod::tls_client()), in new()
82 /// let builder = TlsConfigBuilder::new().ca_file("ca.crt");
87 .and_then(|mut builder| builder.set_ca_file(path).map(|_| builder)); in ca_file()
102 /// let builder = TlsConfigBuilder::new().max_proto_version(TlsVersion::TLS_1_2);
105 self.inner = self.inner.and_then(|mut builder| { in max_proto_version()
106 builder in max_proto_version()
108 .map(|_| builder) in max_proto_version()
433 pub fn builder() -> TlsConfigBuilder { builder() functions
[all...]
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/task/
H A Dbuilder.rs15 //! [`TaskBuilder`] inherit all attributes of this builder.
113 let builder = TaskBuilder::new(); in ut_builder_name()
116 assert_eq!(builder.name(name.clone()).name.unwrap(), name); in ut_builder_name()
128 let builder = TaskBuilder::new(); in ut_builder_pri()
130 assert_eq!(builder.qos(pri).qos.unwrap(), pri); in ut_builder_pri()
132 let builder = TaskBuilder::new(); in ut_builder_pri()
134 assert_eq!(builder.qos(pri).qos.unwrap(), pri); in ut_builder_pri()
136 let builder = TaskBuilder::new(); in ut_builder_pri()
138 assert_eq!(builder.qos(pri).qos.unwrap(), pri); in ut_builder_pri()
140 let builder in ut_builder_pri()
[all...]
H A Djoin_set.rs53 builder: TaskBuilder,
96 builder: Default::default(), in new()
164 fn spawn_inner<T>(&mut self, task: T, builder: Option<&TaskBuilder>) -> CancelHandle in spawn_inner()
169 let handle = match builder { in spawn_inner()
170 None => spawn_async(&self.builder, task), in spawn_inner()
171 Some(builder) => builder.spawn(task), in spawn_inner()
268 /// Creates a builder that configures task attributes. This builder could
276 /// let mut builder
[all...]
H A Dmod.rs16 pub mod builder; modules
28 pub use builder::TaskBuilder;
98 builder: &TaskBuilder,
108 let raw = Task::create_raw_task::<T, S>(builder, scheduler, task, virtual_table_type);
115 builder: &TaskBuilder,
125 builder,
/commonlibrary/rust/ylong_http/ylong_http/examples/
H A Dmimebody_multi.rs125 let multi = MimeMulti::builder() in main()
128 MimePart::builder() in main()
134 MimePart::builder() in main()
141 MimeMulti::builder() in main()
144 MimePart::builder() in main()
152 MimePart::builder() in main()
163 MimePart::builder() in main()
170 MimePart::builder() in main()
H A Dmimebody_multi_then_async_data.rs50 let multi = MimeMulti::builder()
53 MimePart::builder()
59 MimePart::builder()
66 MimeMulti::builder()
69 MimePart::builder()
77 MimePart::builder()
88 MimePart::builder()
95 MimePart::builder()
/commonlibrary/rust/ylong_runtime/ylong_runtime_macros/src/
H A Dselect.rs71 builder: &mut ParserBuilder, in parse_group()
77 builder.len = group_num(group.stream()) - 1; in parse_group()
83 builder.except_index = group.stream().into_iter().count(); in parse_group()
90 fn parse_token(buf: &[TokenTree], idx: &mut usize, flags: &mut Flags, builder: &mut ParserBuilder) { in parse_token()
98 if !parse_group(group, idx, flags, builder) { in parse_token()
108 builder.except.extend(default_or_except); in parse_token()
110 builder.default.extend(default_or_except); in parse_token()
121 let mut builder = ParserBuilder::default(); variables
125 parse_token(&buf, &mut idx, &mut flags, &mut builder);
127 builder
[all...]
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/executor/
H A Dblocking_pool.rs23 use crate::builder::{CallbackHook, CommonBuilder};
44 pub fn new(builder: &CommonBuilder) -> BlockPoolSpawner { in new()
45 let keep_alive_time = builder in new()
48 let max_thread_num = builder in new()
66 stack_size: builder.stack_size, in new()
67 after_start: builder.after_start.clone(), in new()
68 before_stop: builder.before_stop.clone(), in new()
71 max_permanent_thread_num: builder.blocking_permanent_thread_num, in new()
175 let mut builder = thread::Builder::new().name(format!("block-r-{worker_id}")); in create_permanent_threads() variables
177 builder in create_permanent_threads()
234 let mut builder = thread::Builder::new().name(format!("block-{worker_id}")); spawn() variables
[all...]
H A Dasync_pool.rs28 use crate::builder::multi_thread_builder::MultiThreadBuilder;
29 use crate::builder::CallbackHook;
413 pub(crate) fn new(builder: &MultiThreadBuilder) -> io::Result<Self> {
416 let thread_num = builder.core_thread_size.unwrap_or_else(get_cpu_core);
420 is_affinity: builder.common.is_affinity,
422 after_start: builder.common.after_start.clone(),
423 before_stop: builder.common.before_stop.clone(),
424 worker_name: builder.common.worker_name.clone(),
425 stack_size: builder.common.stack_size,
455 let mut builder in create_async_thread_pool() variables
[all...]
H A Dmod.rs25 use crate::builder::multi_thread_builder::GLOBAL_BUILDER;
26 use crate::builder::RuntimeBuilder;
45 use crate::builder::{initialize_blocking_spawner, initialize_async_spawner};
110 // we have just made sure the global builder is a some, so this unwrap_unchecked is safe
140 // we have just made sure the global builder is a some, so this unwrap_unchecked
175 /// use ylong_runtime::builder::RuntimeBuilder;
200 pub(crate) fn spawn_with_attr<T, R>(&self, task: T, builder: &TaskBuilder) -> JoinHandle<R>
207 AsyncHandle::CurrentThread(current_thread) => current_thread.spawn(builder, task),
209 AsyncHandle::MultiThread(async_spawner) => async_spawner.spawn(builder, task),
211 AsyncHandle::FfrtMultiThread => spawn(task, builder),
[all...]
/commonlibrary/rust/ylong_http/ylong_http/src/body/mime/decode/
H A Dmulti.rs43 /// let multi1 = MimeMulti::builder()
46 /// MimePart::builder()
104 /// let multi1 = MimeMulti::builder()
106 /// .add_part(MimePart::builder().build().unwrap())
546 let multi1 = MimeMulti::builder() in ut_mime_multi_decoder_new()
548 .add_part(MimePart::builder().build().unwrap()) in ut_mime_multi_decoder_new()
572 let multi1 = MimeMulti::builder() in ut_mime_multi_decoder_one_part()
575 MimePart::builder() in ut_mime_multi_decoder_one_part()
605 let multi1 = MimeMulti::builder() in ut_mime_multi_decoder_one_part_no_headers()
608 MimePart::builder() in ut_mime_multi_decoder_one_part_no_headers()
[all...]
/commonlibrary/memory_utils/libpurgeablemem/c/include/
H A Dpurgeable_mem_builder_c.h27 /* purgeable mem builder */
35 /* If return true, @builder will be set to NULL to avoid Use-After-Free */
36 bool PurgMemBuilderDestroy(struct PurgMemBuilder *builder);
38 bool PurgMemBuilderAppendFunc(struct PurgMemBuilder *builder, PurgMemBuilderFunc func, void *param,
41 bool PurgMemBuilderAppendBuilder(struct PurgMemBuilder *builder, struct PurgMemBuilder *newcomer);
43 /* build @data content from @builder */
44 bool PurgMemBuilderBuildAll(struct PurgMemBuilder *builder, void *data, size_t size);
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/ffrt/
H A Dspawner.rs25 pub(crate) fn ffrt_submit(t: Task, builder: &TaskBuilder) {
44 if let Some(qos) = builder.qos {
48 if let Some(name) = &builder.name {
66 pub fn spawn<F>(task: F, builder: &TaskBuilder) -> JoinHandle<F::Output> in spawn()
72 let (task, join_handle) = Task::create_task(builder, scheduler, task, VirtualTableType::Ffrt); in spawn()
74 ffrt_submit(task, builder); in spawn()
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/
H A Dspawn.rs47 pub(crate) fn spawn_blocking<T, R>(builder: &TaskBuilder, task: T) -> JoinHandle<R>
54 spawn(task, builder)
60 pub(crate) fn spawn_blocking<T, R>(builder: &TaskBuilder, task: T) -> JoinHandle<R>
67 rt.spawn_blocking(builder, task)
70 /// Gets global default executor, spawns async tasks by the task builder, and
73 pub(crate) fn spawn_async<T, R>(builder: &TaskBuilder, task: T) -> JoinHandle<R>
80 rt.spawn_with_attr(task, builder)
/commonlibrary/memory_utils/libpurgeablemem/cpp/src/
H A Dpurgeable_mem_builder.cpp33 void PurgeableMemBuilder::AppendBuilder(std::unique_ptr<PurgeableMemBuilder> builder) in AppendBuilder() argument
35 IF_NULL_LOG_ACTION(builder, "input builder is nullptr", return); in AppendBuilder()
37 nextBuilder_->AppendBuilder(std::move(builder)); in AppendBuilder()
39 nextBuilder_ = std::move(builder); in AppendBuilder()
H A Dpurgeable_ashmem.cpp45 PurgeableAshMem::PurgeableAshMem(std::unique_ptr<PurgeableMemBuilder> builder) in PurgeableAshMem() argument
53 IF_NULL_LOG_ACTION(builder, "%{public}s: input builder nullptr", return); in PurgeableAshMem()
54 builder_ = std::move(builder); in PurgeableAshMem()
58 PurgeableAshMem::PurgeableAshMem(size_t dataSize, std::unique_ptr<PurgeableMemBuilder> builder) in PurgeableAshMem() argument
70 IF_NULL_LOG_ACTION(builder, "%{public}s: input builder nullptr", return); in PurgeableAshMem()
76 builder_ = std::move(builder); in PurgeableAshMem()
/commonlibrary/rust/ylong_http/ylong_http_client/tests/
H A Dsdv_async_https_pinning.rs74 let pins = PubKeyPins::builder() in sdv_client_public_key_pinning()
82 let client = ylong_http_client::async_impl::Client::builder() in sdv_client_public_key_pinning()
123 let pins = PubKeyPins::builder() in sdv_client_public_key_pinning()
131 let client = ylong_http_client::async_impl::Client::builder() in sdv_client_public_key_pinning()
172 let pins = PubKeyPins::builder() in sdv_client_public_key_pinning()
180 let client = ylong_http_client::async_impl::Client::builder() in sdv_client_public_key_pinning()
252 let pins = PubKeyPins::builder() in sdv_client_public_key_pinning_error()
264 let client = ylong_http_client::async_impl::Client::builder() in sdv_client_public_key_pinning_error()
272 let request = ylong_http_client::async_impl::Request::builder() in sdv_client_public_key_pinning_error()
/commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/
H A Drequest.rs45 /// let request = Request::builder().body(Body::empty());
66 /// let builder = Request::builder();
68 pub fn builder() -> RequestBuilder { in builder() functions
119 /// let builder = RequestBuilder::new();
132 /// let builder = RequestBuilder::new().method("GET");
145 /// let builder = RequestBuilder::new().url("www.example.com");
158 /// let builder = RequestBuilder::new().version("HTTP/1.1");
173 /// let builder = RequestBuilder::new().header("Content-Type", "application/octet-stream");
188 /// let builder
205 let mut builder = self; body() variables
[all...]
/commonlibrary/memory_utils/libpurgeablemem/test/
H A Dpurgeable_cpp_test.cpp211 std::unique_ptr<PurgeableMemBuilder> builder = std::make_unique<TestDataBuilder>('A', 'Z'); in HWTEST_F() local
212 PurgeableMem *pobj = new PurgeableMem(27, std::move(builder)); in HWTEST_F()
234 std::unique_ptr<PurgeableMemBuilder> builder = std::make_unique<TestDataBuilder>('A', 'Z'); in HWTEST_F() local
235 PurgeableMem *pobj = new PurgeableMem(27, std::move(builder)); in HWTEST_F()
262 std::unique_ptr<PurgeableMemBuilder> builder = std::make_unique<TestDataBuilder>('A', 'Z'); in HWTEST_F() local
263 PurgeableMem *pobj = new PurgeableMem(27, std::move(builder)); in HWTEST_F()
299 std::unique_ptr<PurgeableMemBuilder> builder = std::make_unique<TestBigDataBuilder>('A'); in HWTEST_F() local
300 PurgeableMem *pobj = new PurgeableMem(4098, std::move(builder)); in HWTEST_F()
328 std::unique_ptr<PurgeableMemBuilder> builder = std::make_unique<TestBigDataBuilder>('A'); in HWTEST_F() local
329 PurgeableMem *pobj = new PurgeableMem(4098, std::move(builder)); in HWTEST_F()
362 std::unique_ptr<PurgeableMemBuilder> builder = std::make_unique<TestBigDataBuilder>('A'); HWTEST_F() local
399 std::unique_ptr<PurgeableMemBuilder> builder = std::make_unique<TestBigDataBuilder>('A'); HWTEST_F() local
432 std::unique_ptr<PurgeableMemBuilder> builder = std::make_unique<TestDataBuilder>('A', 'Z'); HWTEST_F() local
459 std::unique_ptr<PurgeableMemBuilder> builder = std::make_unique<TestDataBuilder>('A', 'Z'); HWTEST_F() local
[all...]
/commonlibrary/rust/ylong_http/ylong_http_client/src/util/
H A Dproxy.rs96 let mut builder = Uri::builder(); variables
97 builder = builder
102 builder = builder.path(path.clone());
106 builder = builder.query(query.clone());
109 // Here all parts of builder is accurate.
110 builder
[all...]
/commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/downloader/
H A Dmod.rs14 mod builder; modules
19 pub use builder::DownloaderBuilder;
20 use builder::WantsBody;
99 /// let mut downloader = Downloader::builder()
131 Self::builder().body(response).console().build() in console()
141 /// let builder = Downloader::builder();
143 pub fn builder() -> DownloaderBuilder<WantsBody> { in builder() functions

Completed in 11 milliseconds

1234