Home
last modified time | relevance | path

Searched refs:threadIndex (Results 1 - 25 of 30) sorted by relevance

12

/foundation/graphic/graphic_2d/rosen/modules/render_service/core/pipeline/
H A Drs_vk_image_manager.cpp75 pid_t threadIndex) in MapVkImageFromSurfaceBuffer()
85 return NewImageCacheFromBuffer(buffer, threadIndex); in MapVkImageFromSurfaceBuffer()
107 const sptr<OHOS::SurfaceBuffer>& buffer, pid_t threadIndex) in NewImageCacheFromBuffer()
117 imageCache->SetThreadIndex(threadIndex); in NewImageCacheFromBuffer()
137 pid_t threadIndex = UNI_RENDER_THREAD_INDEX; in UnMapVkImageFromSurfaceBuffer() local
143 threadIndex = imageCacheSeqs_[seqNum]->GetThreadIndex(); in UnMapVkImageFromSurfaceBuffer()
145 auto func = [this, seqNum, threadIndex]() { in UnMapVkImageFromSurfaceBuffer()
154 RSTaskDispatcher::GetInstance().PostTask(threadIndex, func); in UnMapVkImageFromSurfaceBuffer()
72 MapVkImageFromSurfaceBuffer( const sptr<OHOS::SurfaceBuffer>& buffer, const sptr<SyncFence>& acquireFence, pid_t threadIndex) MapVkImageFromSurfaceBuffer() argument
106 NewImageCacheFromBuffer( const sptr<OHOS::SurfaceBuffer>& buffer, pid_t threadIndex) NewImageCacheFromBuffer() argument
H A Drs_egl_image_manager.h58 void SetThreadIndex(const pid_t threadIndex) in SetThreadIndex() argument
60 threadIndex_ = threadIndex; in SetThreadIndex()
79 const sptr<SyncFence>& acquireFence, pid_t threadIndex);
88 const pid_t threadIndex);
H A Drs_vk_image_manager.h64 void SetThreadIndex(const pid_t threadIndex = UNI_RENDER_THREAD_INDEX) in SetThreadIndex()
66 threadIndex_ = threadIndex; in SetThreadIndex()
82 const sptr<SyncFence>& acquireFence, pid_t threadIndex);
90 const sptr<OHOS::SurfaceBuffer>& buffer, pid_t threadIndex);
H A Drs_egl_image_manager.cpp251 const pid_t threadIndex) in CreateImageCacheFromBuffer()
260 imageCache->SetThreadIndex(threadIndex); in CreateImageCacheFromBuffer()
285 const sptr<SyncFence>& acquireFence, pid_t threadIndex) in MapEglImageFromSurfaceBuffer()
301 return CreateImageCacheFromBuffer(buffer, threadIndex); in MapEglImageFromSurfaceBuffer()
319 pid_t threadIndex = 0; in UnMapEglImageFromSurfaceBuffer() local
326 threadIndex = imageCacheSeqs_[seqNum]->GetThreadIndex(); in UnMapEglImageFromSurfaceBuffer()
342 RSTaskDispatcher::GetInstance().PostTask(threadIndex, func); in UnMapEglImageFromSurfaceBuffer()
250 CreateImageCacheFromBuffer(const sptr<OHOS::SurfaceBuffer>& buffer, const pid_t threadIndex) CreateImageCacheFromBuffer() argument
284 MapEglImageFromSurfaceBuffer(const sptr<OHOS::SurfaceBuffer>& buffer, const sptr<SyncFence>& acquireFence, pid_t threadIndex) MapEglImageFromSurfaceBuffer() argument
H A Drs_uni_render_util.h75 bool forceCPU, uint32_t threadIndex = UNI_RENDER_THREAD_INDEX, bool useRenderParams = false);
79 const DrawableV2::RSSurfaceRenderNodeDrawable& surfaceDrawable, bool forceCPU, uint32_t threadIndex);
98 static void ClearCacheSurface(RSRenderNode& node, uint32_t threadIndex, bool isClearCompletedCacheSurface = true);
162 static void PostReleaseSurfaceTask(std::shared_ptr<Drawing::Surface>&& surface, uint32_t threadIndex);
H A Drs_uni_render_util.cpp428 const RSSurfaceRenderNode& node, bool forceCPU, uint32_t threadIndex, bool useRenderParams) in CreateBufferDrawParam()
446 params.threadIndex = threadIndex; in CreateBufferDrawParam()
491 const DrawableV2::RSSurfaceRenderNodeDrawable& surfaceDrawable, bool forceCPU, uint32_t threadIndex) in CreateBufferDrawParam()
500 params.threadIndex = threadIndex; in CreateBufferDrawParam()
547 params.threadIndex = static_cast<uint32_t>(gettid()); in CreateBufferDrawParamForRotationFixed()
1122 void RSUniRenderUtil::ClearCacheSurface(RSRenderNode& node, uint32_t threadIndex, bool isClearCompletedCacheSurface) in ClearCacheSurface() argument
1127 if (cacheSurfaceThreadIndex == threadIndex && completedSurfaceThreadIndex == threadIndex) { in ClearCacheSurface()
427 CreateBufferDrawParam( const RSSurfaceRenderNode& node, bool forceCPU, uint32_t threadIndex, bool useRenderParams) CreateBufferDrawParam() argument
490 CreateBufferDrawParam( const DrawableV2::RSSurfaceRenderNodeDrawable& surfaceDrawable, bool forceCPU, uint32_t threadIndex) CreateBufferDrawParam() argument
1146 PostReleaseSurfaceTask(std::shared_ptr<Drawing::Surface>&& surface, uint32_t threadIndex) PostReleaseSurfaceTask() argument
1169 instance->AddToReleaseQueue(std::move(surface), threadIndex); PostReleaseSurfaceTask() local
[all...]
H A Drs_divided_render_util.cpp43 params.threadIndex = gettid(); in CreateBufferDrawParam()
H A Drs_base_render_engine.cpp172 const sptr<SurfaceBuffer>& buffer, const sptr<SyncFence>& acquireFence, const uint32_t threadIndex, in CreateEglImageFromBuffer()
188 auto eglTextureId = eglImageManager_->MapEglImageFromSurfaceBuffer(buffer, acquireFence, threadIndex); in CreateEglImageFromBuffer()
661 params.acquireFence, params.threadIndex); in DrawImage()
685 image = CreateEglImageFromBuffer(canvas, params.buffer, params.acquireFence, params.threadIndex, in DrawImage()
171 CreateEglImageFromBuffer(RSPaintFilterCanvas& canvas, const sptr<SurfaceBuffer>& buffer, const sptr<SyncFence>& acquireFence, const uint32_t threadIndex, const std::shared_ptr<Drawing::ColorSpace>& drawingColorSpace) CreateEglImageFromBuffer() argument
/foundation/graphic/graphic_2d/rosen/test/render/render/unittest/drawable/
H A Drs_ui_first_render_drawable_test.cpp81 uint32_t threadIndex = 0; in HWTEST_F() local
84 auto result = surfaceDrawable_->GetCacheSurface(threadIndex, needCheckThread, releaseAfterGet); in HWTEST_F()
91 result = surfaceDrawable_->GetCacheSurface(threadIndex, needCheckThread, releaseAfterGet); in HWTEST_F()
96 surfaceDrawable_->cacheSurfaceThreadIndex_ = threadIndex; in HWTEST_F()
97 result = surfaceDrawable_->GetCacheSurface(threadIndex, needCheckThread, releaseAfterGet); in HWTEST_F()
100 ASSERT_FALSE(surfaceDrawable_->cacheSurfaceThreadIndex_ == threadIndex); in HWTEST_F()
102 result = surfaceDrawable_->GetCacheSurface(threadIndex, needCheckThread, releaseAfterGet); in HWTEST_F()
105 result = surfaceDrawable_->GetCacheSurface(threadIndex, needCheckThread, releaseAfterGet); in HWTEST_F()
132 uint32_t threadIndex = 1; in HWTEST_F() local
136 auto result = surfaceDrawable_->DrawCacheSurface(*rscanvas, boundSize, threadIndex, isUIFirs in HWTEST_F()
159 uint32_t threadIndex = 1; HWTEST_F() local
363 uint32_t threadIndex = 0; HWTEST_F() local
[all...]
/foundation/graphic/graphic_2d/rosen/test/render_service/render_service/unittest/drawable/
H A Drs_ui_first_surface_render_node_drawable_test.cpp92 uint32_t threadIndex = 0; in HWTEST_F() local
95 auto result = surfaceDrawable_->GetCacheSurface(threadIndex, needCheckThread, releaseAfterGet); in HWTEST_F()
102 result = surfaceDrawable_->GetCacheSurface(threadIndex, needCheckThread, releaseAfterGet); in HWTEST_F()
107 surfaceDrawable_->cacheSurfaceThreadIndex_ = threadIndex; in HWTEST_F()
108 result = surfaceDrawable_->GetCacheSurface(threadIndex, needCheckThread, releaseAfterGet); in HWTEST_F()
111 ASSERT_FALSE(surfaceDrawable_->cacheSurfaceThreadIndex_ == threadIndex); in HWTEST_F()
113 result = surfaceDrawable_->GetCacheSurface(threadIndex, needCheckThread, releaseAfterGet); in HWTEST_F()
116 result = surfaceDrawable_->GetCacheSurface(threadIndex, needCheckThread, releaseAfterGet); in HWTEST_F()
131 uint32_t threadIndex = 1; in HWTEST_F() local
136 auto result = surfaceDrawable_->GetCompletedImage(*rscanvas, threadIndex, isUIFirs in HWTEST_F()
160 uint32_t threadIndex = 1; HWTEST_F() local
347 uint32_t threadIndex = 0; HWTEST_F() local
[all...]
/foundation/graphic/graphic_2d/rosen/modules/render_service/core/pipeline/parallel_render/
H A Drs_sub_thread_manager.cpp58 void RSSubThreadManager::PostTask(const std::function<void()>& task, uint32_t threadIndex, bool isSyncTask) in PostTask() argument
60 if (threadIndex >= threadList_.size()) { in PostTask()
65 threadList_[threadIndex]->PostSyncTask(task); in PostTask()
67 threadList_[threadIndex]->PostTask(task); in PostTask()
174 auto threadIndex = surfaceNode->GetSubmittedSubThreadIndex(); in SubmitSubThreadTask() local
175 if (threadIndex != INT_MAX && superRenderTaskList[threadIndex]) { in SubmitSubThreadTask()
177 ", " + std::to_string(threadIndex) + " ]; "); in SubmitSubThreadTask()
178 superRenderTaskList[threadIndex]->AddTask(std::move(renderTask)); in SubmitSubThreadTask()
317 void RSSubThreadManager::ReleaseSurface(uint32_t threadIndex) cons
328 AddToReleaseQueue(std::shared_ptr<Drawing::Surface>&& surface, uint32_t threadIndex) AddToReleaseQueue() argument
[all...]
H A Drs_sub_thread_manager.h35 void PostTask(const std::function<void()>& task, uint32_t threadIndex, bool isSyncTask = false);
49 void ReleaseSurface(uint32_t threadIndex) const;
50 void AddToReleaseQueue(std::shared_ptr<Drawing::Surface>&& surface, uint32_t threadIndex);
H A Drs_sub_thread.h34 RSSubThread(RenderContext* context, uint32_t threadIndex) : threadIndex_(threadIndex), renderContext_(context) {} in RSSubThread() argument
/foundation/communication/ipc/ipc/native/src/core/source/
H A Dipc_thread_pool.cpp89 int threadIndex = 0; in SpawnThread() local
90 std::string threadName = MakeThreadName(proto, threadIndex); in SpawnThread()
108 newThread->Start(policy, proto, threadIndex); in SpawnThread()
114 std::string IPCWorkThreadPool::MakeThreadName(int proto, int &threadIndex) in MakeThreadName() argument
117 threadIndex = sequence; in MakeThreadName()
H A Dipc_workthread.cpp56 std::string IPCWorkThread::MakeBasicThreadName(int proto, int threadIndex) in MakeBasicThreadName() argument
59 return "OS_RPC_" + std::to_string(threadIndex); in MakeBasicThreadName()
61 return "OS_IPC_" + std::to_string(threadIndex); in MakeBasicThreadName()
148 void IPCWorkThread::Start(int policy, int proto, int threadIndex) in Start() argument
171 param->index = threadIndex; in Start()
/foundation/resourceschedule/ffrt/src/eu/
H A Dworker_thread.cpp55 static int threadIndex[QoS::MaxNum()] = {0}; in WorkerSetup() local
58 std::string(WORKER_THREAD_SYMBOL) + std::to_string(threadIndex[qos()]++); in WorkerSetup()
60 FFRT_LOGE("ffrt threadName qos[%d] index[%d]", qos(), threadIndex[qos()]); in WorkerSetup()
/foundation/communication/ipc/ipc/native/src/core/include/
H A Dipc_workthread.h44 static std::string MakeBasicThreadName(int proto, int threadIndex);
49 void Start(int policy, int proto, int threadIndex);
H A Dipc_thread_pool.h62 std::string MakeThreadName(int proto, int &threadIndex);
/foundation/graphic/graphic_2d/rosen/modules/render_service/core/drawable/
H A Drs_ui_first_surface_render_node_drawable.cpp73 std::shared_ptr<Drawing::Surface> RSSurfaceRenderNodeDrawable::GetCacheSurface(uint32_t threadIndex, in GetCacheSurface() argument
79 if (!needCheckThread || cacheSurfaceThreadIndex_ == threadIndex || !cacheSurface_) { in GetCacheSurface()
133 RSPaintFilterCanvas& canvas, uint32_t threadIndex, bool isUIFirst) in GetCompletedImage()
195 if (threadIndex == completedSurfaceThreadIndex_) { in GetCompletedImage()
222 uint32_t threadIndex, bool isUIFirst) in DrawCacheSurface()
229 auto cacheImage = GetCompletedImage(canvas, threadIndex, isUIFirst); in DrawCacheSurface()
257 uint32_t threadIndex, bool isNeedFP16) in InitCacheSurface()
260 cacheSurfaceThreadIndex_ = threadIndex; in InitCacheSurface()
132 GetCompletedImage( RSPaintFilterCanvas& canvas, uint32_t threadIndex, bool isUIFirst) GetCompletedImage() argument
221 DrawCacheSurface(RSPaintFilterCanvas& canvas, const Vector2f& boundSize, uint32_t threadIndex, bool isUIFirst) DrawCacheSurface() argument
256 InitCacheSurface(Drawing::GPUContext* gpuContext, ClearCacheSurfaceFunc func, uint32_t threadIndex, bool isNeedFP16) InitCacheSurface() argument
H A Drs_surface_render_node_drawable.h108 std::shared_ptr<Drawing::Surface> GetCacheSurface(uint32_t threadIndex, bool needCheckThread,
111 std::shared_ptr<Drawing::Image> GetCompletedImage(RSPaintFilterCanvas& canvas, uint32_t threadIndex,
117 uint32_t threadIndex = UNI_MAIN_THREAD_INDEX, bool isNeedFP16 = false);
149 uint32_t threadIndex = UNI_MAIN_THREAD_INDEX, bool isUIFirst = false);
H A Drs_dma_buffer_surface_render_node_drawable.cpp172 param.threadIndex = 0; in DrawDmaBufferWithGPU()
/foundation/graphic/graphic_2d/rosen/test/render_service/render_service/unittest/pipeline/
H A Drs_uni_render_util_test.cpp459 * @tc.desc: Test ClearCacheSurface when threadIndex = 0
468 uint32_t threadIndex = 0; in HWTEST_F() local
469 RSUniRenderUtil::ClearCacheSurface(*node, threadIndex); in HWTEST_F()
483 uint32_t threadIndex = UNI_MAIN_THREAD_INDEX; in HWTEST_F() local
484 RSUniRenderUtil::ClearCacheSurface(*node, threadIndex); in HWTEST_F()
487 RSUniRenderUtil::ClearCacheSurface(*node, threadIndex); in HWTEST_F()
504 uint32_t threadIndex = UNI_MAIN_THREAD_INDEX; in HWTEST_F() local
505 RSUniRenderUtil::PostReleaseSurfaceTask(std::move(surface), threadIndex); in HWTEST_F() local
506 threadIndex = UNI_RENDER_THREAD_INDEX; in HWTEST_F()
507 RSUniRenderUtil::PostReleaseSurfaceTask(std::move(surface), threadIndex); in HWTEST_F() local
522 uint32_t threadIndex = INVALID_NODEID; HWTEST_F() local
526 RSUniRenderUtil::PostReleaseSurfaceTask(std::move(surface), threadIndex); HWTEST_F() local
537 uint32_t threadIndex = 1; HWTEST_F() local
546 RSUniRenderUtil::ClearNodeCacheSurface(std::move(cacheSurface), std::move(completedSurface), threadIndex, 0); HWTEST_F() local
550 RSUniRenderUtil::ClearNodeCacheSurface(std::move(cacheSurface1), std::move(completedSurface1), threadIndex, 0); HWTEST_F() local
[all...]
/foundation/graphic/graphic_2d/rosen/test/render_service/render_service_base/unittest/pipeline/
H A Drs_base_render_node_test.cpp528 uint32_t threadIndex = 1; in HWTEST_F() local
530 node->DrawCacheSurface(paintFilterCanvas, threadIndex, isUIFirst); in HWTEST_F()
533 node->DrawCacheSurface(paintFilterCanvas, threadIndex, isUIFirst); in HWTEST_F()
536 node->DrawCacheSurface(paintFilterCanvas, threadIndex, isUIFirst); in HWTEST_F()
539 node->DrawCacheSurface(paintFilterCanvas, threadIndex, isUIFirst); in HWTEST_F()
554 uint32_t threadIndex = 1; in HWTEST_F() local
556 EXPECT_EQ(node->GetCompletedImage(paintFilterCanvas, threadIndex, isUIFirst), nullptr); in HWTEST_F()
559 EXPECT_EQ(node->GetCompletedImage(paintFilterCanvas, threadIndex, isUIFirst), nullptr); in HWTEST_F()
587 uint32_t threadIndex = 1; in HWTEST_F() local
590 ASSERT_EQ(node->GetCompletedCacheSurface(threadIndex, needCheckThrea in HWTEST_F()
628 uint32_t threadIndex = 1; HWTEST_F() local
[all...]
/foundation/arkui/napi/test/unittest/
H A Dtest_napi_threadsafe.cpp702 auto runFunc = [callbackData](const napi_env &env, int32_t threadIndex) { in CallThreadSafeWithDiffPriorityMultipleThreadTest()
703 if (threadIndex == FIRST_THREAD_INDEX) { in CallThreadSafeWithDiffPriorityMultipleThreadTest()
708 } else if (threadIndex == SECOND_THREAD_INDEX) { in CallThreadSafeWithDiffPriorityMultipleThreadTest()
710 } else if (threadIndex == THIRD_THREAD_INDEX) { in CallThreadSafeWithDiffPriorityMultipleThreadTest()
712 } else if (threadIndex == FOURTH_THREAD_INDEX) { in CallThreadSafeWithDiffPriorityMultipleThreadTest()
714 } else if (threadIndex == FIFTH_THREAD_INDEX) { in CallThreadSafeWithDiffPriorityMultipleThreadTest()
/foundation/graphic/graphic_2d/rosen/modules/render_service_base/include/pipeline/
H A Drs_render_node.h399 uint32_t threadIndex = UNI_MAIN_THREAD_INDEX);
410 std::shared_ptr<Drawing::Surface> GetCacheSurface(uint32_t threadIndex, bool needCheckThread,
415 std::shared_ptr<Drawing::Surface> GetCompletedCacheSurface(uint32_t threadIndex = UNI_MAIN_THREAD_INDEX,
426 void DrawCacheSurface(RSPaintFilterCanvas& canvas, uint32_t threadIndex = UNI_MAIN_THREAD_INDEX,
1075 RSPaintFilterCanvas& canvas, uint32_t threadIndex, bool isUIFirst);

Completed in 22 milliseconds

12