| /commonlibrary/rust/ylong_http/ylong_http/src/body/mime/common/ |
| H A D | headers.rs | 28 Start,
48 stage: HeaderStatus::Start,
59 HeaderStatus::Start => match self.into_iter.next() { in check_next()
93 self.stage = HeaderStatus::Start; in check_next()
101 HeaderStatus::Start => {
130 stage: HeaderStatus::Start,
140 HeaderStatus::Start => { in check_next()
151 self.stage = HeaderStatus::Start; in check_next()
170 HeaderStatus::Start => self.start_decode(remains),
|
| /commonlibrary/c_utils/base/test/unittest/common/ |
| H A D | utils_thread_test.cpp | 133 ThreadStatus status = test->Start("test_thread_01", THREAD_PROI_LOW, 1024); in HWTEST_F()
161 ThreadStatus status = test->Start("test_thread_02", THREAD_PROI_LOW, 1024); in HWTEST_F()
189 ThreadStatus status = test->Start("test_thread_03", THREAD_PROI_LOW, 1024); in HWTEST_F()
216 ThreadStatus status = test->Start("test_thread_04", THREAD_PROI_LOW, 1024); in HWTEST_F()
244 ThreadStatus status = test->Start("test_thread_05", THREAD_PROI_LOW, 1024); in HWTEST_F()
271 ThreadStatus status = test->Start("test_thread_06", THREAD_PROI_LOW, 1024); in HWTEST_F()
304 ThreadStatus status = test->Start("", THREAD_PROI_LOW, 0); in HWTEST_F()
308 status = test->Start("", THREAD_PROI_NORMAL, 1024); in HWTEST_F()
332 ThreadStatus status = test->Start("", THREAD_PROI_NORMAL, 1024); in HWTEST_F()
387 ThreadStatus status = test->Start("", THREAD_PROI_NORMA in HWTEST_F()
[all...] |
| H A D | utils_thread_pool_test.cpp | 96 pool.Start(4); in HWTEST_F()
123 pool.Start(5); in HWTEST_F()
151 pool.Start(5); in HWTEST_F()
201 pool.Start(5); in HWTEST_F()
236 pool.Start(5); in HWTEST_F()
293 pool.Start(5); in HWTEST_F()
|
| H A D | utils_event_test.cpp | 148 // 6. Start handler in HWTEST_F()
149 handler->Start(reactor.get()); in HWTEST_F()
161 ASSERT_TRUE(handler->Start(reactor.get())); in HWTEST_F()
193 EXPECT_NE(handler1->Start(reactor.get()), EVENT_SYS_ERR_OK); // already started. in HWTEST_F()
194 EXPECT_NE(handler3->Start(reactor.get()), EVENT_SYS_ERR_OK); // Bad fd. in HWTEST_F()
317 ASSERT_TRUE(handler->Start(reactor.get())); in InitAndRun()
560 bool Start(IOEventReactor* reactor);
690 if (!handler->Start(reactor_.get())) { in ScheduleTimer()
691 std::cout << "||" << gettid() << "||" << "Start timer handler failed." << std::endl; in ScheduleTimer()
876 bool TimerEventHandler::Start(IOEventReacto function in OHOS::__anon33::TimerEventHandler
[all...] |
| /commonlibrary/c_utils/base/test/benchmarktest/thread_benchmark_test/ |
| H A D | thread_benchmark_test.cpp | 150 ThreadStatus status = test->Start("test_thread_01", THREAD_PROI_LOW, THREAD_STACK_SIZE); in BENCHMARK_F()
190 ThreadStatus status = test->Start("test_thread_02", THREAD_PROI_LOW, THREAD_STACK_SIZE); in BENCHMARK_F()
254 ThreadStatus status = test->Start("test_thread_03", THREAD_PROI_LOW, THREAD_STACK_SIZE); in BENCHMARK_F()
274 ThreadStatus status = test->Start("test_thread_04", THREAD_PROI_LOW, THREAD_STACK_SIZE); in BENCHMARK_F()
314 ThreadStatus status = test->Start("test_thread_05", THREAD_PROI_LOW, THREAD_STACK_SIZE); in BENCHMARK_F()
334 ThreadStatus status = test->Start("test_thread_06", THREAD_PROI_LOW, THREAD_STACK_SIZE); in BENCHMARK_F()
377 ThreadStatus status = test->Start("", THREAD_PROI_LOW, 0); in BENCHMARK_F()
382 status = test->Start("", THREAD_PROI_NORMAL, THREAD_STACK_SIZE); in BENCHMARK_F()
404 ThreadStatus status = test->Start("", THREAD_PROI_NORMAL, THREAD_STACK_SIZE); in ThreadTestStart()
|
| /commonlibrary/c_utils/base/test/benchmarktest/thread_pool_benchmark_test/ |
| H A D | thread_pool_benchmark_test.cpp | 128 pool.Start(startThreads); in BENCHMARK_F()
179 pool.Start(startThreads); in BENCHMARK_F()
215 pool.Start(startThreads); in BENCHMARK_F()
271 pool.Start(startThreads); in BENCHMARK_F()
317 pool.Start(startThreads); in BENCHMARK_F()
383 pool.Start(startThreads); in BENCHMARK_F()
|
| /commonlibrary/ets_utils/js_concurrent_module/taskpool/ |
| H A D | thread.h | 26 bool Start();
|
| H A D | task_runner.cpp | 56 return taskInnerRunner_->Start();
in Execute()
|
| H A D | thread.cpp | 29 bool Thread::Start() in Start() function in Commonlibrary::Concurrent::TaskPoolModule::Thread
|
| /commonlibrary/ets_utils/js_concurrent_module/worker/ |
| H A D | thread.h | 26 bool Start();
|
| H A D | thread.cpp | 21 bool Thread::Start()
in Start() function in Commonlibrary::Concurrent::WorkerModule::Thread
|
| H A D | worker_runner.cpp | 43 return workerInnerRunner_->Start();
in Execute()
|
| /commonlibrary/c_utils/base/include/ |
| H A D | thread_ex.h | 77 ThreadStatus Start(const std::string& name, int32_t priority = THREAD_PROI_NORMAL, size_t stack = 0);
|
| H A D | thread_pool.h | 60 uint32_t Start(int threadsNum);
68 * If <b>Start()</b> has never been called, the task will be executed
|
| H A D | io_event_handler.h | 36 bool Start(IOEventReactor* reactor);
|
| /commonlibrary/c_utils/base/test/benchmarktest/event_benchmark_test/ |
| H A D | event_benchmark_test.cpp | 185 // 5. Start handler in BENCHMARK_F()
186 handler->Start(reactor.get()); in BENCHMARK_F()
201 AssertTrue((handler->Start(reactor.get())), in BENCHMARK_F()
202 "handler->Start(reactor.get()) did not equal true as expected.", state); in BENCHMARK_F()
279 AssertUnequal(handler1->Start(reactor.get()), true, in BENCHMARK_F()
280 "handler1->Start(reactor.get()) was not different from false as expected.", state); in BENCHMARK_F()
281 AssertUnequal(handler3->Start(reactor.get()), true, in BENCHMARK_F()
282 "handler3->Start(reactor.get()) was not different from false as expected.", state); in BENCHMARK_F()
438 AssertTrue((handler->Start(reactor.get())), in BENCHMARK_F()
439 "handler->Start(reacto in BENCHMARK_F()
1022 bool TimerEventHandler::Start(IOEventReactor* reactor) Start() function in OHOS::__anon12::TimerEventHandler
[all...] |
| /commonlibrary/rust/ylong_http/ylong_http/src/body/mime/encode/ |
| H A D | part.rs | 87 stage: PartStatus::Start,
97 PartStatus::Start => { in check_next()
177 PartStatus::Start => self.start_encode(), in data()
200 PartStatus::Start => Poll::Ready(self.start_encode()), in poll_data()
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/tests/ |
| H A D | async_buf_write.rs | 129 let seek = buf_writer.seek(SeekFrom::Start(5)).await.unwrap(); in sdv_buf_writer_seek()
136 buf_writer.seek(SeekFrom::Start(5)).await.unwrap(); in sdv_buf_writer_seek()
|
| /commonlibrary/rust/ylong_json/src/ |
| H A D | states.rs | 138 Start, // State at the start of the match. in parse_object()
148 // The initial status is Start. in parse_object()
149 let mut state = InnerState::Start; in parse_object()
154 (InnerState::Start | InnerState::NoComma, Some(RIGHT_CURLY_BRACKET)) => { in parse_object()
161 (InnerState::Start | InnerState::AfterComma, Some(QUOTATION_MARK)) => { in parse_object()
179 (InnerState::Start, Some(_)) => return unexpected_character!(deserializer), in parse_object()
441 Start, in parse_array()
451 // The initial status is Start. in parse_array()
452 let mut state = InnerState::Start; in parse_array()
457 (InnerState::Start, Som in parse_array()
[all...] |
| /commonlibrary/c_utils/base/src/ |
| H A D | io_event_handler.cpp | 45 bool IOEventHandler::Start(IOEventReactor* reactor) in Start() function in OHOS::Utils::IOEventHandler
|
| H A D | thread_pool.cpp | 37 uint32_t ThreadPool::Start(int numThreads) in Start() function in OHOS::ThreadPool
|
| H A D | thread_ex.cpp | 106 ThreadStatus Thread::Start(const std::string& name, int32_t priority, size_t stack) in Start() function in OHOS::Thread
|
| /commonlibrary/c_utils/base/test/fuzztest/thread_fuzzer/ |
| H A D | thread_fuzzer.cpp | 92 auto result = t->Start(name, newPriority, stacksize); in ThreadTestFunc()
|
| /commonlibrary/rust/ylong_http/ylong_http/src/h1/response/ |
| H A D | decoder.rs | 116 Start,
304 self.stage = ParseStage::Header(HeaderStage::Start);
363 HeaderStage::Start => { in decode_header()
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/process/sys/unix/ |
| H A D | pipe.rs | 121 pipe.fd.seek(std::io::SeekFrom::Start(seek)).unwrap(); in ut_process_pipe_test()
|