Home
last modified time | relevance | path

Searched defs:ackMessage (Results 1 – 6 of 6) sorted by relevance

/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/
Dsingle_ver_data_sync.cpp1121 Message *ackMessage = new (std::nothrow) Message(message->GetMessageId()); in SendDataAck() local
1235 Message *ackMessage = new (std::nothrow) Message(inMsgId); in SendSaveDataNotifyPacket() local
1348 Message *ackMessage = new (std::nothrow) Message(DATA_SYNC_MESSAGE); in SendResetWatchDogPacket() local
1902 Message *ackMessage = new (std::nothrow) Message(message->GetMessageId()); in SendControlAck() local
Dtime_sync.cpp409 Message *ackMessage = new (std::nothrow) Message(TIME_SYNC_MESSAGE); in RequestRecv() local
Dvalue_slice_sync.cpp587 Message *ackMessage = new (std::nothrow) Message(VALUE_SLICE_SYNC_MESSAGE); in SendAckPacket() local
Dmulti_ver_data_sync.cpp642 Message *ackMessage = new (std::nothrow) Message(MULTI_VER_DATA_SYNC_MESSAGE); in SendAckPacket() local
Dcommit_history_sync.cpp670 Message *ackMessage = new (std::nothrow) Message(COMMIT_HISTORY_SYNC_MESSAGE); in SendAckPacket() local
Dability_sync.cpp1090 Message *ackMessage = new (std::nothrow) Message(ABILITY_SYNC_MESSAGE); in SendAck() local