Home
last modified time | relevance | path

Searched refs:SetCopiedObject (Results 1 – 13 of 13) sorted by relevance

/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/
H A Ddistributeddb_ability_sync_test.cpp136 msg1.SetCopiedObject(packet1);
187 msg1.SetCopiedObject(packet1);
238 msg1.SetCopiedObject(packet1);
295 msg1.SetCopiedObject(packet1);
353 msg1.SetCopiedObject(packet1);
457 msg1.SetCopiedObject(packet1);
474 msg1.SetCopiedObject(packet1);
483 msg1.SetCopiedObject(packet1);
530 msg1.SetCopiedObject(packet1);
546 msg1.SetCopiedObject(packet1);
[all …]
H A Ddistributeddb_time_sync_test.cpp359 msg->SetCopiedObject<>(data);
370 msg->SetCopiedObject<>(data);
427 msg->SetCopiedObject<>(data);
438 msg->SetCopiedObject<>(data);
H A Ddistributeddb_multi_ver_p2p_sync_test.cpp644 oriMsgA.SetCopiedObject(packetA);
647 oriMsgB.SetCopiedObject(packetB);
810 oriMsgA.SetCopiedObject(packetA);
813 oriMsgB.SetCopiedObject(packetB);
926 oriMsgA.SetCopiedObject(packetA);
929 oriMsgB.SetCopiedObject(packetB);
1009 oriMsgA.SetCopiedObject(packetA);
1012 oriMsgB.SetCopiedObject(packetB);
1117 oriMsgA.SetCopiedObject(packetA);
1120 oriMsgB.SetCopiedObject(packetB);
H A Ddistributeddb_mock_sync_module_test.cpp694 msg.SetCopiedObject(packet);
783 message->SetCopiedObject(packet);
965 message->SetCopiedObject(packet);
997 message->SetCopiedObject(packet);
H A Ddistributeddb_single_ver_p2p_subscribe_sync_test.cpp337 msg.SetCopiedObject(packet);
H A Ddistributeddb_single_ver_p2p_query_sync_test.cpp735 msg.SetCopiedObject(packet);
H A Ddistributeddb_single_ver_p2p_complex_sync_test.cpp1090 message.SetCopiedObject(packet);
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/communicator/
H A Ddistributeddb_communicator_common.cpp83 int errCode = inMsg->SetCopiedObject(RegedTinyObject()); in RegFuncForTinyMsg()
101 int errCode = inMsg->SetCopiedObject(RegedHugeObject()); in RegFuncForHugeMsg()
165 int errCode = inMsg->SetCopiedObject(RegedOverSizeObject()); in RegFuncForOverSizeMsg()
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/
H A Dtime_sync.cpp247 int errCode = message->SetCopiedObject<>(packet); in SyncStart()
339 return inMsg->SetCopiedObject<>(packet); in DeSerialization()
366 return inMsg->SetCopiedObject<>(packet); in DeSerialization()
434 int errCode = ackMessage->SetCopiedObject<>(ackPacket); in RequestRecv()
H A Dability_sync.cpp393 errCode = message->SetCopiedObject<>(packet); in SyncStart()
1190 int errCode = ackMessage->SetCopiedObject<>(ackPacket); in SendAck()
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/communicator/include/
H A Dmessage.h60 int SetCopiedObject(const T &inObj) in SetCopiedObject() function
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/singlever/
H A Dsingle_ver_serialize_manager.cpp507 return inMsg->SetCopiedObject<>(packet); in AckPacketDeSerialization()
516 return inMsg->SetCopiedObject<>(packet); in AckPacketDeSerialization()
H A Dsingle_ver_data_sync.cpp1135 int errCode = ackMessage->SetCopiedObject(ack); in SendDataAck()
1251 int errCode = ackMessage->SetCopiedObject(ack); in SendSaveDataNotifyPacket()
1370 int errCode = ackMessage->SetCopiedObject(ack); in SendResetWatchDogPacket()
1939 int errCode = ackMessage->SetCopiedObject(ack); in SendControlAck()