Home
last modified time | relevance | path

Searched refs:SetMessageId (Results 1 – 11 of 11) sorted by relevance

/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/
H A Ddistributeddb_multi_ver_p2p_sync_test.cpp645 oriMsgA.SetMessageId(TIME_SYNC_MESSAGE);
648 oriMsgB.SetMessageId(TIME_SYNC_MESSAGE);
674 outMsgA.SetMessageId(TIME_SYNC_MESSAGE);
687 outMsgB.SetMessageId(TIME_SYNC_MESSAGE);
811 oriMsgA.SetMessageId(COMMIT_HISTORY_SYNC_MESSAGE);
814 oriMsgB.SetMessageId(COMMIT_HISTORY_SYNC_MESSAGE);
840 outMsgA.SetMessageId(COMMIT_HISTORY_SYNC_MESSAGE);
853 outMsgB.SetMessageId(COMMIT_HISTORY_SYNC_MESSAGE);
927 oriMsgA.SetMessageId(COMMIT_HISTORY_SYNC_MESSAGE);
930 oriMsgB.SetMessageId(COMMIT_HISTORY_SYNC_MESSAGE);
[all …]
H A Ddistributeddb_time_sync_test.cpp340 msg->SetMessageId(TIME_SYNC_MESSAGE);
357 msg->SetMessageId(DATA_SYNC_MESSAGE);
368 msg->SetMessageId(TIME_SYNC_MESSAGE);
408 msg->SetMessageId(TIME_SYNC_MESSAGE);
425 msg->SetMessageId(DATA_SYNC_MESSAGE);
436 msg->SetMessageId(TIME_SYNC_MESSAGE);
H A Ddistributeddb_single_ver_p2p_subscribe_sync_test.cpp285 msg.SetMessageId(CONTROL_SYNC_MESSAGE);
301 outMsg.SetMessageId(CONTROL_SYNC_MESSAGE);
338 msg.SetMessageId(CONTROL_SYNC_MESSAGE);
355 outMsg.SetMessageId(CONTROL_SYNC_MESSAGE);
H A Ddistributeddb_single_ver_p2p_query_sync_test.cpp643 msg.SetMessageId(QUERY_SYNC_MESSAGE);
736 msg.SetMessageId(QUERY_SYNC_MESSAGE);
753 outMsg.SetMessageId(QUERY_SYNC_MESSAGE);
H A Ddistributeddb_relational_ver_p2p_sync_test.cpp2129 inMsg->SetMessageId(INVALID_MESSAGE_ID); in __anond45d0a2b1902()
2166 inMsg->SetMessageId(INVALID_MESSAGE_ID); in __anond45d0a2b1b02()
2192 inMsg->SetMessageId(INVALID_MESSAGE_ID); in __anond45d0a2b1c02()
2258 inMsg->SetMessageId(INVALID_MESSAGE_ID); in __anond45d0a2b1f02()
2301 inMsg->SetMessageId(INVALID_MESSAGE_ID); in __anond45d0a2b2102()
H A Ddistributeddb_single_ver_p2p_sync_check_test.cpp788 inMsg->SetMessageId(INVALID_MESSAGE_ID); in RegOnDispatchWithOffline()
801 inMsg->SetMessageId(INVALID_MESSAGE_ID); in RegOnDispatchWithInvalidMsg()
1303 inMsg->SetMessageId(INVALID_MESSAGE_ID); in RegOnDispatchWithInvalidMsgAndCnt()
H A Ddistributeddb_single_ver_p2p_complex_sync_test.cpp434 msg->SetMessageId(INVALID_MESSAGE_ID); in __anonb4f3bed90502()
622 msg->SetMessageId(INVALID_MESSAGE_ID); in __anonb4f3bed91102()
2305 msg->SetMessageId(INVALID_MESSAGE_ID); in __anonb4f3bed91d02()
H A Ddistributeddb_mock_sync_module_test.cpp1216 message->SetMessageId(LOCAL_DATA_CHANGED); in __anon34a84a721302()
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/communicator/include/
H A Dmessage.h120 void SetMessageId(uint32_t inMessageId) in SetMessageId() function
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/
H A Ddevice_manager.cpp151 msg->SetMessageId(LOCAL_DATA_CHANGED); in SendLocalDataChanged()
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/communicator/src/
H A Dprotocol_proto.cpp681 inMsg->SetMessageId(messageHdr.messageId); in DeSerializeMessage()