Home
last modified time | relevance | path

Searched refs:outs (Results 1 - 14 of 14) sorted by relevance

/foundation/resourceschedule/ffrt/src/dm/
H A Ddependence_manager.h40 inline bool CheckOutsHandle(const ffrt_deps_t* outs) in CheckOutsHandle() argument
42 if (outs == nullptr) { in CheckOutsHandle()
45 for (uint32_t i = 0; i < outs->len; i++) { in CheckOutsHandle()
46 if ((outs->items[i].type) == ffrt_dependence_task) { in CheckOutsHandle()
53 inline void OutsDedup(std::vector<const void *>& outsNoDup, const ffrt_deps_t* outs) in OutsDedup() argument
55 for (uint32_t i = 0; i < outs->len; i++) { in OutsDedup()
56 if (std::find(outsNoDup.begin(), outsNoDup.end(), outs->items[i].ptr) == outsNoDup.end()) { in OutsDedup()
57 outsNoDup.push_back(outs->items[i].ptr); in OutsDedup()
83 const ffrt_deps_t *ins, const ffrt_deps_t *outs, const task_attr_private *attr) = 0;
H A Dsdependence_manager.cpp59 void SDependenceManager::RemoveRepeatedDeps(std::vector<CPUEUTask*>& in_handles, const ffrt_deps_t* ins, const ffrt_deps_t* outs, in RemoveRepeatedDeps() argument
62 // signature去重：1）outs去重 in RemoveRepeatedDeps()
63 if (outs) { in RemoveRepeatedDeps()
64 OutsDedup(outsNoDup, outs); in RemoveRepeatedDeps()
67 // signature去重：2）ins去重（不影响功能，skip）；3）ins不和outs重复（当前不支持weak signature） in RemoveRepeatedDeps()
74 const ffrt_deps_t *ins, const ffrt_deps_t *outs, const task_attr_private *attr) in onSubmit()
76 // 0 check outs handle in onSubmit()
77 if (!CheckOutsHandle(outs)) { in onSubmit()
78 FFRT_LOGE("outs contain handles error"); in onSubmit()
108 RemoveRepeatedDeps(task->in_handles, ins, outs, insNoDu in onSubmit()
73 onSubmit(bool has_handle, ffrt_task_handle_t &handle, ffrt_function_header_t *f, const ffrt_deps_t *ins, const ffrt_deps_t *outs, const task_attr_private *attr) onSubmit() argument
[all...]
H A Dsdependence_manager.h31 const ffrt_deps_t *outs, const task_attr_private *attr) override;
51 void RemoveRepeatedDeps(std::vector<CPUEUTask*>& in_handles, const ffrt_deps_t* ins, const ffrt_deps_t* outs,
/foundation/resourceschedule/ffrt/src/core/
H A Dversion_ctx.h100 v->myProducer->outs.insert(this); in MergeProducerOutDep()
101 v->myProducer->outs.erase(v->myProducer->outs.find(v)); in MergeProducerOutDep()
H A Dversion_ctx.cpp67 producer->outs.insert(parentVersion->last); in AddProducer()
H A Dtask.cpp44 const ffrt_deps_t *ins, const ffrt_deps_t *outs, const task_attr_private *attr) in submit_impl()
46 FFRTFacade::GetDMInstance().onSubmit(has_handle, handle, f, ins, outs, attr); in submit_impl()
43 submit_impl(bool has_handle, ffrt_task_handle_t &handle, ffrt_function_header_t *f, const ffrt_deps_t *ins, const ffrt_deps_t *outs, const task_attr_private *attr) submit_impl() argument
/foundation/distributedhardware/distributed_hardware_fwk/av_transport/av_trans_handler/histreamer_ability_querier/src/
H A Dhistreamer_ability_querier.cpp42 static const std::string OUTS = "outs";
120 std::vector<AudioEncoderOut> outs; in ParseAudioEncoderOut() local
126 outs.push_back(out); in ParseAudioEncoderOut()
129 return outs; in ParseAudioEncoderOut()
149 audioEncoder.outs = ParseAudioEncoderOut(pluginInfo->outCaps); in QueryAudioEncoderAbility()
277 for (const auto &out : audioEncoder.outs) { in ToJson()
322 audioEncoder.outs.push_back(out); in FromJson()
342 std::vector<AudioDecoderOut> outs; in ParseAudioDecoderOut() local
348 outs.push_back(out); in ParseAudioDecoderOut()
351 return outs; in ParseAudioDecoderOut()
551 std::vector<VideoEncoderOut> outs; ParseVideoEncoderOut() local
748 std::vector<VideoDecoderOut> outs; ParseVideoDecoderOut() local
[all...]
/foundation/distributedhardware/distributed_hardware_fwk/av_transport/av_trans_handler/histreamer_ability_querier/include/
H A Dhistreamer_ability_querier.h54 std::vector<AudioEncoderOut> outs; member
81 std::vector<AudioDecoderOut> outs; member
107 std::vector<VideoEncoderOut> outs; member
134 std::vector<VideoDecoderOut> outs; member
/foundation/distributedhardware/distributed_hardware_fwk/utils/include/
H A Dhistreamer_ability_parser.h276 std::vector<AudioEncoderOut> outs; member
298 std::vector<AudioDecoderOut> outs; member
319 std::vector<VideoEncoderOut> outs; member
341 std::vector<VideoDecoderOut> outs; member
/foundation/distributedhardware/distributed_hardware_fwk/utils/src/
H A Dhistreamer_ability_parser.cpp26 static const std::string OUTS = "outs";
131 audioEncoder.outs.push_back(out); in FromJson()
216 audioDecoder.outs.push_back(out); in FromJson()
291 videoEncoder.outs.push_back(out); in FromJson()
378 videoDecoder.outs.push_back(out); in FromJson()
/foundation/distributedhardware/distributed_hardware_fwk/utils/test/unittest/common/histreamer_ability_parser/
H A Dhistreamer_ability_parser_test.cpp31 static const std::string OUTS = "outs";
146 EXPECT_TRUE(audioEncoder.outs.empty()); in HWTEST_F()
230 EXPECT_TRUE(audioDecoder.outs.empty()); in HWTEST_F()
309 EXPECT_TRUE(videoEncoder.outs.empty()); in HWTEST_F()
392 EXPECT_TRUE(videoDecoder.outs.empty()); in HWTEST_F()
/foundation/resourceschedule/ffrt/src/tm/
H A Dscpu_task.h26 std::unordered_set<VersionCtx*> outs; member in ffrt::SCPUEUTask
/foundation/resourceschedule/ffrt/src/sched/
H A Dscheduler.h109 for (auto data : task->outs) { in updateTask()
/foundation/distributedhardware/distributed_hardware_fwk/av_transport/av_trans_handler/histreamer_ability_querier/test/unittest/common/src/
H A Dhistreamer_ability_querier_test.cpp346 EXPECT_TRUE(audioEncoder.outs.empty()); in HWTEST_F()
439 EXPECT_TRUE(audioDecoder.outs.empty()); in HWTEST_F()
526 EXPECT_TRUE(videoEncoder.outs.empty()); in HWTEST_F()
612 EXPECT_TRUE(videoDecoder.outs.empty()); in HWTEST_F()

Completed in 8 milliseconds