| /foundation/appexecfwk/standard/test/systemtest/common/ems/ems_event_handler_system_test/ |
| D | ems_event_handler_test.cpp | 248 auto handler = std::make_shared<TestEventHandler>(runner); in ProcessEventTest() local
252 handler->SendEvent(event); in ProcessEventTest()
274 auto handler = std::make_shared<EventHandler>(runner); variable
277 std::string eventName = handler->GetEventName(event001);
289 auto handler = std::make_shared<EventHandler>(runner); variable
292 std::string eventName = handler->GetEventName(event002);
304 auto handler = std::make_shared<EventHandler>(runner); variable
308 std::string eventName = handler->GetEventName(event003);
320 auto handler = std::make_shared<EventHandler>(runner); variable
324 std::string eventName = handler->GetEventName(event004);
[all …]
|
| /foundation/appexecfwk/standard/libs/test/moduletest/common/event_handler/ |
| D | event_handler_set_get_remove_module_test.cpp | 62 auto handler = std::make_shared<MyEventHandler>(nullptr); variable
63 handler->SetEventRunner(myRunner);
64 bool result = handler->SendEvent(STOP_EVENT_ID);
82 auto handler = std::make_shared<MyEventHandler>(myRunner); variable
83 handler->SetEventRunner(nullptr);
84 bool allowSend = handler->SendEvent(Random());
101 auto handler = std::make_shared<MyEventHandler>(myRunner); variable
102 auto currentRunner = handler->GetEventRunner();
118 auto handler = std::make_shared<MyEventHandler>(nullptr); variable
119 auto currentRunner = handler->GetEventRunner();
[all …]
|
| D | event_handler_send_sync_event_module_test.cpp | 33 void WaitTaskCalled(const F &f, const std::shared_ptr<EventHandler> &handler) in WaitTaskCalled() argument
36 if (handler->PostTask(f)) { in WaitTaskCalled()
62 auto handler = std::make_shared<MyEventHandler>(myRunner); in SendEventWithSmartPtr() local
69 auto task = [&handler, &result, &sharedPtr, &weakPtr, &uniquePtr, &f, smartPointerType]() { in SendEventWithSmartPtr()
72 result = handler->SendSyncEvent(RUN_EVENT_ID, sharedPtr); in SendEventWithSmartPtr()
76 result = handler->SendSyncEvent(RUN_EVENT_ID, weakPtr); in SendEventWithSmartPtr()
80 result = handler->SendSyncEvent(RUN_EVENT_ID, uniquePtr); in SendEventWithSmartPtr()
84 …result = handler->SendSyncEvent(RUN_EVENT_ID, std::unique_ptr<int, void (*)(int *)>((new int(1)), … in SendEventWithSmartPtr()
92 WaitTaskCalled(task, handler); in SendEventWithSmartPtr()
146 auto handler = std::make_shared<MyEventHandler>(myRunner); variable
[all …]
|
| D | event_handler_post_task_module_test.cpp | 64 auto handler = std::make_shared<MyEventHandler>(myRunner); variable
66 bool postResult = handler->PostTask(f, taskName, delayTime, EventQueue::Priority::LOW);
69 handler->SendEvent(STOP_EVENT_ID, param, delayTime + 1);
90 auto handler = std::make_shared<MyEventHandler>(myRunner); variable
92 bool postResult = handler->PostTask(f, delayTime, EventQueue::Priority::HIGH);
94 handler->SendEvent(STOP_EVENT_ID);
115 auto handler = std::make_shared<MyEventHandler>(myRunner); variable
117 bool postResult = handler->PostImmediateTask(f, taskName);
119 handler->SendEvent(STOP_EVENT_ID);
141 auto handler = std::make_shared<MyEventHandler>(myRunner); variable
[all …]
|
| D | event_handler_fd_listener_module_test.cpp | 93 auto handler = GetOwner(); in OnWritable() local
94 if (handler) { in OnWritable()
95 handler->RemoveFileDescriptorListener(fileDescriptor); in OnWritable()
98 handler->PostTask(f, delayTime); in OnWritable()
146 auto handler = std::make_shared<MyEventHandler>(myRunner); variable
147 … auto inResult = handler->AddFileDescriptorListener(fds[0], FILE_DESCRIPTOR_INPUT_EVENT, listener);
149 …auto outResult = handler->AddFileDescriptorListener(fds[1], FILE_DESCRIPTOR_OUTPUT_EVENT, listener…
154 handler->SendEvent(STOP_EVENT_ID, param, delayTime);
173 auto handler = std::make_shared<MyEventHandler>(myRunner); variable
176 auto inResult = handler->AddFileDescriptorListener(fd, FILE_DESCRIPTOR_INPUT_EVENT, listener);
[all …]
|
| D | event_handler_send_event_module_test.cpp | 33 auto handler = std::make_shared<MyEventHandler>(myRunner); in SendAndCheck() local
34 bool lValueResult = handler->SendEvent(event, delayTime, priority); in SendAndCheck()
37 bool rValueResult = handler->SendEvent(InnerEvent::Get(RUN_EVENT_ID), delayTime, priority); in SendAndCheck()
40 handler->SendEvent(STOP_EVENT_ID, 0, delayTime + 1); in SendAndCheck()
54 auto handler = std::make_shared<MyEventHandler>(myRunner); in SendEventWithPriority() local
61 lvalueSendResult = handler->SendHighPriorityEvent(event, delayTime); in SendEventWithPriority()
63 …handler->SendHighPriorityEvent(InnerEvent::Get(RUN_EVENT_ID, std::make_unique<int>(1)), delayTime); in SendEventWithPriority()
67 lvalueSendResult = handler->SendImmediateEvent(event); in SendEventWithPriority()
68 …rvalueSendResult = handler->SendImmediateEvent(InnerEvent::Get(RUN_EVENT_ID, std::make_unique<int>… in SendEventWithPriority()
73 handler->SendEvent(STOP_EVENT_ID); in SendEventWithPriority()
[all …]
|
| D | event_handler_send_timing_event_module_test.cpp | 43 void WaitTaskCalled(const F &f, const std::shared_ptr<EventHandler> &handler) in WaitTaskCalled() argument
48 if (handler->PostTimingTask(f, nowTime + delayTime)) { in WaitTaskCalled()
73 auto handler = std::make_shared<MyEventHandler>(myRunner); in SendEventWithSmartPtr() local
83 handler->SendTimingEvent(RUN_EVENT_ID, sharedPtr, nowTime + delayTime); in SendEventWithSmartPtr()
87 handler->SendTimingEvent(RUN_EVENT_ID, weakPtr, nowTime + delayTime); in SendEventWithSmartPtr()
91 handler->SendTimingEvent(RUN_EVENT_ID, uniquePtr, nowTime + delayTime); in SendEventWithSmartPtr()
95 handler->SendTimingEvent( in SendEventWithSmartPtr()
102 handler->SendTimingEvent(STOP_EVENT_ID, delayTime + delayTime + nowTime); in SendEventWithSmartPtr()
152 auto handler = std::make_shared<MyEventHandler>(myRunner); variable
154 bool result = handler->SendTimingEvent(nullPtr, nowTime + delayTime, EventQueue::Priority::LOW);
[all …]
|
| D | event_handler_press_module_test.cpp | 97 auto handler = GetOwner(); in OnWritable() local
98 if (handler) { in OnWritable()
99 handler->RemoveFileDescriptorListener(fileDescriptor); in OnWritable()
106 handler->PostTask(f, delayTime * (i + 1)); in OnWritable()
126 auto handler = std::make_shared<MyEventHandler>(myRunner); variable
129 bool sentResult = handler->SendEvent(RUN_EVENT_ID);
130 handler->SendEvent(STOP_EVENT_ID);
183 auto handler = std::make_shared<MyEventHandler>(myRunner); variable
185 bool sentResult = handler->SendEvent(Random() + 1);
190 handler->SendEvent(STOP_EVENT_ID);
[all …]
|
| /foundation/ace/napi/reference_manager/ |
| D | native_reference_manager.cpp | 27 for (auto handler = referenceHandlers_; handler != nullptr; handler = referenceHandlers_) { in ~NativeReferenceManager() local
28 referenceHandlers_ = handler->next; in ~NativeReferenceManager()
29 delete handler->reference; in ~NativeReferenceManager()
30 delete handler; in ~NativeReferenceManager()
45 for (auto handler = referenceHandlers_; handler != nullptr; handler = handler->next) { in ReleaseHandler() local
46 if (handler->reference == reference) { in ReleaseHandler()
48 tmp->next = handler->next; in ReleaseHandler()
50 referenceHandlers_ = handler->next; in ReleaseHandler()
52 delete handler; in ReleaseHandler()
55 tmp = handler; in ReleaseHandler()
|
| /foundation/appexecfwk/standard/test/systemtest/common/ems/ems_event_runner_system_test/ |
| D | ems_event_runner_system_test.cpp | 179 F const &f, const std::shared_ptr<EventHandler> &handler, const std::atomic<bool> &taskCalled) in WaitUntilTaskCalled() argument
184 if (handler->PostTask(f)) { in WaitUntilTaskCalled()
203 static void CreateRunnerWithName(const std::shared_ptr<EventHandler> &handler, const std::string &t… in CreateRunnerWithName() argument
221 WaitUntilTaskCalled(f, handler, taskCalled); in CreateRunnerWithName()
237 auto handler = std::make_shared<EventHandler>(runner); variable
243 handler->PostTask(task);
256 auto handler = std::make_shared<EventHandler>(runner); variable
261 handler->PostTask(task);
274 auto handler = std::make_shared<EventHandler>(runner); variable
279 handler->PostTask(task);
[all …]
|
| /foundation/appexecfwk/standard/libs/libeventhandler/test/unittest/ |
| D | lib_event_handler_checker_test.cpp | 80 auto handler = std::make_shared<EventHandler>(runner); variable
105 handler->PostTask(fs);
106 handler->PostTask(f);
108 handler->SetDeliveryTimeoutCallback(deliveryTimeoutThread);
109 handler->SetDistributeTimeoutCallback(distributeTimeoutThread);
132 auto handler = std::make_shared<EventHandler>(runner); variable
157 handler->PostTask(fs);
158 handler->PostTask(f);
160 handler->SetDeliveryTimeoutCallback(deliveryTimeoutThread);
161 handler->SetDistributeTimeoutCallback(distributeTimeoutThread);
[all …]
|
| D | lib_event_handler_event_runner_test.cpp | 43 static void WaitUntilTaskCalled(F const &f, const std::shared_ptr<EventHandler> &handler, const std… in WaitUntilTaskCalled() argument
48 if (handler->PostTask(f)) { in WaitUntilTaskCalled()
67 static void CreateRunnerWithName(const std::shared_ptr<EventHandler> &handler, const std::string &t… in CreateRunnerWithName() argument
85 WaitUntilTaskCalled(f, handler, taskCalled); in CreateRunnerWithName()
138 auto handler = std::make_shared<EventHandler>(EventRunner::Create()); variable
146 WaitUntilTaskCalled(f, handler, taskCalled);
162 auto handler = std::make_shared<EventHandler>(runner); variable
170 if (handler->PostTask(f)) {
188 auto handler = std::make_shared<EventHandler>(EventRunner::Create(threadName)); variable
194 CreateRunnerWithName(handler, threadName);
[all …]
|
| D | lib_event_handler_event_queue_test.cpp | 757 auto handler = std::make_shared<EventHandler>(runner); variable
766 if (handler->PostTask(f, REMOVE_DELAY_TIME, EventQueue::Priority::LOW)) {
767 handler->RemoveAllEvents();
785 auto handler = std::make_shared<MyEventHandler>(runner); variable
793 handler->SendEvent(event, REMOVE_DELAY_TIME, EventQueue::Priority::LOW);
794 handler->RemoveEvent(REMOVE_EVENT_ID);
812 auto handler = std::make_shared<MyEventHandler>(runner); variable
820 handler->SendEvent(event, REMOVE_DELAY_TIME, EventQueue::Priority::LOW);
821 handler->RemoveEvent(REMOVE_EVENT_ID, eventParam);
843 auto handler = std::make_shared<EventHandler>(runner); variable
[all …]
|
| /foundation/ace/ace_engine_lite/frameworks/native_engine/async/ |
| D | js_async_work.cpp | 29 void JsAsyncWork::SetAppQueueHandler(const QueueHandler handler) in SetAppQueueHandler() argument
31 appQueuehandler_ = handler; in SetAppQueueHandler()
73 bool JsAsyncWork::DispatchAsyncWork(AsyncHandler handler, void *data) in DispatchAsyncWork() argument
75 return DispatchAsyncWorkInner(nullptr, handler, data); in DispatchAsyncWork()
78 bool JsAsyncWork::DispatchAsyncWorkInner(AsyncWorkHandler workHandler, AsyncHandler handler, void *… in DispatchAsyncWorkInner() argument
80 if ((workHandler == nullptr) && (handler == nullptr)) { in DispatchAsyncWorkInner()
96 if ((handler != nullptr) && (postUITask_ != nullptr)) { in DispatchAsyncWorkInner()
97 auto task2 = [handler, data]() { in DispatchAsyncWorkInner()
98 handler(data, ERR_OK); in DispatchAsyncWorkInner()
110 asyncWork->handler = handler; in DispatchAsyncWorkInner()
[all …]
|
| D | message_queue_utils.cpp | 40 int8_t MessageQueueUtils::DeleteMessageQueue(QueueHandler handler) in DeleteMessageQueue() argument
42 if (handler == nullptr) { in DeleteMessageQueue()
50 osMessageQueueId_t queueId = static_cast<osMessageQueueId_t>(handler); in DeleteMessageQueue()
59 int8_t MessageQueueUtils::PutMessage(QueueHandler handler, const void* msgPtr, uint32_t timeOut) in PutMessage() argument
61 if ((handler == nullptr) || (msgPtr == nullptr)) { in PutMessage()
69 osMessageQueueId_t queueId = static_cast<osMessageQueueId_t>(handler); in PutMessage()
79 int8_t MessageQueueUtils::GetMessage(QueueHandler handler, void* msgPtr, uint32_t timeOut) in GetMessage() argument
81 if ((handler == nullptr) || (msgPtr == nullptr)) { in GetMessage()
89 osMessageQueueId_t queueId = static_cast<osMessageQueueId_t>(handler); in GetMessage()
|
| /foundation/communication/netmanager_base/test/netconnmanager/unittest/net_conn_manager_test/ |
| D | net_handle_test.cpp | 45 auto handler = DelayedSingleton<NetHandle>::GetInstance(); variable
46 handler->SetNetId(netId);
47 int32_t result = handler->BindSocket(socket_fd);
56 auto handler = DelayedSingleton<NetHandle>::GetInstance(); variable
57 handler->SetNetId(netId);
58 handler->GetAddressesByName(host, addrList);
66 auto handler = DelayedSingleton<NetHandle>::GetInstance(); variable
67 handler->SetNetId(netId);
68 handler->GetAddressByName(host, addr);
|
| /foundation/ai/engine/services/common/platform/os_wrapper/audio_loader/source/ |
| D | audio_wrapper.cpp | 49 int32_t AudioWrapper::Init(ConvertType typeId, intptr_t &handler) in Init() argument
51 if (handler != INVALID_HANDLER) { in Init()
61 InitAudioDecoder(handler); in Init()
72 void AudioWrapper::InitAudioDecoder(intptr_t &handler) in InitAudioDecoder() argument
80 handler = (intptr_t)(converter); in InitAudioDecoder()
81 coders_.emplace(handler, converter); in InitAudioDecoder()
101 int32_t AudioWrapper::Deinit(intptr_t handler) in Deinit() argument
104 auto iter = coders_.find(handler); in Deinit()
122 int32_t AudioWrapper::SetConfig(intptr_t handler, const CoderConfig &config) in SetConfig() argument
125 auto iter = coders_.find(handler); in SetConfig()
[all …]
|
| /foundation/ace/ace_engine/frameworks/core/event/ |
| D | event_trigger.h | 28 void RegisterEventHandler(const RefPtr<AceEventHandler>& handler) in RegisterEventHandler() argument
30 handler_ = handler; in RegisterEventHandler()
43 auto handler = handler_.Upgrade(); in TriggerAsyncEvent() local
44 if (!handler) { in TriggerAsyncEvent()
48 handler->HandleAsyncEvent(marker, std::forward<Args>(args)...); in TriggerAsyncEvent()
62 auto handler = handler_.Upgrade(); in TriggerSyncEvent() local
63 if (!handler) { in TriggerSyncEvent()
67 handler->HandleSyncEvent(marker, std::forward<Args>(args)...); in TriggerSyncEvent()
|
| /foundation/ace/ace_engine_lite/frameworks/tools/qt/simulator/jsfwk/targets/simulator/mock/ |
| D | message_queue_utils.cpp | 34 int8_t MessageQueueUtils::DeleteMessageQueue(QueueHandler handler) in DeleteMessageQueue() argument
36 (void)(handler); in DeleteMessageQueue()
41 int8_t MessageQueueUtils::PutMessage(QueueHandler handler, const void *msgPtr, uint32_t timeOut) in PutMessage() argument
44 if ((handler == nullptr) || (msgPtr == nullptr)) { in PutMessage()
56 JSThread *eventLoopOwner = static_cast<JSThread *>(handler); in PutMessage()
61 int8_t MessageQueueUtils::GetMessage(QueueHandler handler, void *msgPtr, uint32_t timeOut) in GetMessage() argument
63 (void)(handler); in GetMessage()
|
| /foundation/communication/dsoftbus/adapter/common/bus_center/include/ |
| D | lnn_event_monitor_impl.h | 46 typedef int32_t (*LnnInitEventMonitorImpl)(LnnMonitorEventHandler handler);
48 int32_t LnnInitNetlinkMonitorImpl(LnnMonitorEventHandler handler);
50 int32_t LnnInitProductMonitorImpl(LnnMonitorEventHandler handler);
52 int32_t LnnInitLwipMonitorImpl(LnnMonitorEventHandler handler);
54 int32_t LnnInitWifiServiceMonitorImpl(LnnMonitorEventHandler handler);
56 int32_t LnnInitDriverMonitorImpl(LnnMonitorEventHandler handler);
|
| /foundation/distributeddatamgr/objectstore/frameworks/jskitsimpl/src/adaptor/ |
| D | js_watcher.cpp | 42 bool JSWatcher::On(const char *type, napi_value handler) in On() argument
49 return listener->Add(env_, handler); in On()
52 void JSWatcher::Off(const char *type, napi_value handler) in Off() argument
59 if (handler == nullptr) { in Off()
62 listener->Del(env_, handler); in Off()
107 for (EventHandler *handler = listener->handlers_; handler != nullptr; handler = handler->next) { in Emit() local
108 ChangeArgs *changeArgs = new ChangeArgs(handler->callbackRef, sessionId, changeData); in Emit()
173 for (EventHandler *handler = listener->handlers_; handler != nullptr; handler = handler->next) { in Emit() local
174 StatusArgs *changeArgs = new StatusArgs(handler->callbackRef, sessionId, networkId, status); in Emit()
180 EventHandler *EventListener::Find(napi_env env, napi_value handler) in Find() argument
[all …]
|
| /foundation/appexecfwk/standard/test/systemtest/common/ems/ems_dumper_system_test/ |
| D | ems_dumper_system_test.cpp | 188 auto handler = std::make_shared<EventHandler>(runner); variable
192 handler->Dump(dump001);
205 auto handler = std::make_shared<EventHandler>(runner); variable
208 handler->PostTask(task, DELAY_TIME, EventQueue::Priority::LOW);
210 handler->Dump(dump002);
223 auto handler = std::make_shared<EventHandler>(runner); variable
226 handler->SendEvent(event, DELAY_TIME, EventQueue::Priority::LOW);
228 handler->Dump(dump003);
241 auto handler = std::make_shared<EventHandler>(runner); variable
244 handler->SendEvent(event, DELAY_TIME, EventQueue::Priority::LOW);
[all …]
|
| /foundation/ai/engine/services/common/platform/os_wrapper/audio_loader/include/ |
| D | audio_wrapper.h | 34 int32_t Init(ConvertType typeId, intptr_t &handler);
40 int32_t SetConfig(intptr_t handler, const CoderConfig &config);
43 int32_t StartCodec(intptr_t handler);
46 int32_t Convert(intptr_t handler, const CoderStream &source, CoderStream &converted);
49 int32_t Deinit(intptr_t handler);
55 void InitAudioDecoder(intptr_t &handler);
|
| /foundation/multimedia/histreamer/engine/plugin/core/ |
| D | plugin_loader.cpp | 33 PluginLoader::PluginLoader(void* handler, std::string name) : handler_(handler), name_(std::move(na… in PluginLoader() argument
77 std::shared_ptr<PluginLoader> PluginLoader::CheckSymbol(void* handler, const std::string& name) in CheckSymbol() argument
79 if (handler) { in CheckSymbol()
85 registerFunc = (RegisterFunc)(::GetProcAddress((HMODULE)handler, registerFuncName.c_str())); in CheckSymbol()
86 … unregisterFunc = (UnregisterFunc)(::GetProcAddress((HMODULE)handler, unregisterFuncName.c_str())); in CheckSymbol()
88 registerFunc = (RegisterFunc)(::dlsym(handler, registerFuncName.c_str())); in CheckSymbol()
89 unregisterFunc = (UnregisterFunc)(::dlsym(handler, unregisterFuncName.c_str())); in CheckSymbol()
92 std::shared_ptr<PluginLoader> loader(new PluginLoader(handler, name)); in CheckSymbol()
|
| /foundation/distributedhardware/distributedhardwarefwk/utils/include/eventbus/ |
| D | event_registration.h | 30 …EventRegistration(void * const handler, EventSender * const sender) : handler(handler), sender(sen… in EventRegistration() argument
36 return handler; in GetHandler()
45 void * const handler;
|