Home
last modified time | relevance | path

Searched refs:TYPE_NOTIFY (Results 1 – 8 of 8) sorted by relevance

/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/communicator/include/
H A Dmessage.h33 constexpr uint16_t TYPE_NOTIFY = 3; variable
113 if (inMsgType != TYPE_REQUEST && inMsgType != TYPE_RESPONSE && inMsgType != TYPE_NOTIFY) { in SetMessageType()
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/communicator/
H A Ddistributeddb_communicator_common.cpp273 outMsg->SetMessageType(TYPE_NOTIFY); in BuildRegedGiantMessage()
301 outMsg->SetMessageType(TYPE_NOTIFY); in BuildRegedOverSizeMessage()
329 outMsg->SetMessageType(TYPE_NOTIFY); in BuildUnRegedTinyMessage()
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/singlever/
H A Dsingle_ver_serialize_manager.cpp59 case TYPE_NOTIFY: in DataSerialization()
105 case TYPE_NOTIFY: in DataDeSerialization()
158 case TYPE_NOTIFY: in CalculateDataLen()
183 case TYPE_NOTIFY: in CalculateControlLen()
321 if (msgType != TYPE_REQUEST && msgType != TYPE_RESPONSE && msgType != TYPE_NOTIFY) { in IsPacketValid()
H A Dsingle_ver_sync_state_machine.cpp620 if (inMsg->GetMessageType() == TYPE_NOTIFY) { in AbilitySyncResponseRecv()
771 case TYPE_NOTIFY: in DataPktRecv()
1068 if (msgType == TYPE_RESPONSE || msgType == TYPE_NOTIFY) { in IsNeedResetWatchdog()
H A Dsingle_ver_data_sync.cpp1159 if (message->GetMessageType() == TYPE_NOTIFY || message->IsFeedbackError()) { in AckPacketIdCheck()
1258 …SingleVerDataSyncUtils::SetMessageHeadInfo(*ackMessage, TYPE_NOTIFY, context->GetDeviceId(), seque… in SendSaveDataNotifyPacket()
1377 SingleVerDataSyncUtils::SetMessageHeadInfo(*ackMessage, TYPE_NOTIFY, context->GetDeviceId(), in SendResetWatchDogPacket()
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/
H A Dability_sync.cpp647 case TYPE_NOTIFY: in CalculateLen()
670 case TYPE_NOTIFY: in Serialization()
687 case TYPE_NOTIFY: in DeSerialization()
1197 …isAckNotify) ? ackMessage->SetMessageType(TYPE_RESPONSE) : ackMessage->SetMessageType(TYPE_NOTIFY); in SendAck()
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/
H A Ddistributeddb_mock_sync_module_test.cpp689 msg.SetMessageType(TYPE_NOTIFY);
754 message->SetMessageType(TYPE_NOTIFY);
811 message->SetMessageType(TYPE_NOTIFY);
H A Ddistributeddb_relational_ver_p2p_sync_test.cpp1470 … if (inMsg->GetMessageType() != TYPE_NOTIFY || inMsg->GetMessageId() != ABILITY_SYNC_MESSAGE) { in __anond45d0a2b1002()