| /base/hiviewdfx/hiview/test/plugins/examples/event_processor_example4/ |
| D | event_processor_example4.cpp | 39 bool EventProcessorExample4::CanProcessEvent(std::shared_ptr<Event> event) in CanProcessEvent()
41 if (event->messageType_ == Event::MessageType::FAULT_EVENT && in CanProcessEvent()
46 if (event->messageType_ == Event::MessageType::FAULT_EVENT && in CanProcessEvent()
54 bool EventProcessorExample4::OnEvent(std::shared_ptr<Event>& event) in OnEvent()
80 …GetHiviewContext()->PostUnorderedEvent(shared_from_this(), Event::Repack<Event, Event>(event, fals… in OnEvent()
100 void EventProcessorExample4::OnEventListeningCallback(const Event &msg) in OnEventListeningCallback()
|
| D | event_processor_example4.h | 25 bool CanProcessEvent(std::shared_ptr<Event> event) override;
26 bool OnEvent(std::shared_ptr<Event>& event) override;
29 void OnEventListeningCallback(const Event &msg) override;
|
| /base/hiviewdfx/hiview/base/include/ |
| D | event_dispatch_queue.h | 32 EventDispatchQueue(const std::string& name, Event::ManageType type, HiviewContext* context_);
37 void Enqueue(std::shared_ptr<Event> event);
46 void ProcessUnorderedEvent(const Event &event);
51 Event::ManageType type_;
55 std::list<std::shared_ptr<Event>> pendingEvents_;
|
| D | event.h | 32 class DllExport Event : public std::enable_shared_from_this<Event> {
34 explicit Event(const std::string &sender) in Event() function
60 explicit Event(const std::string &sender, const std::string &name) in Event() function
86 virtual ~Event() {}; in ~Event()
201 static std::shared_ptr<Derived> DownCastTo(std::shared_ptr<Event> event) in DownCastTo()
208 static std::shared_ptr<Derived> Repack(std::shared_ptr<Event>& event, bool replace = true)
228 virtual bool OnEvent(std::shared_ptr<Event>& event) = 0;
229 virtual bool OnEventProxy(std::shared_ptr<Event> event) in OnEventProxy()
234 virtual bool CanProcessEvent(std::shared_ptr<Event> event __UNUSED) in CanProcessEvent()
239 virtual bool IsInterestedPipelineEvent(std::shared_ptr<Event> event __UNUSED) in IsInterestedPipelineEvent()
[all …]
|
| D | plugin.h | 46 virtual bool OnEvent(std::shared_ptr<Event>& event) override;
51 virtual bool CanProcessEvent(std::shared_ptr<Event> event) override;
56 virtual bool IsInterestedPipelineEvent(std::shared_ptr<Event> event) override;
58 bool OnEventProxy(std::shared_ptr<Event> event) override;
83 virtual std::shared_ptr<Event> GetEvent(Event::MessageType type) in GetEvent()
85 auto event = std::make_shared<Event>(name_); in GetEvent()
94 virtual void OnEventListeningCallback(const Event &msg) in OnEventListeningCallback()
105 void DelayProcessEvent(std::shared_ptr<Event> event, uint64_t delay);
199 …virtual void PostUnorderedEvent(std::shared_ptr<Plugin> plugin __UNUSED, std::shared_ptr<Event> ev… in PostUnorderedEvent()
206 std::shared_ptr<Event> event __UNUSED) in PostSyncEventToTarget()
[all …]
|
| /base/hiviewdfx/hiview/test/plugins/examples/dynamic_load_plugin_example/ |
| D | dynamic_load_plugin_example.cpp | 25 bool DynamicLoadPluginExample::OnEvent(std::shared_ptr<Event>& event) in OnEvent()
36 AddListenerInfo(Event::PLUGIN_MAINTENANCE, {"event_test1"}); in OnLoad()
40 AddListenerInfo(OHOS::HiviewDFX::Event::MessageType::RAW_EVENT); in OnLoad()
41 AddListenerInfo(OHOS::HiviewDFX::Event::MessageType::SYS_EVENT, {"testbb"}); in OnLoad()
49 void DynamicLoadPluginExample::OnUnorderedEvent(const Event &msg) in OnUnorderedEvent()
|
| /base/hiviewdfx/hiview/test/plugins/examples/event_processor_example1/ |
| D | event_processor_example1.cpp | 37 bool EventProcessorExample1::CanProcessEvent(std::shared_ptr<Event> event) in CanProcessEvent()
44 if (event->messageType_ == Event::MessageType::FAULT_EVENT && in CanProcessEvent()
49 if (event->messageType_ == Event::MessageType::FAULT_EVENT && in CanProcessEvent()
54 if (event->messageType_ == Event::MessageType::FAULT_EVENT && in CanProcessEvent()
63 bool EventProcessorExample1::OnEvent(std::shared_ptr<Event>& event) in OnEvent()
74 void EventProcessorExample1::HandleEvent(std::shared_ptr<Event>& event) in HandleEvent()
|
| D | event_processor_example1.h | 25 bool CanProcessEvent(std::shared_ptr<Event> event) override;
26 bool OnEvent(std::shared_ptr<Event>& event) override;
31 void HandleEvent(std::shared_ptr<Event>& event);
|
| /base/hiviewdfx/hiview/plugins/reliability/bbox_detectors/test/moduletest/ |
| D | bbox_detector_module_test.cpp | 64 shared_ptr<Event> event = dynamic_pointer_cast<Event>(sysEvent);
99 shared_ptr<Event> event = dynamic_pointer_cast<Event>(sysEvent);
134 shared_ptr<Event> event = dynamic_pointer_cast<Event>(sysEvent);
168 shared_ptr<Event> event = dynamic_pointer_cast<Event>(sysEvent);
|
| /base/hiviewdfx/hiview/plugins/faultlogger/service/ |
| D | faultlogger.h | 48 bool OnEvent(std::shared_ptr<Event> &event) override;
49 bool IsInterestedPipelineEvent(std::shared_ptr<Event> event) override;
50 bool CanProcessEvent(std::shared_ptr<Event> event) override;
65 void OnUnorderedEvent(const Event &msg) override;
70 void AddFaultLogIfNeed(FaultLogInfo& info, std::shared_ptr<Event> event);
74 bool JudgmentRateLimiting(std::shared_ptr<Event> event);
|
| /base/hiviewdfx/hiview/base/ |
| D | event.cpp | 24 void Event::SetValue(const std::string &name, const std::string &value) in SetValue()
32 const std::string Event::GetValue(const std::string &name) const in GetValue()
41 void Event::SetValue(const std::string &name, int32_t value) in SetValue()
50 int32_t Event::GetIntValue(const std::string &name) const in GetIntValue()
61 void Event::ResetTimestamp() in ResetTimestamp()
66 void Event::SetKeyValuePairs(std::map<std::string, std::string> keyValuePairs) in SetKeyValuePairs()
71 std::map<std::string, std::string> Event::GetKeyValuePairs() const in GetKeyValuePairs()
|
| D | event_dispatch_queue.cpp | 31 EventDispatchQueue::EventDispatchQueue(const std::string& name, Event::ManageType type, HiviewConte… in EventDispatchQueue()
49 std::shared_ptr<Event> event = nullptr; in Run()
66 if (type_ == Event::ManageType::UNORDERED) { in Run()
76 void EventDispatchQueue::ProcessUnorderedEvent(const Event& event) in ProcessUnorderedEvent()
111 void EventDispatchQueue::Enqueue(std::shared_ptr<Event> event) in Enqueue()
|
| D | plugin.cpp | 34 bool Plugin::OnEvent(std::shared_ptr<Event>& event __UNUSED) in OnEvent()
39 bool Plugin::CanProcessEvent(std::shared_ptr<Event> event __UNUSED) in CanProcessEvent()
44 bool Plugin::IsInterestedPipelineEvent(std::shared_ptr<Event> event __UNUSED) in IsInterestedPipelineEvent()
54 bool Plugin::OnEventProxy(std::shared_ptr<Event> event) in OnEventProxy()
60 std::shared_ptr<Event> dupEvent = event; in OnEventProxy()
86 void Plugin::DelayProcessEvent(std::shared_ptr<Event> event, uint64_t delay) in DelayProcessEvent()
|
| /base/hiviewdfx/hiview/core/test/unittest/common/ |
| D | event_dispatch_queue_test.cpp | 37 std::shared_ptr<Event> EventDispatchQueueTest::CreateEvent(const std::string& name, int32_t id, in CreateEvent()
38 … const std::string& message, Event::MessageType type) in CreateEvent()
40 auto event = std::make_shared<Event>(name); in CreateEvent()
47 void ExtendEventListener::OnUnorderedEvent(const OHOS::HiviewDFX::Event& msg) in OnUnorderedEvent()
72 …auto unorderQueue = std::make_shared<EventDispatchQueue>("test1", Event::ManageType::UNORDERED, &p…
|
| /base/hiviewdfx/hiview/plugins/sys_dispatcher/ |
| D | sys_dispatcher.cpp | 32 auto notifyFunc = [&] (std::shared_ptr<Event> event) -> void { in OnLoad()
57 std::shared_ptr<SysEvent> SysEventDispatcher::Convert2SysEvent(std::shared_ptr<Event>& event) in Convert2SysEvent()
63 if (event->messageType_ != Event::MessageType::SYS_EVENT) { in Convert2SysEvent()
67 std::shared_ptr<SysEvent> sysEvent = Event::DownCastTo<SysEvent>(event); in Convert2SysEvent()
74 bool SysEventDispatcher::OnEvent(std::shared_ptr<Event> &event) in OnEvent()
|
| /base/hiviewdfx/hiview/plugins/freeze_detector/ |
| D | freeze_detector_plugin.h | 35 bool OnEvent(std::shared_ptr<Event> &event) override;
38 bool CanProcessEvent(std::shared_ptr<Event> event) override;
39 void OnEventListeningCallback(const Event& msg) override;
43 WatchPoint MakeWatchPoint(const Event& event);
|
| /base/hiviewdfx/hiview/base/test/unittest/common/ |
| D | event_loop_test.cpp | 66 bool RealEventHandler::OnEvent(std::shared_ptr<Event>& event) in OnEvent()
86 bool OverheadCalculateEventHandler::OnEvent(std::shared_ptr<Event>& event) in OnEvent()
177 auto event1 = std::make_shared<Event>("test1");
202 auto event1 = std::make_shared<Event>("test1");
203 auto event2 = std::make_shared<Event>("test2");
204 auto event3 = std::make_shared<Event>("test3");
205 auto event4 = std::make_shared<Event>("test4");
206 auto event5 = std::make_shared<Event>("test5");
207 auto event6 = std::make_shared<Event>("test6");
208 auto event7 = std::make_shared<Event>("test7");
[all …]
|
| D | event_base_test.cpp | 48 bool TestEventHandler::OnEvent(std::shared_ptr<OHOS::HiviewDFX::Event>& event) in OnEvent()
56 void TestEventListener::OnUnorderedEvent(const Event& event) in OnUnorderedEvent()
58 ASSERT_TRUE(event.messageType_ == Event::MessageType::NONE); in OnUnorderedEvent()
90 std::shared_ptr<Event> event = std::make_shared<Event>("");
105 Event event("");
136 Event event("");
|
| /base/hiviewdfx/hiview/test/plugins/examples_bundle/bundle_plugin_example3/ |
| D | bundle_plugin_example3.h | 25 bool CanProcessEvent(std::shared_ptr<Event> event) override;
26 bool OnEvent(std::shared_ptr<Event>& event) override;
29 void OnEventListeningCallback(const Event &msg) override;
|
| D | bundle_plugin_example3.cpp | 39 bool BundlePluginExample3::CanProcessEvent(std::shared_ptr<Event> event) in CanProcessEvent()
44 bool BundlePluginExample3::OnEvent(std::shared_ptr<Event>& event) in OnEvent()
62 void BundlePluginExample3::OnEventListeningCallback(const Event &msg) in OnEventListeningCallback()
|
| /base/hiviewdfx/hiview/test/plugins/examples/event_processor_example2/ |
| D | event_processor_example2.cpp | 39 bool EventProcessorExample2::CanProcessEvent(std::shared_ptr<Event> event) in CanProcessEvent()
44 bool EventProcessorExample2::OnEvent(std::shared_ptr<Event>& event) in OnEvent()
61 … auto repackEvent = PipelineEvent::RepackPipelineEvent<Event, PipelineEvent>(shared_from_this(), in OnEvent()
81 AddListenerInfo(OHOS::HiviewDFX::Event::MessageType::RAW_EVENT); in OnLoad()
90 void EventProcessorExample2::OnUnorderedEvent(const Event &msg) in OnUnorderedEvent()
|
| D | event_processor_example2.h | 25 bool CanProcessEvent(std::shared_ptr<Event> event) override;
26 bool OnEvent(std::shared_ptr<Event>& event) override;
29 void OnUnorderedEvent(const Event &msg) override;
|
| /base/hiviewdfx/hiview/include/ |
| D | plugin_extra_info.h | 37 class CapacityPublishEvent : public Event {
40 : Event(sender), pluginCapacity_(pluginCapacityInfo) {}; in CapacityPublishEvent()
45 class CapacityObtainEvent : public Event {
48 : Event(plugin), plugin_(plugin), capacity_(capacity) {}; in CapacityObtainEvent()
|
| /base/hiviewdfx/hiview/plugins/eventlogger/test/unittest/common/ |
| D | event_logger_plugin_test.cpp | 71 std::shared_ptr<Event> event = nullptr;
86 std::shared_ptr<Event> event = std::make_shared<Event>("Eventlogger002");
101 std::shared_ptr<Event> event = std::make_shared<Event>("Eventlogger003");
153 std::shared_ptr<Event> event = nullptr;
178 std::shared_ptr<Event> onEvent = std::static_pointer_cast<Event>(event);
204 std::shared_ptr<Event> onEvent = std::static_pointer_cast<Event>(event);
230 std::shared_ptr<Event> onEvent = event;
262 std::shared_ptr<Event> onEvent = event;
|
| /base/hiviewdfx/hiview/plugins/event_store/ |
| D | sys_event_store.cpp | 64 std::shared_ptr<SysEvent> SysEventStore::Convert2SysEvent(std::shared_ptr<Event>& event) in Convert2SysEvent()
70 if (event->messageType_ != Event::MessageType::SYS_EVENT) { in Convert2SysEvent()
74 std::shared_ptr<SysEvent> sysEvent = Event::DownCastTo<SysEvent>(event); in Convert2SysEvent()
81 bool SysEventStore::OnEvent(std::shared_ptr<Event>& event) in OnEvent()
|