Home
last modified time | relevance | path

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

/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/singlever/
H A Dsingle_ver_data_sync.cpp1128 Message *ackMessage = new (std::nothrow) Message(message->GetMessageId()); in SendDataAck() local
1242 Message *ackMessage = new (std::nothrow) Message(inMsgId); in SendSaveDataNotifyPacket() local
1360 Message *ackMessage = new (std::nothrow) Message(DATA_SYNC_MESSAGE); in SendResetWatchDogPacket() local
1931 Message *ackMessage = new (std::nothrow) Message(message->GetMessageId()); in SendControlAck() local
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/multiver/
H A Dvalue_slice_sync.cpp589 Message *ackMessage = new (std::nothrow) Message(VALUE_SLICE_SYNC_MESSAGE); in SendAckPacket() local
H A Dmulti_ver_data_sync.cpp644 Message *ackMessage = new (std::nothrow) Message(MULTI_VER_DATA_SYNC_MESSAGE); in SendAckPacket() local
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/
H A Dcommit_history_sync.cpp672 Message *ackMessage = new (std::nothrow) Message(COMMIT_HISTORY_SYNC_MESSAGE); in SendAckPacket() local
H A Dtime_sync.cpp426 Message *ackMessage = new (std::nothrow) Message(TIME_SYNC_MESSAGE); in RequestRecv() local
H A Dability_sync.cpp1185 Message *ackMessage = new (std::nothrow) Message(ABILITY_SYNC_MESSAGE); in SendAck() local