Home
last modified time | relevance | path

Searched refs:innerMsg (Results 1 - 16 of 16) sorted by relevance

/foundation/distributedhardware/distributed_input/services/source/sourcemanager/src/
H A Ddinput_source_manager_event_handler.cpp60 nlohmann::json innerMsg = *it; in NotifyRegisterCallback() local
61 if (!IsString(innerMsg, INPUT_SOURCEMANAGER_KEY_DEVID) || in NotifyRegisterCallback()
62 !IsString(innerMsg, INPUT_SOURCEMANAGER_KEY_HWID) || in NotifyRegisterCallback()
63 !IsBoolean(innerMsg, INPUT_SOURCEMANAGER_KEY_RESULT)) { in NotifyRegisterCallback()
67 std::string deviceId = innerMsg[INPUT_SOURCEMANAGER_KEY_DEVID]; in NotifyRegisterCallback()
68 std::string dhId = innerMsg[INPUT_SOURCEMANAGER_KEY_HWID]; in NotifyRegisterCallback()
69 bool result = innerMsg[INPUT_SOURCEMANAGER_KEY_RESULT]; in NotifyRegisterCallback()
100 nlohmann::json innerMsg = *it; in NotifyUnregisterCallback() local
101 if (!IsString(innerMsg, INPUT_SOURCEMANAGER_KEY_DEVID) || in NotifyUnregisterCallback()
102 !IsString(innerMsg, INPUT_SOURCEMANAGER_KEY_HWI in NotifyUnregisterCallback()
129 nlohmann::json innerMsg = *it; NotifyPrepareCallback() local
156 nlohmann::json innerMsg = *it; NotifyUnprepareCallback() local
183 nlohmann::json innerMsg = *it; NotifyStartCallback() local
217 nlohmann::json innerMsg = *it; NotifyStopCallback() local
262 nlohmann::json innerMsg = *it; NotifyStartDhidCallback() local
289 nlohmann::json innerMsg = *it; NotifyStopDhidCallback() local
316 nlohmann::json innerMsg = *it; NotifyKeyStateCallback() local
346 nlohmann::json innerMsg = *it; NotifyStartServerCallback() local
369 nlohmann::json innerMsg = *it; NotifyRelayPrepareCallback() local
395 nlohmann::json innerMsg = *it; NotifyRelayUnprepareCallback() local
421 nlohmann::json innerMsg = *it; NotifyRelayPrepareRemoteInput() local
461 nlohmann::json innerMsg = *it; NotifyRelayUnprepareRemoteInput() local
497 nlohmann::json innerMsg = *it; NotifyRelayStartDhidCallback() local
525 nlohmann::json innerMsg = *it; NotifyRelayStopDhidCallback() local
553 nlohmann::json innerMsg = *it; NotifyRelayStartTypeCallback() local
581 nlohmann::json innerMsg = *it; NotifyRelayStopTypeCallback() local
[all...]
/foundation/ability/ability_lite/services/abilitymgr_lite/src/slite/
H A Djs_ability_thread.cpp128 SliteAbilityInnerMsg innerMsg; in AppTaskHandler() local
130 osStatus_t ret = osMessageQueueGet(messageQueueId, &innerMsg, &prio, osWaitForever); in AppTaskHandler()
134 AbilityThread *abilityThread = innerMsg.abilityThread; in AppTaskHandler()
142 switch (innerMsg.msgId) { in AppTaskHandler()
145 abilityThread->HandleCreate(innerMsg.want); in AppTaskHandler()
146 abilityThread->HandleRestore(innerMsg.abilitySavedData); in AppTaskHandler()
147 ClearWant(innerMsg.want); in AppTaskHandler()
148 AdapterFree(innerMsg.want); in AppTaskHandler()
149 innerMsg.want = nullptr; in AppTaskHandler()
152 abilityThread->HandleForeground(innerMsg in AppTaskHandler()
[all...]
H A Dnative_ability_thread.cpp164 SliteAbilityInnerMsg innerMsg; in NativeAppTaskHandler() local
166 osStatus_t ret = osMessageQueueGet(messageQueueId, &innerMsg, &prio, osWaitForever); in NativeAppTaskHandler()
170 AbilityThread *abilityThread = innerMsg.abilityThread; in NativeAppTaskHandler()
178 switch (innerMsg.msgId) { in NativeAppTaskHandler()
181 abilityThread->HandleCreate(innerMsg.want); in NativeAppTaskHandler()
182 abilityThread->HandleRestore(innerMsg.abilitySavedData); in NativeAppTaskHandler()
183 ClearWant(innerMsg.want); in NativeAppTaskHandler()
184 AdapterFree(innerMsg.want); in NativeAppTaskHandler()
185 innerMsg.want = nullptr; in NativeAppTaskHandler()
188 abilityThread->HandleForeground(innerMsg in NativeAppTaskHandler()
[all...]
H A Dability_thread.cpp104 int32_t AbilityThread::SendScheduleMsgToAbilityThread(SliteAbilityInnerMsg &innerMsg) in SendScheduleMsgToAbilityThread() argument
110 osStatus_t ret = osMessageQueuePut(GetMessageQueueId(), static_cast<void *>(&innerMsg), 0, 0); in SendScheduleMsgToAbilityThread()
H A Dability_record_manager.cpp1068 SliteAbilityInnerMsg innerMsg; in SendMsgToAbilityThread() local
1071 innerMsg.msgId = SliteAbilityMsgId::CREATE; in SendMsgToAbilityThread()
1072 innerMsg.want = CreateWant(record); in SendMsgToAbilityThread()
1074 innerMsg.abilitySavedData = record->abilitySavedData; in SendMsgToAbilityThread()
1078 innerMsg.msgId = SliteAbilityMsgId::FOREGROUND; in SendMsgToAbilityThread()
1079 innerMsg.want = CreateWant(record); in SendMsgToAbilityThread()
1082 innerMsg.msgId = SliteAbilityMsgId::BACKGROUND; in SendMsgToAbilityThread()
1085 innerMsg.msgId = SliteAbilityMsgId::DESTROY; in SendMsgToAbilityThread()
1087 innerMsg.abilitySavedData = record->abilitySavedData; in SendMsgToAbilityThread()
1091 innerMsg in SendMsgToAbilityThread()
[all...]
/foundation/arkui/ace_engine_lite/frameworks/tools/qt/simulator/jsfwk/targets/simulator/mock/jsthread/
H A Djs_thread.cpp105 const AbilityInnerMsg *innerMsg = GetMessage(); in HandleEventLoop() local
106 if (innerMsg == nullptr) { in HandleEventLoop()
109 // the innerMsg will be freed out of the scop in HandleEventLoop()
110 std::unique_ptr<const AbilityInnerMsg> msgGuard(innerMsg); in HandleEventLoop()
111 switch ((uint32_t)innerMsg->msgId) { in HandleEventLoop()
137 AsyncWork *work = reinterpret_cast<AsyncWork *>(innerMsg->data); in HandleEventLoop()
/foundation/arkui/ace_engine_lite/frameworks/src/core/context/
H A Dslite_ace_ability.cpp73 void SliteAceAbility::HandleExtraMessage(const AbilitySlite::SliteAbilityInnerMsg &innerMsg) in HandleExtraMessage() argument
75 switch (innerMsg.msgId) { in HandleExtraMessage()
80 auto* work = reinterpret_cast<AsyncWork *>(innerMsg.data); in HandleExtraMessage()
H A Dslite_ace_ability.h37 void HandleExtraMessage(const AbilitySlite::SliteAbilityInnerMsg &innerMsg) override;
/foundation/arkui/ace_engine_lite/frameworks/native_engine/async/
H A Djs_async_work.cpp61 AbilityInnerMsg innerMsg; in DispatchToLoop() local
62 innerMsg.msgId = msgId; in DispatchToLoop()
63 innerMsg.data = data; in DispatchToLoop()
64 int8_t ret = MessageQueueUtils::PutMessage(appQueuehandler_, static_cast<void *>(&innerMsg), 0); in DispatchToLoop()
/foundation/distributedhardware/distributed_hardware_fwk/services/distributedhardwarefwkservice/src/componentmanager/
H A Dcomponent_privacy.cpp303 cJSON *innerMsg = cJSON_GetArrayItem(dataMsg.get(), 0); in ProcessStartPage() local
304 if (!IsString(innerMsg, PRIVACY_SUBTYPE)) { in ProcessStartPage()
308 std::string subtype = cJSON_GetObjectItem(innerMsg, PRIVACY_SUBTYPE.c_str())->valuestring; in ProcessStartPage()
309 if (!IsString(innerMsg, PRIVACY_NETWORKID)) { in ProcessStartPage()
317 std::string networkId = cJSON_GetObjectItem(innerMsg, PRIVACY_NETWORKID.c_str())->valuestring; in ProcessStartPage()
329 cJSON *innerMsg = cJSON_GetArrayItem(dataMsg.get(), 0); in ProcessStopPage() local
330 if (!IsString(innerMsg, PRIVACY_SUBTYPE)) { in ProcessStopPage()
338 std::string subtype = cJSON_GetObjectItem(innerMsg, PRIVACY_SUBTYPE.c_str())->valuestring; in ProcessStopPage()
/foundation/arkui/ace_engine_lite/frameworks/tools/qt/simulator/jsfwk/targets/simulator/mock/amsthread/
H A Dams_thread.cpp86 const AMSMessage *innerMsg = GetMessage(); in run() local
87 if (innerMsg == nullptr) { in run()
91 // the innerMsg will be freed out of the scop in run()
92 std::unique_ptr<const AMSMessage> msgGuard(innerMsg); in run()
93 switch (innerMsg->command) { in run()
95 StartAbilityInner(innerMsg->path, innerMsg->bundle); in run()
99 TerminateAbilityInner(innerMsg->token); in run()
/foundation/ability/ability_lite/interfaces/kits/ability_lite/slite/
H A Dslite_ability.h94 virtual void HandleExtraMessage(const SliteAbilityInnerMsg &innerMsg);
/foundation/ability/ability_lite/services/abilitymgr_lite/include/slite/
H A Dability_thread.h52 virtual int32_t SendScheduleMsgToAbilityThread(SliteAbilityInnerMsg &innerMsg);
/foundation/ability/ability_lite/frameworks/ability_lite/src/slite/
H A Dslite_ability.cpp69 void SliteAbility::HandleExtraMessage(const SliteAbilityInnerMsg &innerMsg) in HandleExtraMessage() argument
/foundation/distributedhardware/distributed_input/services/sink/transport/src/
H A Ddistributed_input_sink_transport.cpp81 std::shared_ptr<nlohmann::json> innerMsg = event->GetSharedObject<nlohmann::json>(); in ProcessEvent() local
82 if (innerMsg == nullptr) { in ProcessEvent()
83 DHLOGE("innerMsg is null."); in ProcessEvent()
88 jsonStr[DINPUT_SOFTBUS_KEY_INPUT_DATA] = innerMsg->dump(); in ProcessEvent()
90 RecordEventLog(innerMsg); in ProcessEvent()
/foundation/distributedhardware/distributed_input/services/source/inputinject/src/
H A Ddistributed_input_node_manager.cpp215 nlohmann::json innerMsg = *(it); in ScanAllNode() local
216 std::string devId = innerMsg[INPUT_NODE_DEVID]; in ScanAllNode()
217 std::string devicedhId = innerMsg[INPUT_NODE_DHID]; in ScanAllNode()

Completed in 10 milliseconds