Home
last modified time | relevance | path

Searched refs:queueSize (Results 1 - 25 of 43) sorted by relevance

12

/foundation/communication/dsoftbus/core/common/queue/
H A Dsoftbus_queue.c59 int32_t QueueSizeCalc(uint32_t unitNum, uint32_t* queueSize) in QueueSizeCalc() argument
63 if (queueSize == NULL) { in QueueSizeCalc()
64 COMM_LOGE(COMM_UTILS, "queueSize is null"); in QueueSizeCalc()
73 *queueSize = ((size + CACHE_LINE_SIZE - 1) & (~(CACHE_LINE_SIZE - 1))); in QueueSizeCalc()
100 uint32_t queueSize; in CreateQueue() local
101 int ret = QueueSizeCalc(unitNum, &queueSize); in CreateQueue()
105 LockFreeQueue *queue = (LockFreeQueue *)SoftBusCalloc(queueSize); in CreateQueue()
/foundation/graphic/surface_lite/frameworks/
H A Dsurface_impl.cpp179 void SurfaceImpl::SetQueueSize(uint8_t queueSize) in SetQueueSize() argument
182 RETURN_IF_FAIL(queueSize >= SURFACE_MIN_QUEUE_SIZE && queueSize <= SURFACE_MAX_QUEUE_SIZE); in SetQueueSize()
183 producer_->SetQueueSize(queueSize); in SetQueueSize()
189 uint8_t queueSize = producer_->GetQueueSize(); in GetQueueSize() local
190 return queueSize; in GetQueueSize()
H A Dbuffer_queue.cpp303 void BufferQueue::SetQueueSize(uint8_t queueSize) in SetQueueSize() argument
305 if (queueSize > BUFFER_QUEUE_SIZE_MAX || queueSize == queueSize_) { in SetQueueSize()
306 GRAPHIC_LOGI("The queue count(%u) is invalid", queueSize); in SetQueueSize()
310 if (queueSize_ > queueSize) { in SetQueueSize()
311 uint8_t needDelete = queueSize_ - queueSize; in SetQueueSize()
330 queueSize_ = queueSize; in SetQueueSize()
332 } else if (queueSize_ < queueSize) { in SetQueueSize()
333 queueSize_ = queueSize; in SetQueueSize()
H A Dbuffer_client_producer.cpp142 void BufferClientProducer::SetQueueSize(uint8_t queueSize) in SetQueueSize() argument
147 WriteUint8(&requestIo, queueSize); in SetQueueSize()
154 GRAPHIC_LOGW("Set Attr(%d:%u) failed", SET_QUEUE_SIZE, queueSize); in SetQueueSize()
179 uint8_t queueSize; in GetQueueSize() local
180 ReadUint8(&reply, &queueSize); in GetQueueSize()
182 return queueSize; in GetQueueSize()
H A Dbuffer_queue_producer.cpp80 uint32_t queueSize; in OnSetQueueSize() local
81 ReadUint32(io, &queueSize); in OnSetQueueSize()
82 product->SetQueueSize(queueSize); in OnSetQueueSize()
279 void BufferQueueProducer::SetQueueSize(uint8_t queueSize) in SetQueueSize() argument
282 bufferQueue_->SetQueueSize(queueSize); in SetQueueSize()
H A Dbuffer_client_producer.h73 * @param [in] queueSize. Could allocate buffer count.
75 void SetQueueSize(uint8_t queueSize) override;
H A Dbuffer_queue_producer.h80 * @param [in] queueSize. Could allocate buffer count.
82 void SetQueueSize(uint8_t queueSize) override;
/foundation/communication/dsoftbus/tests/core/common/queue/
H A Dqueue_test.cpp71 uint32_t queueSize; in HWTEST_F() local
74 ret = QueueSizeCalc(QUEUE_SIZE_MAX + 1, &queueSize); in HWTEST_F()
/foundation/systemabilitymgr/samgr_lite/samgr/source/
H A Dtask_manager.c46 MQueueId queueId = (MQueueId)QUEUE_Create(name, sizeof(Exchange), config->queueSize); in SAMGR_CreateFixedTaskPool()
48 HILOG_ERROR(HILOG_MODULE_SAMGR, "Create Queue<%s> size:%hu failed!", name, config->queueSize); in SAMGR_CreateFixedTaskPool()
54 HILOG_ERROR(HILOG_MODULE_SAMGR, "Create TaskPool<%s> size:%hu failed!", name, config->queueSize); in SAMGR_CreateFixedTaskPool()
/foundation/systemabilitymgr/samgr_lite/interfaces/kits/samgr/
H A Dservice.h137 uint16 queueSize; member
/foundation/graphic/graphic_surface/surface/test/unittest/
H A Dnative_window_test.cpp432 int32_t queueSize = 0; in HWTEST_F() local
433 ASSERT_EQ(OH_NativeWindow_NativeWindowHandleOpt(nativeWindow, code, &queueSize), OHOS::GSERROR_OK); in HWTEST_F()
434 ASSERT_EQ(queueSize, 3); in HWTEST_F()
436 ASSERT_EQ(OH_NativeWindow_NativeWindowHandleOpt(nativeWindow, code, &queueSize), OHOS::GSERROR_OK); in HWTEST_F()
437 ASSERT_EQ(queueSize, 5); in HWTEST_F()
624 int32_t queueSize = 0; in HWTEST_F() local
625 ASSERT_EQ(OH_NativeWindow_NativeWindowHandleOpt(nativeWindowTmp, code, &queueSize), OHOS::GSERROR_OK); in HWTEST_F()
626 ASSERT_EQ(queueSize, 3); in HWTEST_F()
635 ASSERT_EQ(OH_NativeWindow_NativeWindowHandleOpt(nativeWindowTmp, code, &queueSize), OHOS::GSERROR_OK); in HWTEST_F()
636 ASSERT_EQ(queueSize, in HWTEST_F()
671 int32_t queueSize = 0; NativeWindowAttachBuffer003Test() local
846 int32_t queueSize = 0; HWTEST_F() local
[all...]
/foundation/graphic/graphic_2d/rosen/modules/render_service/core/drawable/
H A Drs_dma_buffer_surface_render_node_drawable.cpp80 const uint8_t queueSize = 3; in CreateSurface() local
81 surface->SetQueueSize(queueSize); in CreateSurface()
/foundation/multimedia/image_effect/frameworks/native/render_environment/render_thread/worker/
H A Drender_thread.h62 RenderThread<QUEUE>::RenderThread(size_t queueSize, std::function<void()> idleTask) : idleTask(idleTask), in RenderThread() argument
63 qSize(queueSize) in RenderThread()
/foundation/distributedhardware/distributed_audio/services/audioclient/spkclient/src/
H A Ddspeaker_client.cpp130 uint64_t queueSize = static_cast<uint64_t>(dataQueue_.size()); in OnWriteData() local
131 DHLOGD("Pop spk data, dataQueue size: %{public}" PRIu64, queueSize); in OnWriteData()
287 uint64_t queueSize = static_cast<uint64_t>(dataQueue_.size()); in PlayThreadRunning() local
288 DHLOGD("Pop spk data, dataqueue size: %{public}" PRIu64, queueSize); in PlayThreadRunning()
354 uint64_t queueSize = static_cast<uint64_t>(dataQueue_.size()); in OnDecodeTransDataDone() local
355 DHLOGD("Push new spk data, buf len: %{public}" PRIu64, queueSize); in OnDecodeTransDataDone()
/foundation/graphic/surface_lite/interfaces/innerkits/
H A Dbuffer_producer.h90 * @param [in] queueSize. Could allocate buffer count.
92 virtual void SetQueueSize(uint8_t queueSize) = 0;
H A Dsurface_impl.h55 * @param [in] queueSize. Could alloc buffer count.
57 void SetQueueSize(uint8_t queueSize) override;
H A Dbuffer_queue.h92 * @param [in] queueSize. Could alloc buffer count.
94 void SetQueueSize(uint8_t queueSize);
/foundation/graphic/surface_lite/interfaces/kits/
H A Dsurface.h80 * @param queueSize Indicates the number of buffers to set.
84 virtual void SetQueueSize(uint8_t queueSize) = 0;
/foundation/distributedhardware/distributed_screen/services/screentransport/test/unittest/screensourcetrans/src/
H A Dscreen_source_trans_test.cpp558 uint32_t queueSize = trans->dataQueue_.size(); in HWTEST_F() local
561 EXPECT_NE(queueSize, trans->dataQueue_.size()); in HWTEST_F()
573 uint32_t queueSize = trans->dataQueue_.size(); in HWTEST_F() local
579 EXPECT_NE(queueSize, trans->dataQueue_.size()); in HWTEST_F()
/foundation/distributedhardware/distributed_audio/services/audiomanager/managersource/src/
H A Ddmic_dev.cpp564 uint64_t queueSize; in OnDecodeTransDataDone() local
566 queueSize = static_cast<uint64_t>(dataQueue_.size()); in OnDecodeTransDataDone()
567 DHLOGD("Data queue overflow. buf current size: %{public}" PRIu64, queueSize); in OnDecodeTransDataDone()
571 queueSize = static_cast<uint64_t>(dataQueue_.size()); in OnDecodeTransDataDone()
572 DHLOGD("Push new mic data, buf len: %{public}" PRIu64, queueSize); in OnDecodeTransDataDone()
/foundation/arkui/ace_engine/frameworks/core/components_ng/render/adapter/
H A Drosen_render_surface.h107 void SetSurfaceQueueSize(int32_t queueSize = SURFACE_QUEUE_SIZE) override
109 queueSize_ = queueSize;
/foundation/graphic/graphic_surface/surface/src/
H A Dbuffer_queue.cpp358 SURFACE_TRACE_NAME_FMT("RequestBuffer name: %s queueId: %" PRIu64 " queueSize: %u", in RequestBuffer()
841 SURFACE_TRACE_NAME_FMT("AcquireBuffer with PresentTimestamp name: %s queueId: %" PRIu64 " queueSize: %u" in AcquireBuffer()
1244 int32_t queueSize = static_cast<int32_t>(bufferQueueSize_); in AttachBuffer() local
1245 if (usedSize >= queueSize) { in AttachBuffer()
1247 if (freeSize >= usedSize - queueSize + 1) { in AttachBuffer()
1248 DeleteBuffersLocked(usedSize - queueSize + 1); in AttachBuffer()
1319 GSError BufferQueue::SetQueueSize(uint32_t queueSize) in SetQueueSize() argument
1321 if (isShared_ == true && queueSize != 1) { in SetQueueSize()
1322 BLOGW("shared queue size: %{public}u, uniqueId: %{public}" PRIu64 ".", queueSize, uniqueId_); in SetQueueSize()
1326 if (queueSize in SetQueueSize()
[all...]
/foundation/graphic/graphic_surface/surface/test/fuzztest/surface_fuzzer/
H A Dsurface_fuzzer.cpp188 uint32_t queueSize = GetData<uint32_t>(); in SurfaceFuzzTest1() local
201 pSurface->SetQueueSize(queueSize); in SurfaceFuzzTest1()
213 cSurface->SetQueueSize(queueSize); in SurfaceFuzzTest1()
/foundation/arkui/ace_engine/frameworks/core/components_ng/render/
H A Drender_surface.h121 virtual void SetSurfaceQueueSize(int32_t queueSize) {} in SetSurfaceQueueSize() argument
/foundation/graphic/graphic_surface/surface/test/fuzztest/bufferqueue_fuzzer/
H A Dbufferqueue_fuzzer.cpp61 uint32_t queueSize = GetData<uint32_t>(); in BufferQueueFuzzTest2() local
85 bufferqueue->SetQueueSize(queueSize); in BufferQueueFuzzTest2()

Completed in 21 milliseconds

12