Home
last modified time | relevance | path

Searched refs:ABILITY_SYNC_MESSAGE (Results 1 – 10 of 10) sorted by relevance

/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/
H A Ddistributeddb_ability_sync_test.cpp134 Message msg1(ABILITY_SYNC_MESSAGE);
151 Message msg2(ABILITY_SYNC_MESSAGE);
185 Message msg1(ABILITY_SYNC_MESSAGE);
202 Message msg2(ABILITY_SYNC_MESSAGE);
236 Message msg1(ABILITY_SYNC_MESSAGE);
253 Message msg2(ABILITY_SYNC_MESSAGE);
293 Message msg1(ABILITY_SYNC_MESSAGE);
310 Message msg2(ABILITY_SYNC_MESSAGE);
351 Message msg1(ABILITY_SYNC_MESSAGE);
368 Message msg2(ABILITY_SYNC_MESSAGE);
[all …]
H A Ddistributeddb_single_ver_p2p_sync_check_test.cpp918 … if (msg->GetMessageId() != TIME_SYNC_MESSAGE && msg->GetMessageId() != ABILITY_SYNC_MESSAGE) { in RegOnDispatchWithoutDataPacket()
1781 if (msg->GetMessageId() != ABILITY_SYNC_MESSAGE) { in __anon6e997c5f2a02()
1820 if (msg->GetMessageId() != ABILITY_SYNC_MESSAGE) { in __anon6e997c5f2b02()
H A Ddistributeddb_relational_multi_user_test.cpp416 … if (msg->GetMessageId() != TIME_SYNC_MESSAGE && msg->GetMessageId() != ABILITY_SYNC_MESSAGE) { in RegOnDispatchWithoutDataPacket()
H A Ddistributeddb_mock_sync_module_test.cpp688 DistributedDB::Message msg(ABILITY_SYNC_MESSAGE);
H A Ddistributeddb_relational_ver_p2p_sync_test.cpp1470 … if (inMsg->GetMessageType() != TYPE_NOTIFY || inMsg->GetMessageId() != ABILITY_SYNC_MESSAGE) { in __anond45d0a2b1002()
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/
H A Dsync_types.h31 ABILITY_SYNC_MESSAGE, enumerator
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/
H A Dability_sync.cpp388 Message *message = new (std::nothrow) Message(ABILITY_SYNC_MESSAGE); in SyncStart()
624 return MessageTransform::RegTransformFunction(ABILITY_SYNC_MESSAGE, func); in RegisterTransformFunc()
629 if ((inMsg == nullptr) || (inMsg->GetMessageId() != ABILITY_SYNC_MESSAGE)) { in CalculateLen()
1185 Message *ackMessage = new (std::nothrow) Message(ABILITY_SYNC_MESSAGE); in SendAck()
H A Dsync_task_context.cpp435 …emoteSoftwareVersion() <= SOFTWARE_VERSION_BASE && inMsg->GetMessageId() != ABILITY_SYNC_MESSAGE) { in ReceiveMessageCallback()
H A Dsync_engine.cpp576 case ABILITY_SYNC_MESSAGE: in GetMsgSize()
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/singlever/
H A Dsingle_ver_sync_state_machine.cpp191 case ABILITY_SYNC_MESSAGE: in ReceiveMessageCallback()
948 … if (inMsg->GetMessageId() == TIME_SYNC_MESSAGE || inMsg->GetMessageId() == ABILITY_SYNC_MESSAGE || in IsPacketValid()