Home
last modified time | relevance | path

Searched refs:messageId (Results 1 - 21 of 21) sorted by relevance

/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/
H A Dvirtual_communicator_aggregator.cpp202 uint32_t messageId = inMsg->GetMessageId(); in DispatchMessageInner() local
207 bool isNeedDelay = ((sendDelayTime_ > 0) && (delayTimes_ > 0) && (messageId == delayMessageId_) && in DispatchMessageInner()
220 DelayTimeHandle(messageId, dstTarget); in DispatchMessageInner()
320 void VirtualCommunicatorAggregator::DelayTimeHandle(uint32_t messageId, const std::string &dstTarget) in DelayTimeHandle() argument
322 if ((skipTimes_ == 0) && delayTimes_ > 0 && (messageId == delayMessageId_) && in DelayTimeHandle()
326 if (skipTimes_ > 0 && (messageId == delayMessageId_) && (delayDevices_.count(dstTarget) > 0)) { in DelayTimeHandle()
H A Dvirtual_communicator_aggregator.h101 void DelayTimeHandle(uint32_t messageId, const std::string &dstTarget);
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/communicator/src/
H A Dheader_converter.cpp76 headerConverted.messageId = NetToHost(headerOriginal.messageId); in ConvertNetToHost()
H A Dframe_header.h66 uint32_t messageId = 0; // Indicate message command member
H A Dprotocol_proto.cpp174 // If messageId not register in this software version, we return errCode and the Message without an object. in ToMessage()
602 uint32_t messageId = inMsg->GetMessageId(); in CalculateDataSerializeLength() local
604 if (GetTransformFunc(messageId, function) != E_OK) { in CalculateDataSerializeLength()
605 LOGE("[Proto][CalcuDataSerialLen] Not registered for messageId=%" PRIu32 ".", messageId); in CalculateDataSerializeLength()
614 ", alignedLen=%" PRIu32 ".", messageId, serializeLen, alignedLen); in CalculateDataSerializeLength()
634 messageHdr->messageId = inMsg->GetMessageId(); in SerializeMessage()
645 // If dataLen not zero, the TransformFunc of this messageId must exist, the caller's logic guarantee it in SerializeMessage()
648 LOGE("[Proto][Serialize] Not register, messageId=%" PRIu32 ".", inMsg->GetMessageId()); in SerializeMessage()
681 inMsg->SetMessageId(messageHdr.messageId); in DeSerializeMessage()
1112 GetTransformFunc(uint32_t messageId, DistributedDB::TransformFunc &function) GetTransformFunc() argument
[all...]
H A Dprotocol_proto.h135 static int GetTransformFunc(uint32_t messageId, TransformFunc &function);
/foundation/multimodalinput/input/intention/cooperate/plugin/src/
H A Ddsoftbus_handler.cpp231 int32_t messageId = static_cast<int32_t>(packet.GetMsgId()); in OnPacket() local
232 auto it = handles_.find(messageId); in OnPacket()
237 FI_HILOGD("Unsupported messageId: %{public}d from %{public}s", messageId, in OnPacket()
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/singlever/
H A Dsingle_ver_sync_state_machine.h213 SyncType GetSyncType(uint32_t messageId) const;
H A Dsingle_ver_data_packet.cpp152 uint32_t DataRequestPacket::CalculateLen(uint32_t messageId) const in CalculateLen()
175 if (messageId == QUERY_SYNC_MESSAGE) { in CalculateLen()
H A Dsingle_ver_data_packet.h73 uint32_t CalculateLen(uint32_t messageId) const;
H A Dsingle_ver_serialize_manager.cpp756 LOGE("[SingleVerSerializeManager][RegisterTransformFunc] regist messageId %u failed %d", in RegisterCommunicatorTransformFunc()
834 uint32_t messageId = inMsg->GetMessageId(); in BuildISyncPacket() local
835 if (messageId != static_cast<uint32_t>(REMOTE_EXECUTE_MESSAGE)) { in BuildISyncPacket()
H A Dsingle_ver_sync_state_machine.cpp1159 SyncType SingleVerSyncStateMachine::GetSyncType(uint32_t messageId) const in GetSyncType()
1161 if (messageId == QUERY_SYNC_MESSAGE) { // LCOV_EXCL_BR_LINE in GetSyncType()
/foundation/graphic/graphic_2d/rosen/modules/render_service_client/core/ui/
H A Drs_ui_director.cpp384 static uint32_t messageId = 0; in ProcessMessages() local
394 auto msgId = ++messageId; in ProcessMessages()
395 RS_TRACE_NAME_FMT("RSUIDirector::ProcessMessages [messageId:%lu,cmdIndex:%llu,cmdCount:%lu]", in ProcessMessages()
399 ROSEN_LOGI("RSUIDirector::ProcessMessages messageId:%{public}d, cmdCount:%{public}lu, " in ProcessMessages()
404 RS_TRACE_NAME_FMT("RSUIDirector::ProcessMessages PostTask messageId [%lu]", msgId); in ProcessMessages()
405 ROSEN_LOGI("RSUIDirector::PostTask messageId:%{public}d, cmdCount:%{public}lu, instanceId:%{public}d", in ProcessMessages()
/foundation/communication/bluetooth_service/services/bluetooth/service/src/gatt/
H A Dgatt_connection_manager.h118 bool ProcessMessage(int messageId, int arg1 = 0, void *arg2 = nullptr);
H A Dgatt_connection_manager.cpp1203 bool GattConnectionManager::Device::ProcessMessage(int messageId, int arg1, void *arg2) in ProcessMessage() argument
1205 HILOGI("Call Massage ID: %{public}d, Device Address:[%{public}s] Transport:[%{public}d]", messageId, in ProcessMessage()
1208 return SM().ProcessMessage(utility::Message(messageId, arg1, arg2)); in ProcessMessage()
/foundation/ability/ability_runtime/services/abilitymgr/include/
H A Dability_connect_manager.h546 * @param messageId, message id.
548 void PostTimeOutTask(const std::shared_ptr<AbilityRecord> &abilityRecord, uint32_t messageId);
549 void PostTimeOutTask(const std::shared_ptr<AbilityRecord> &abilityRecord, int connectRecordId, uint32_t messageId);
H A Dability_record.h428 void PostUIExtensionAbilityTimeoutTask(uint32_t messageId);
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/communicator/
H A Dadapter_stub.cpp424 msgHeader->messageId = HostToNet(messageIdField_); in ApplySendBitError()
/foundation/ability/ability_runtime/services/abilitymgr/src/
H A Dability_connect_manager.cpp1478 void AbilityConnectManager::PostTimeOutTask(const std::shared_ptr<AbilityRecord> &abilityRecord, uint32_t messageId) in PostTimeOutTask() argument
1482 if (messageId == AbilityConnectManager::CONNECT_TIMEOUT_MSG) { in PostTimeOutTask()
1487 PostTimeOutTask(abilityRecord, connectRecordId, messageId); in PostTimeOutTask()
1491 int connectRecordId, uint32_t messageId) in PostTimeOutTask()
1498 if (messageId == AbilityManagerService::LOAD_TIMEOUT_MSG) { in PostTimeOutTask()
1500 return abilityRecord->PostUIExtensionAbilityTimeoutTask(messageId); in PostTimeOutTask()
1506 } else if (messageId == AbilityConnectManager::CONNECT_TIMEOUT_MSG) { in PostTimeOutTask()
1512 TAG_LOGE(AAFwkTag::ABILITYMGR, "messageId error"); in PostTimeOutTask()
1526 auto timeoutTask = [abilityRecord, connectManager = shared_from_this(), messageId]() { in PostTimeOutTask()
1527 if (messageId in PostTimeOutTask()
1490 PostTimeOutTask(const std::shared_ptr<AbilityRecord> &abilityRecord, int connectRecordId, uint32_t messageId) PostTimeOutTask() argument
[all...]
H A Dability_record.cpp516 void AbilityRecord::PostUIExtensionAbilityTimeoutTask(uint32_t messageId) in PostUIExtensionAbilityTimeoutTask() argument
522 TAG_LOGD(AAFwkTag::ABILITYMGR, "post timeout %{public}d, id %{public}d", messageId, recordId_); in PostUIExtensionAbilityTimeoutTask()
523 switch (messageId) { in PostUIExtensionAbilityTimeoutTask()
/foundation/ability/ability_runtime/test/unittest/ability_connect_manager_test/
H A Dability_connect_manager_test.cpp1836 uint32_t messageId = 2; in HWTEST_F() local
1837 connectManager->PostTimeOutTask(abilityRecord, messageId); in HWTEST_F()

Completed in 49 milliseconds