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/device/singlever/
Dsingle_ver_data_sync.cpp1139 Message *ackMessage = new (std::nothrow) Message(message->GetMessageId()); in SendDataAck() local
1253 Message *ackMessage = new (std::nothrow) Message(inMsgId); in SendSaveDataNotifyPacket() local
1371 Message *ackMessage = new (std::nothrow) Message(DATA_SYNC_MESSAGE); in SendResetWatchDogPacket() local
1953 Message *ackMessage = new (std::nothrow) Message(message->GetMessageId()); in SendControlAck() local
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/multiver/
Dvalue_slice_sync.cpp589 Message *ackMessage = new (std::nothrow) Message(VALUE_SLICE_SYNC_MESSAGE); in SendAckPacket() local
Dmulti_ver_data_sync.cpp644 Message *ackMessage = new (std::nothrow) Message(MULTI_VER_DATA_SYNC_MESSAGE); in SendAckPacket() local
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/
Dcommit_history_sync.cpp672 Message *ackMessage = new (std::nothrow) Message(COMMIT_HISTORY_SYNC_MESSAGE); in SendAckPacket() local
Dtime_sync.cpp426 Message *ackMessage = new (std::nothrow) Message(TIME_SYNC_MESSAGE); in RequestRecv() local
Dability_sync.cpp1185 Message *ackMessage = new (std::nothrow) Message(ABILITY_SYNC_MESSAGE); in SendAck() local