Home
last modified time | relevance | path

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

/ohos5.0/foundation/distributedhardware/distributed_input/services/source/sourcemanager/src/
H A Ddinput_source_manager_event_handler.cpp60 nlohmann::json innerMsg = *it; in NotifyRegisterCallback() local
100 nlohmann::json innerMsg = *it; in NotifyUnregisterCallback() local
129 nlohmann::json innerMsg = *it; in NotifyPrepareCallback() local
156 nlohmann::json innerMsg = *it; in NotifyUnprepareCallback() local
183 nlohmann::json innerMsg = *it; in NotifyStartCallback() local
217 nlohmann::json innerMsg = *it; in NotifyStopCallback() local
262 nlohmann::json innerMsg = *it; in NotifyStartDhidCallback() local
289 nlohmann::json innerMsg = *it; in NotifyStopDhidCallback() local
316 nlohmann::json innerMsg = *it; in NotifyKeyStateCallback() local
346 nlohmann::json innerMsg = *it; in NotifyStartServerCallback() local
[all …]
/ohos5.0/foundation/ability/ability_lite/services/abilitymgr_lite/src/slite/
H A Djs_ability_thread.cpp128 SliteAbilityInnerMsg innerMsg; in AppTaskHandler() local
134 AbilityThread *abilityThread = innerMsg.abilityThread; in AppTaskHandler()
142 switch (innerMsg.msgId) { in AppTaskHandler()
145 abilityThread->HandleCreate(innerMsg.want); in AppTaskHandler()
147 ClearWant(innerMsg.want); in AppTaskHandler()
148 AdapterFree(innerMsg.want); in AppTaskHandler()
149 innerMsg.want = nullptr; in AppTaskHandler()
152 abilityThread->HandleForeground(innerMsg.want); in AppTaskHandler()
153 ClearWant(innerMsg.want); in AppTaskHandler()
154 AdapterFree(innerMsg.want); in AppTaskHandler()
[all …]
H A Dnative_ability_thread.cpp164 SliteAbilityInnerMsg innerMsg; in NativeAppTaskHandler() local
170 AbilityThread *abilityThread = innerMsg.abilityThread; in NativeAppTaskHandler()
178 switch (innerMsg.msgId) { in NativeAppTaskHandler()
181 abilityThread->HandleCreate(innerMsg.want); in NativeAppTaskHandler()
183 ClearWant(innerMsg.want); in NativeAppTaskHandler()
184 AdapterFree(innerMsg.want); in NativeAppTaskHandler()
185 innerMsg.want = nullptr; in NativeAppTaskHandler()
188 abilityThread->HandleForeground(innerMsg.want); in NativeAppTaskHandler()
189 ClearWant(innerMsg.want); in NativeAppTaskHandler()
190 AdapterFree(innerMsg.want); 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.msgId = (SliteAbilityMsgId)state; in SendMsgToAbilityThread()
[all …]
/ohos5.0/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()
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()
/ohos5.0/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()
/ohos5.0/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()
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()
/ohos5.0/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()
/ohos5.0/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;
/ohos5.0/foundation/ability/ability_lite/interfaces/kits/ability_lite/slite/
H A Dslite_ability.h94 virtual void HandleExtraMessage(const SliteAbilityInnerMsg &innerMsg);
/ohos5.0/foundation/ability/ability_lite/services/abilitymgr_lite/include/slite/
H A Dability_thread.h52 virtual int32_t SendScheduleMsgToAbilityThread(SliteAbilityInnerMsg &innerMsg);
/ohos5.0/foundation/ability/ability_lite/frameworks/ability_lite/src/slite/
H A Dslite_ability.cpp69 void SliteAbility::HandleExtraMessage(const SliteAbilityInnerMsg &innerMsg) in HandleExtraMessage() argument
/ohos5.0/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()
88 jsonStr[DINPUT_SOFTBUS_KEY_INPUT_DATA] = innerMsg->dump(); in ProcessEvent()
90 RecordEventLog(innerMsg); in ProcessEvent()
/ohos5.0/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()