Home
last modified time | relevance | path

Searched defs:ackCode (Results 1 – 7 of 7) sorted by relevance

/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/
Dvalue_slice_sync.cpp360 int32_t ackCode = packet->GetErrCode(); in RequestPacketSerialization() local
380 int ackCode = 0; in RequestPacketDeSerialization() local
433 int32_t ackCode = 0; in AckPacketSerialization() local
454 int32_t ackCode = 0; in AckPacketDeSerialization() local
579 int ackCode, const Message *message) in SendAckPacket()
Dability_sync.cpp201 void AbilitySyncAckPacket::SetAckCode(int32_t ackCode) in SetAckCode()
470 int ackCode = errCode; in AckNotifyRecv() local
843 int32_t ackCode = E_OK; in AckPacketDeSerialization() local
931 int AbilitySync::SetAbilityAckBodyInfo(AbilitySyncAckPacket &ackPacket, int ackCode, bool isAckNoti… in SetAbilityAckBodyInfo()
1004 int ackCode = packet->GetAckCode(); in AckMsgCheck() local
1033 int ackCode; in HandleRequestRecv() local
1060 int AbilitySync::SendAck(const Message *message, int ackCode, bool isAckNotify, AbilitySyncAckPacke… in SendAck()
1076 int AbilitySync::SendAckWithEmptySchema(const Message *message, int ackCode, in SendAckWithEmptySchema()
Dremote_executor_packet.cpp238 void RemoteExecutorAckPacket::SetAckCode(int32_t ackCode) in SetAckCode()
Dmulti_ver_data_sync.cpp383 int32_t ackCode = packet->GetErrCode(); in RequestPacketSerialization() local
Dcommit_history_sync.cpp659 std::vector<MultiVerCommitNode> &commits, int ackCode, const Message *message) in SendAckPacket()
Dsingle_ver_sync_state_machine.cpp609 int ackCode = packet->GetAckCode(); in AbilitySyncRecv() local
Dsingle_ver_data_sync.cpp845 int ackCode = E_OK; in PullResponseStart() local
1071 int SingleVerDataSync::SendPullResponseDataPkt(int ackCode, SyncEntry &syncOutData, in SendPullResponseDataPkt()