Searched refs:pipeline (Results 1 - 8 of 8) sorted by relevance
| /base/hiviewdfx/hiview/base/ |
| H A D | event_source.cpp | 33 for (auto& pipeline : listeners_) {
in PublishPipelineEvent()
34 if ((pipeline != nullptr) && (pipeline->CanProcessEvent(event))) {
in PublishPipelineEvent()
35 // one event can only be processed by on pipeline
in PublishPipelineEvent()
36 pipeline->ProcessEvent(event);
in PublishPipelineEvent()
43 void EventSource::AddPipeline(std::shared_ptr<Pipeline> pipeline)
in AddPipeline() argument
45 if (pipeline == nullptr) {
in AddPipeline()
46 HIVIEW_LOGW("Add nullptr pipeline to %{public}s.", GetName().c_str());
in AddPipeline()
49 HIVIEW_LOGD("EventSource add pipeline %{public}s.", pipeline in AddPipeline()
[all...] |
| H A D | audit_log_parser.cpp | 143 if (pipeEvent.pipeline.find(name) != std::string::npos) { in GetPipelineSummary()
282 rit->pipeline = eventElements[LOG_ELEMENT_PIPE_EVENT_PIPELINE_POS]; in ParsePipelineDoneEvent()
|
| /base/hiviewdfx/hiview/base/test/unittest/common/ |
| H A D | pipeline_test.cpp | 24 #include "pipeline.h"
69 * @tc.steps: step1. create pipeline
in DoTest()
71 auto pipeline = std::make_shared<Pipeline>("PipelineTest", pluginList);
in DoTest() local
74 * @tc.steps: step2. create pipeline event
in DoTest()
85 * @tc.steps: step3. process pipeline event
in DoTest()
87 if (pipeline->CanProcessEvent(event)) {
in DoTest()
88 pipeline->ProcessEvent(event);
in DoTest()
112 * @tc.desc: create pipeline with multiple plugins
119 * @tc.steps: step1. create pipeline
in HWTEST_F()
120 * @tc.steps: step2. create pipeline even in HWTEST_F()
193 auto pipeline = std::make_shared<Pipeline>("PipelineTest", pluginList); HWTEST_F() local
[all...] |
| /base/hiviewdfx/hiview/base/include/ |
| H A D | event_source.h | 21 #include "pipeline.h"
31 void AddPipeline(std::shared_ptr<Pipeline> pipeline);
|
| H A D | audit_log_parser.h | 52 std::string pipeline = ""; member
63 " Pipeline:" + pipeline + " TimeCost:" + std::to_string((destroyTime - createTime)) + in ToString()
78 PipelineEventInfo() : eventSerialId(0), createTime(0), destroyTime(0), creator(""), pipeline(""), digest(""){}; in PipelineEventInfo()
97 // [timestamp] [eventSerialId] [5] [pipeline]
|
| /base/hiviewdfx/hiview/build/ |
| H A D | gen_plugin_build.py | 113 for pipeline, plugin_list in pipelines.items():
114 items.append('%s:' % (pipeline))
123 for pipeline in pipeline_list:
124 items.append('%s ' % (pipeline))
272 raise Exception("[{}] not exist in pipeline".format(value))
285 for pipeline in pipeline_list:
286 if pipeline not in pipelines:
287 raise Exception("[{}] not exist in pipeline".format(pipelines))
|
| /base/hiviewdfx/hiview/service/ |
| H A D | hiview_service.cpp | 209 auto pipeline = entry.first;
in DumpPipelineUsageInfo() local
210 DumpPipelineUsageInfo(fd, pipeline);
in DumpPipelineUsageInfo()
|
| /base/hiviewdfx/hiview/core/ |
| H A D | hiview_platform.cpp | 241 HIVIEW_LOGI("Start to create pipeline %{public}s", pipelineInfo.name.c_str());
in LoadBusinessPlugin()
245 // 3. bind pipeline and call onload of event source
in LoadBusinessPlugin()
454 HIVIEW_LOGW("pipeline %{public}s already exists! create pipeline failed", pipelineInfo.name.c_str());
in CreatePipeline()
461 HIVIEW_LOGI("could not find plugin(%{public}s), skip adding to pipeline(%{public}s).",
in CreatePipeline()
468 std::shared_ptr<Pipeline> pipeline = std::make_shared<Pipeline>(pipelineInfo.name, pluginList);
in CreatePipeline() local
469 pipelines_[pipelineInfo.name] = std::move(pipeline);
in CreatePipeline()
862 HIVIEW_LOGW("Fail to find pipeline with name :%{public}s", pipelineName.c_str());
in AppendPluginToPipeline()
871 HIVIEW_LOGI("plugin %{public}s add to pipeline %{public}s succeed.", pluginName.c_str(), pipelineName.c_str());
in AppendPluginToPipeline()
|
Completed in 6 milliseconds