/foundation/communication/dsoftbus/components/nstackx/fillp/src/public/src/ |
H A D | dympool.c | 24 DympoolType *pool = FILLP_NULL_PTR; in DympCreatePool() local 26 FILLP_LOGERR("Error to create pool initSize:%d,maxSize:%d,itemSize:%d", initSize, maxSize, itemSize); in DympCreatePool() 30 pool = SpungeAlloc(1, sizeof(DympoolType), SPUNGE_ALLOC_TYPE_MALLOC); in DympCreatePool() 31 if (pool == FILLP_NULL_PTR) { in DympCreatePool() 36 pool->maxSize = maxSize; in DympCreatePool() 37 pool->itemSize = itemSize; in DympCreatePool() 38 pool->currentSize = 0; in DympCreatePool() 39 pool->itemOperaCb.createCb = itemOperaCb->createCb; in DympCreatePool() 40 pool->itemOperaCb.destroyCb = itemOperaCb->destroyCb; in DympCreatePool() 41 pool in DympCreatePool() 75 DympDestroyPool(DympoolType *pool) DympDestroyPool() argument 110 DympSetConsSafe(DympoolType *pool, FILLP_BOOL safe) DympSetConsSafe() argument 115 DympSetProdSafe(DympoolType *pool, FILLP_BOOL safe) DympSetProdSafe() argument 120 DympExpandMemory(DympoolType *pool, int stepSizeWork) DympExpandMemory() argument 176 DympAskMoreMemory(DympoolType *pool, int stepSize, int throttleGrow) DympAskMoreMemory() argument 204 DympAlloc(DympoolType *pool, void **data, int throttleGrow) DympAlloc() argument [all...] |
/foundation/communication/dhcp/services/dhcp_server/src/ |
H A D | dhcp_address_pool.cpp | 85 int CheckIpAvailability(DhcpAddressPool *pool, uint8_t macAddr[DHCP_HWADDR_LENGTH], uint32_t distIp) in CheckIpAvailability() argument 87 if (!pool) { in CheckIpAvailability() 88 DHCP_LOGE("pool pointer is null."); in CheckIpAvailability() 95 AddressBinding *lease = GetLease(pool, distIp); in CheckIpAvailability() 98 if (distIp == pool->serverId || distIp == pool->gateway) { in CheckIpAvailability() 104 if (IsReservedIp(pool, distIp) && !same) { in CheckIpAvailability() 128 DhcpAddressPool *pool, uint8_t macAddr[DHCP_HWADDR_LENGTH], uint32_t distIp, int *outOfRange) in CheckRangeAvailability() 130 if (!pool || !pool in CheckRangeAvailability() 127 CheckRangeAvailability( DhcpAddressPool *pool, uint8_t macAddr[DHCP_HWADDR_LENGTH], uint32_t distIp, int *outOfRange) CheckRangeAvailability() argument 180 AddressDistribute(DhcpAddressPool *pool, uint8_t macAddr[DHCP_HWADDR_LENGTH]) AddressDistribute() argument 223 InitAddressPool(DhcpAddressPool *pool, const char *ifname, PDhcpOptionList options) InitAddressPool() argument 255 FreeAddressPool(DhcpAddressPool *pool) FreeAddressPool() argument 301 IsReservedIp(DhcpAddressPool *pool, uint32_t ipAddress) IsReservedIp() argument 398 AddLease(DhcpAddressPool *pool, AddressBinding *lease) AddLease() argument 421 GetLease(DhcpAddressPool *pool, uint32_t ipAddress) GetLease() argument 439 UpdateLease(DhcpAddressPool *pool, AddressBinding *lease) UpdateLease() argument 458 RemoveLease(DhcpAddressPool *pool, AddressBinding *lease) RemoveLease() argument 478 LoadBindingRecoders(DhcpAddressPool *pool) LoadBindingRecoders() argument 517 SaveBindingRecoders(const DhcpAddressPool *pool, int force) SaveBindingRecoders() argument 565 DeleteMacInLease(DhcpAddressPool *pool, AddressBinding *lease) DeleteMacInLease() argument [all...] |
H A D | dhcp_dhcpd.cpp | 48 void LoadLocalConfig(DhcpAddressPool *pool) in LoadLocalConfig() argument 53 void ReloadLocalConfig(DhcpAddressPool *pool) in ReloadLocalConfig() argument 94 ArgumentInfo *arg = GetArgument("pool"); in PareseAddreesRange() 96 DHCP_LOGD("pool info:%s", arg->value); in PareseAddreesRange() 105 config->pool.beginAddress = ParseIpAddr(poolPartArg); in PareseAddreesRange() 108 config->pool.endAddress = ParseIpAddr(poolPartArg); in PareseAddreesRange() 114 if (!config->pool.beginAddress || !config->pool.endAddress) { in PareseAddreesRange() 115 DHCP_LOGE("'pool' argument format error."); in PareseAddreesRange() 120 DHCP_LOGW("failed to get 'pool' argumen in PareseAddreesRange() [all...] |
H A D | dhcp_s_server.cpp | 583 static int CheckAddressRange(DhcpAddressPool *pool) in CheckAddressRange() argument 585 uint32_t serverNetwork = NetworkAddress(pool->serverId, pool->netmask); in CheckAddressRange() 586 uint32_t firstNetwork = NetworkAddress(pool->addressRange.beginAddress, pool->netmask); in CheckAddressRange() 587 uint32_t secondNetwork = NetworkAddress(pool->addressRange.endAddress, pool->netmask); in CheckAddressRange() 593 DHCP_LOGE("server network and address pool network belong to different networks."); in CheckAddressRange() 599 void InitBindingRecoders(DhcpAddressPool *pool) in InitBindingRecoders() argument 601 if (!pool) { in InitBindingRecoders() 624 InitLeaseFile(DhcpAddressPool *pool) InitLeaseFile() argument 799 Repending(DhcpAddressPool *pool, AddressBinding *binding) Repending() argument 832 Rebinding(DhcpAddressPool *pool, AddressBinding *binding) Rebinding() argument 896 GetBinding(DhcpAddressPool *pool, PDhcpMsgInfo received) GetBinding() argument 1043 GetYourIpAddress(PDhcpMsgInfo received, uint32_t *yourIpAddr, DhcpAddressPool *pool) GetYourIpAddress() argument 1085 NotBindingRequest(DhcpAddressPool *pool, PDhcpMsgInfo received, PDhcpMsgInfo reply) NotBindingRequest() argument [all...] |
/foundation/filemanagement/dfs_service/services/distributedfiledaemon/test/unittest/network/ |
H A D | session_pool_test.cpp | 135 shared_ptr<SessionPool> pool = make_shared<SessionPool>(kernelTalker); in HWTEST_F() local 139 pool->OccupySession(TEST_SESSION_ID, 1); in HWTEST_F() 161 shared_ptr<SessionPool> pool = make_shared<SessionPool>(kernelTalker); in HWTEST_F() local 165 pool->occupySession_.erase(TEST_SESSION_ID); in HWTEST_F() 166 pool->occupySession_.insert(make_pair(TEST_SESSION_ID, LINK_TYPE_AP)); in HWTEST_F() 167 bool flag = pool->FindSession(TEST_SESSION_ID); in HWTEST_F() 169 pool->occupySession_.erase(TEST_SESSION_ID); in HWTEST_F() 191 shared_ptr<SessionPool> pool = make_shared<SessionPool>(kernelTalker); in HWTEST_F() local 195 pool->occupySession_.erase(TEST_SESSION_ID_TWO); in HWTEST_F() 196 bool flag = pool in HWTEST_F() 221 shared_ptr<SessionPool> pool = make_shared<SessionPool>(kernelTalker); HWTEST_F() local 249 shared_ptr<SessionPool> pool = make_shared<SessionPool>(kernelTalker); HWTEST_F() local 281 shared_ptr<SessionPool> pool = make_shared<SessionPool>(kernelTalker); HWTEST_F() local 307 shared_ptr<SessionPool> pool = make_shared<SessionPool>(kernelTalker); HWTEST_F() local 353 shared_ptr<SessionPool> pool = make_shared<SessionPool>(kernelTalker); HWTEST_F() local 379 shared_ptr<SessionPool> pool = make_shared<SessionPool>(kernelTalker); HWTEST_F() local 426 shared_ptr<SessionPool> pool = make_shared<SessionPool>(kernelTalker); HWTEST_F() local 466 shared_ptr<SessionPool> pool = make_shared<SessionPool>(kernelTalker); HWTEST_F() local 494 shared_ptr<SessionPool> pool = make_shared<SessionPool>(kernelTalker); HWTEST_F() local 520 shared_ptr<SessionPool> pool = make_shared<SessionPool>(kernelTalker); HWTEST_F() local 552 shared_ptr<SessionPool> pool = make_shared<SessionPool>(kernelTalker); HWTEST_F() local 583 shared_ptr<SessionPool> pool = make_shared<SessionPool>(kernelTalker); HWTEST_F() local [all...] |
/foundation/multimedia/media_foundation/test/unittest/ |
H A D | TestBufferPool.cpp | 34 pool = std::make_shared<BufferPool<AVBuffer>>(DEFAULT_POOL_SIZE); 35 pool->Init(); 42 std::shared_ptr<BufferPool<AVBuffer>> pool; member in OHOS::Media::Test::BufferPoolTest 47 EXPECT_EQ(DEFAULT_POOL_SIZE, pool->Size()); in HWTEST_F() 52 EXPECT_EQ(DEFAULT_POOL_SIZE, pool->Size()); in HWTEST_F() 53 auto buffPtr = pool->AllocateBuffer(); in HWTEST_F() 54 EXPECT_EQ(DEFAULT_POOL_SIZE - 1, pool->Size()); in HWTEST_F() 56 EXPECT_EQ(DEFAULT_POOL_SIZE, pool->Size()); in HWTEST_F() 61 EXPECT_EQ(DEFAULT_POOL_SIZE, pool->Size()); in HWTEST_F() 65 buffers.emplace_back(pool in HWTEST_F() [all...] |
/foundation/multimedia/media_foundation/tests/unittest/avshared_memory_pool/ |
H A D | avshared_memory_pool_test.cpp | 46 std::shared_ptr<AVSharedMemoryPool> pool = std::make_shared<AVSharedMemoryPool>("releaseMemory"); in HWTEST_F() local 48 pool->ReleaseMemory(memory); in HWTEST_F() 49 bool result = pool->DoAcquireMemory(size, &memory); in HWTEST_F() 61 std::shared_ptr<AVSharedMemoryPool> pool = std::make_shared<AVSharedMemoryPool>("doAcquireMemory"); in HWTEST_F() local 63 bool result = pool->DoAcquireMemory(size, &memory); in HWTEST_F() 74 std::shared_ptr<AVSharedMemoryPool> pool = std::make_shared<AVSharedMemoryPool>("checkSize"); in HWTEST_F() local 75 EXPECT_EQ(false, pool->CheckSize(-2)); in HWTEST_F() 76 EXPECT_EQ(false, pool->CheckSize(1)); in HWTEST_F() 77 EXPECT_TRUE(pool->CheckSize(-1)); in HWTEST_F() 89 std::shared_ptr<AVSharedMemoryPool> pool in HWTEST_F() local [all...] |
/foundation/communication/dhcp/test/fuzztest/dhcpaddresspool_fuzzer/ |
H A D | dhcpaddresspool_fuzzer.cpp | 42 DhcpAddressPool pool; in DhcpAddressPoolFuzzTest() local 43 strncpy_s(pool.ifname, IFACE_NAME_SIZE, "*", IFACE_NAME_SIZE - 1); in DhcpAddressPoolFuzzTest() 44 pool.netmask = static_cast<uint32_t>(data[0]); in DhcpAddressPoolFuzzTest() 45 pool.serverId = static_cast<uint32_t>(data[0]); in DhcpAddressPoolFuzzTest() 46 pool.gateway = static_cast<uint32_t>(data[0]); in DhcpAddressPoolFuzzTest() 47 pool.leaseTime = static_cast<uint32_t>(data[0]); in DhcpAddressPoolFuzzTest() 48 pool.renewalTime = static_cast<uint32_t>(data[0]); in DhcpAddressPoolFuzzTest() 57 InitAddressPool(&pool, ifname, &options); in DhcpAddressPoolFuzzTest() 58 FreeAddressPool(&pool); in DhcpAddressPoolFuzzTest() 59 IsReservedIp(&pool, ipAd in DhcpAddressPoolFuzzTest() [all...] |
/foundation/systemabilitymgr/samgr_lite/samgr/source/ |
H A D | task_manager.c | 70 int32 SAMGR_StartTaskPool(TaskPool *pool, const char *name)
in SAMGR_StartTaskPool() argument 72 if (pool == NULL) {
in SAMGR_StartTaskPool() 76 if (pool->top > 0) {
in SAMGR_StartTaskPool() 80 ThreadAttr attr = {name, pool->stackSize, pool->priority, 0, 0};
in SAMGR_StartTaskPool() 81 while (pool->top < pool->size) {
in SAMGR_StartTaskPool() 82 register ThreadId threadId = (ThreadId)THREAD_Create(TaskEntry, pool->queueId, &attr);
in SAMGR_StartTaskPool() 84 HILOG_ERROR(HILOG_MODULE_SAMGR, "Start Task<%s, %hu, %hhu> failed!", name, pool->stackSize, pool in SAMGR_StartTaskPool() 93 SAMGR_ReleaseTaskPool(TaskPool *pool) SAMGR_ReleaseTaskPool() argument 109 SAMGR_ReferenceTaskPool(TaskPool *pool) SAMGR_ReferenceTaskPool() argument [all...] |
H A D | task_manager.h | 48 int32 SAMGR_StartTaskPool(TaskPool *pool, const char *name);
49 int32 SAMGR_ReleaseTaskPool(TaskPool *pool);
50 TaskPool *SAMGR_ReferenceTaskPool(TaskPool *pool);
|
/foundation/communication/dsoftbus/components/nstackx/fillp/src/fillp_lib/src/ |
H A D | fillp_buf_item.c | 44 void FillbufItemPoolSetConflictSafe(void *pool, FILLP_BOOL consSafe, FILLP_BOOL prodSafe) in FillbufItemPoolSetConflictSafe() argument 46 DympSetConsSafe((DympoolType *)pool, consSafe); in FillbufItemPoolSetConflictSafe() 47 DympSetProdSafe((DympoolType *)pool, prodSafe); in FillbufItemPoolSetConflictSafe() 50 int FillpMallocBufItem(void *pool, void **data, int throttleGrow) in FillpMallocBufItem() argument 52 return DympAlloc((DympoolType *)pool, data, throttleGrow); in FillpMallocBufItem() 55 int FillpAskMoreBufItem(void *pool, int stepSize, int throttleGrow) in FillpAskMoreBufItem() argument 57 return DympAskMoreMemory((DympoolType *)pool, stepSize, throttleGrow); in FillpAskMoreBufItem() 75 void FillpDestroyBufItemPool(void *pool) in FillpDestroyBufItemPool() argument 77 if (pool == FILLP_NULL_PTR) { in FillpDestroyBufItemPool() 81 DympDestroyPool((DympoolType *)pool); in FillpDestroyBufItemPool() [all...] |
/foundation/communication/dhcp/services/dhcp_server/include/ |
H A D | dhcp_address_pool.h | 31 typedef uint32_t (*Distribute)(DhcpAddressPool *pool, uint8_t macAddr[DHCP_HWADDR_LENGTH]); 56 int InitAddressPool(DhcpAddressPool *pool, const char *ifname, PDhcpOptionList options); 57 void FreeAddressPool(DhcpAddressPool *pool); 60 int IsReservedIp(DhcpAddressPool *pool, uint32_t ipAddress); 66 int AddLease(DhcpAddressPool *pool, AddressBinding *lease); 67 AddressBinding *GetLease(DhcpAddressPool *pool, uint32_t ipAddress); 68 int UpdateLease(DhcpAddressPool *pool, AddressBinding *lease); 69 int RemoveLease(DhcpAddressPool *pool, AddressBinding *lease); 70 int LoadBindingRecoders(DhcpAddressPool *pool); 71 int SaveBindingRecoders(const DhcpAddressPool *pool, in [all...] |
/foundation/communication/dsoftbus/components/nstackx/fillp/src/fillp_lib/include/ |
H A D | fillp_buf_item.h | 26 void *pool; member 29 int FillpMallocBufItem(void *pool, void **data, int throttleGrow); 30 void FillpDestroyBufItemPool(void *pool); 33 int FillpAskMoreBufItem(void *pool, int stepSize, int throttleGrow); 34 void FillbufItemPoolSetConflictSafe(void *pool, FILLP_BOOL consSafe, FILLP_BOOL prodSafe);
|
/foundation/communication/dsoftbus/components/nstackx/fillp/src/public/include/ |
H A D | dympool.h | 67 void DympDestroyPool(DympoolType *pool); 68 void DympSetConsSafe(DympoolType *pool, FILLP_BOOL safe); 69 void DympSetProdSafe(DympoolType *pool, FILLP_BOOL safe); 70 int DympAskMoreMemory(DympoolType *pool, int stepSize, int throttleGrow); 71 int DympAlloc(DympoolType *pool, void **data, int throttleGrow);
|
/foundation/arkui/ace_engine/frameworks/bridge/js_frontend/engine/jsi/ |
H A D | jsi_canvas_bridge.cpp | 227 auto task = [](const RefPtr<CanvasTaskPool>& pool) { pool->UpdateFontStyle(FontStyle::NORMAL); }; in JsParseTextState() 409 auto pool = paintChild->GetTaskPool(); in HandleWebglContext() 410 if (!pool) { in HandleWebglContext() 413 pool->WebGLInit(canvasRenderContext); in HandleWebglContext() 437 auto pool = paintChild->GetTaskPool(); in HandleWebglContext() local 438 if (!pool) { in HandleWebglContext() 443 auto weakPool = AceType::WeakClaim(AceType::RawPtr(pool)); in HandleWebglContext() 449 auto pool = weakPool.Upgrade(); in HandleWebglContext() 450 if (pool) { in HandleWebglContext() [all...] |
/foundation/graphic/graphic_2d/rosen/modules/2d_graphics/src/drawing/engine_adapter/skia_adapter/ |
H A D | skia_task_executor.cpp | 33 static TaskPoolExecutor pool; in GetInstance() local 34 return pool; in GetInstance() 44 TaskPoolExecutor* pool = this; in InitThreadPool() local 47 std::thread thread([pool, i] { in InitThreadPool() 57 pool->ThreadLoop(); in InitThreadPool()
|
/foundation/graphic/graphic_3d/lume/Lume_3D/src/gltf/ |
H A D | gltf2.cpp | 88 if (auto pool = ecs.GetThreadPool(); pool) { in CreateGLTF2Importer() 89 return CreateGLTF2Importer(ecs, *pool); in CreateGLTF2Importer() 96 IGLTF2Importer::Ptr Gltf2::CreateGLTF2Importer(IEcs& ecs, IThreadPool& pool) in CreateGLTF2Importer() argument 100 return IGLTF2Importer::Ptr { new GLTF2::GLTF2Importer(*engine_, *renderContext_, ecs, pool) }; in CreateGLTF2Importer() 124 ISceneImporter::Ptr Gltf2::CreateSceneImporter(IEcs& ecs, IThreadPool& pool) in CreateSceneImporter() argument 128 return ISceneImporter::Ptr { new GLTF2::Gltf2SceneImporter(*engine_, *renderContext_, ecs, pool) }; in CreateSceneImporter()
|
/foundation/graphic/graphic_3d/lume/LumeRender/src/vulkan/ |
H A D | gpu_memory_allocator_vk.cpp | 224 ref); // pool in ~PlatformGpuMemoryAllocator() 230 ref); // pool in ~PlatformGpuMemoryAllocator() 248 if ((result == VK_ERROR_OUT_OF_DEVICE_MEMORY) && (allocationCreateInfo.pool != VK_NULL_HANDLE)) { in CreateBuffer() 250 "Out of buffer memory with custom memory pool (i.e. block size might be exceeded), bytesize: %" PRIu64 in CreateBuffer() 251 ", falling back to default memory pool", in CreateBuffer() 254 fallBackAllocationCreateInfo.pool = VK_NULL_HANDLE; in CreateBuffer() 304 if ((result == VK_ERROR_OUT_OF_DEVICE_MEMORY) && (allocationCreateInfo.pool != VK_NULL_HANDLE)) { in CreateImage() 305 PLUGIN_LOG_D("Out of memory for image with custom memory pool (i.e. block size might be exceeded), falling " in CreateImage() 306 "back to default memory pool"); in CreateImage() 308 fallBackAllocationCreateInfo.pool in CreateImage() 437 VmaPool pool = VK_NULL_HANDLE; CreatePoolForBuffers() local 488 VmaPool pool = VK_NULL_HANDLE; CreatePoolForImages() local [all...] |
/foundation/multimedia/camera_framework/services/deferred_processing_service/src/base/task_manager/ |
H A D | thread_pool.cpp | 27 auto pool = std::make_unique<ThreadPool>(name, numThreads); in Create() local 28 if (pool) { in Create() 29 pool->Initialize(); in Create() 31 return pool; in Create() 163 DP_ERR_LOG("failed due to thread pool has been stopped."); in Submit()
|
H A D | task_registry.cpp | 47 std::shared_ptr<ITaskGroup> taskGroup = [delayTask, &name, func = std::move(func), serial, pool = threadPool_] () { in RegisterTaskGroup() 49 std::shared_ptr<ITaskGroup> ret = std::make_shared<DelayedTaskGroup>(name, std::move(func), pool); in RegisterTaskGroup() 52 std::shared_ptr<ITaskGroup> ret = std::make_shared<TaskGroup>(name, std::move(func), serial, pool); in RegisterTaskGroup()
|
/foundation/arkui/ace_engine/frameworks/core/components_ng/pattern/scrollable/ |
H A D | scrollable_item_pool.cpp | 25 static ScrollableItemPool pool(MAX_SIZE); in GetInstance() 26 return pool; in GetInstance()
|
/foundation/multimedia/av_codec/services/engine/codec/video/hcodec/ |
H A D | hcodec_dfx.cpp | 77 const vector<BufferInfo>& pool = isInput ? inputBufferPool_ : outputBufferPool_; in PrintAllBufferInfo() local 80 for (const BufferInfo& info : pool) { in PrintAllBufferInfo() 92 auto getbufferCapacity = [](const std::vector<BufferInfo> &pool) -> int32_t { in OnGetHidumperInfo() 93 IF_TRUE_RETURN_VAL(pool.empty(), 0); in OnGetHidumperInfo() 94 IF_TRUE_RETURN_VAL(pool.front().surfaceBuffer, pool.front().surfaceBuffer->GetSize()); in OnGetHidumperInfo() 95 IF_TRUE_RETURN_VAL(!(pool.front().avBuffer && pool.front().avBuffer->memory_), 0); in OnGetHidumperInfo() 96 return pool.front().avBuffer->memory_->GetCapacity(); in OnGetHidumperInfo() 132 const vector<BufferInfo>& pool in UpdateOwner() local [all...] |
/foundation/multimedia/image_framework/plugins/common/libs/image/libextplugin/src/hardware/imagecodec/ |
H A D | image_codec.cpp | 408 vector<BufferInfo>& pool = (portIndex == OMX_DirInput) ? inputBufferPool_ : outputBufferPool_; in AllocateHardwareBuffers() local 409 pool.clear(); in AllocateHardwareBuffers() 438 pool.push_back(bufInfo); in AllocateHardwareBuffers() 452 vector<BufferInfo>& pool = (portIndex == OMX_DirInput) ? inputBufferPool_ : outputBufferPool_; in AllocateSurfaceBuffers() local 453 pool.clear(); in AllocateSurfaceBuffers() 485 pool.push_back(bufInfo); in AllocateSurfaceBuffers() 520 vector<BufferInfo>& pool = (portIndex == OMX_DirInput) ? inputBufferPool_ : outputBufferPool_; in FindBufferInfoByID() local 521 for (BufferInfo &info : pool) { in FindBufferInfoByID() 532 const vector<BufferInfo>& pool = (portIndex == OMX_DirInput) ? inputBufferPool_ : outputBufferPool_; in FindBufferIndexByID() local 533 for (size_t i = 0; i < pool in FindBufferIndexByID() 737 vector<BufferInfo>& pool = (portIndex == OMX_DirInput) ? inputBufferPool_ : outputBufferPool_; ReclaimBuffer() local 752 const vector<BufferInfo>& pool = (portIndex == OMX_DirInput) ? inputBufferPool_ : outputBufferPool_; IsAllBufferOwnedByUs() local 780 const vector<BufferInfo>& pool = (portIndex == OMX_DirInput) ? inputBufferPool_ : outputBufferPool_; ClearBufferPool() local [all...] |
H A D | image_decoder.cpp | 408 vector<BufferInfo>& pool = (portIndex == OMX_DirInput) ? inputBufferPool_ : outputBufferPool_; in EraseBufferFromPool() local 409 if (i >= pool.size()) { in EraseBufferFromPool() 410 HLOGE("EraseBufferFromPool invalid params i: %{public}lu, pool size: %{public}lu", i, pool.size()); in EraseBufferFromPool() 413 BufferInfo& info = pool[i]; in EraseBufferFromPool() 415 pool.erase(pool.begin() + i); in EraseBufferFromPool()
|
/foundation/multimedia/media_foundation/engine/include/foundation/utils/ |
H A D | buffer_pool.h | 162 auto pool = weakRef.lock(); in AllocateBufferUnprotected() 163 if (pool) { in AllocateBufferUnprotected() 164 pool->RecycleBuffer(std::unique_ptr<T>(ptr)); in AllocateBufferUnprotected()
|