| /commonlibrary/c_utils/base/test/benchmarktest/safe_block_queue_benchmark_test/ |
| H A D | safe_block_queue_benchmark_test.cpp | 78 shareQueue.Push(i); in Put()
143 DemoThreadData::shareQueue.Push(Equivalent); in QueuePushFullEquivalent()
152 DemoThreadData::shareQueue.Push(t); in QueuePushInnotfullNotEquivalent()
166 qi.Push(i); in BENCHMARK_F()
187 qi.Push(i); in BENCHMARK_F()
295 DemoThreadData::shareQueue.Push(t); in BENCHMARK_F()
362 DemoThreadData::shareQueue.Push(value); in BENCHMARK_F()
461 DemoThreadData::shareQueue.Push(t); in BENCHMARK_F()
649 qi.Push(i); // Fill the queue in BENCHMARK_F()
|
| /commonlibrary/c_utils/base/test/unittest/common/ |
| H A D | utils_safe_block_queue_test.cpp | 53 shareQueue.Push(j); in Put()
127 qi.Push(i); in HWTEST_F()
139 qi.Push(i); in HWTEST_F()
269 DemoThreadData::shareQueue.Push(t); in QueuePushInfull()
277 DemoThreadData::shareQueue.Push(t); in QueuePushInnotfull()
365 DemoThreadData::shareQueue.Push(value); in HWTEST_F()
396 DemoThreadData::shareQueue.Push(t); in HWTEST_F()
470 DemoThreadData::shareQueue.Push(t); in HWTEST_F()
611 DemoThreadData::shareQueue.Push(t); in HWTEST_F()
|
| H A D | utils_safe_block_queue_tracking.cpp | 56 shareQueue.Push(j); in Put()
132 qi.Push(i); in HWTEST_F()
145 qi.Push(i); in HWTEST_F()
290 DemoThreadData::shareQueue.Push(t); in QueuePushInfull()
298 DemoThreadData::shareQueue.Push(t); in QueuePushInnotfull()
400 DemoThreadData::shareQueue.Push(value); in HWTEST_F()
424 DemoThreadData::shareQueue.Push(Equivalent); in QueuePushFullEquivalent()
546 DemoThreadData::shareQueue.Push(t); in HWTEST_F()
|
| H A D | utils_safe_queue_test.cpp | 49 shareQueue.Push(i); in Put()
259 DemoThreadData::shareQueue.Push(t); in HWTEST_F()
296 * CaseDescription: Push elememts into the queue, then erase certain element, finally clear the queue.
305 DemoThreadData::shareQueue.Push(t); in HWTEST_F()
|
| /commonlibrary/ets_utils/js_concurrent_module/worker/ |
| H A D | message_queue.h | 44 void Push(uint32_t id, MessageDataType data);
|
| H A D | message_queue.cpp | 61 void MarkedMessageQueue::Push(uint32_t id, MessageDataType data)
in Push() function in Commonlibrary::Concurrent::WorkerModule::MarkedMessageQueue
|
| H A D | worker.cpp | 914 worker->hostGlobalCallQueue_.Push(worker->globalCallId_, data); in GlobalCall()
|
| /commonlibrary/c_utils/base/include/ |
| H A D | safe_block_queue.h | 58 virtual void Push(T const& elem) in Push() function in OHOS::SafeBlockQueue
192 virtual void Push(T const& elem) in Push() function in OHOS::SafeBlockQueueTracking
|
| H A D | safe_queue.h | 68 void Push(const T& pt) in Push() function in OHOS::SafeQueueInner
|
| /commonlibrary/c_utils/base/test/benchmarktest/safe_block_queue_tracking_benchmark_test/ |
| H A D | safe_block_queue_tracking_benchmark_test.cpp | 75 shareQueue.Push(i); in Put()
194 qi.Push(i); in BENCHMARK_F()
216 qi.Push(i); in BENCHMARK_F()
348 DemoThreadData::shareQueue.Push(t); in BENCHMARK_F()
412 DemoThreadData::shareQueue.Push(value); in BENCHMARK_F()
433 DemoThreadData::shareQueue.Push(Equivalent); in QueuePushFullEquivalent()
442 DemoThreadData::shareQueue.Push(t); in QueuePushFullNotEquivalent()
529 DemoThreadData::shareQueue.Push(t); in BENCHMARK_F()
|
| /commonlibrary/rust/ylong_http/ylong_http/src/h3/ |
| H A D | stream.rs | 127 /// Push stream message.
128 Push(u64, Frames),
|
| H A D | decoder.rs | 73 Push,
168 // The StreamType branch ensures that only Request/Control/Push can go to the in decode()
270 *self == StreamType::Push
307 StreamType::Push => DecodeState::PushId, in init_state_by_type()
368 StreamType::Push => { in return_by_type()
370 Ok(StreamMessage::Push(push_id, frames)) in return_by_type()
762 0x1 => StreamType::Push, in decode_type()
|
| /commonlibrary/c_utils/base/test/benchmarktest/safe_queue_benchmark_test/ |
| H A D | safe_queue_benchmark_test.cpp | 78 shareQueue.Push(i); in Put()
360 DemoThreadData::shareQueue.Push(t); in BENCHMARK_F()
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/util/h3/ |
| H A D | stream_manager.rs | 485 Ok(StreamMessage::Push(_id, _frames)) => { in process_recv_data()
486 // MAX_PUSH_ID not send, Push Stream means error in process_recv_data()
|
| /commonlibrary/ets_utils/js_concurrent_module/worker/test/ |
| H A D | test_worker.cpp | 321 worker->hostGlobalCallQueue_.Push(index, data); in HostOnGlobalCall()
340 worker->hostGlobalCallQueue_.Push(1, data); in HostOnGlobalCall()
363 worker->hostGlobalCallQueue_.Push(1, data); in HostOnGlobalCallInner001()
389 worker->hostGlobalCallQueue_.Push(1, data); in HostOnGlobalCallInner002()
418 worker->hostGlobalCallQueue_.Push(1, data); in HostOnGlobalCallInner003()
452 worker->hostGlobalCallQueue_.Push(1, data); in HostOnGlobalCallInner004()
485 worker->hostGlobalCallQueue_.Push(0, data); in HostOnGlobalCallInner005()
517 worker->hostGlobalCallQueue_.Push(1, data); in HostOnGlobalCallInner006()
1583 queue.Push(1, data); in HWTEST_F()
1589 queue.Push( in HWTEST_F()
[all...] |