| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/ |
| H A D | distributeddb_ability_sync_test.cpp | 512 EXPECT_EQ(async.AckRecv(nullptr, context), -E_INVALID_ARGS);
513 EXPECT_EQ(async.AckRecv(&msg1, nullptr), -E_INVALID_ARGS);
519 EXPECT_EQ(async.AckRecv(&msg1, context), -E_INVALID_ARGS);
537 EXPECT_EQ(async.AckRecv(&msg1, context), E_OK);
547 EXPECT_EQ(async.AckRecv(&msg1, context), E_OK);
556 EXPECT_EQ(async.AckRecv(&msg1, context), -E_VERSION_NOT_SUPPORT);
596 EXPECT_EQ(async.AckRecv(&msg1, context), -E_NOT_SUPPORT);
|
| H A D | virtual_time_sync_communicator.cpp | 109 errCode = srcTimeSync_->AckRecv(inMsg); in SendMessage()
|
| H A D | distributeddb_single_ver_p2p_complex_sync_test.cpp | 1029 EXPECT_EQ(dataSync->AckRecv(&tmpContext, nullptr), -E_INVALID_ARGS);
1030 EXPECT_EQ(dataSync->AckRecv(nullptr, nullptr), -E_INVALID_ARGS);
1031 EXPECT_EQ(dataSync->AckRecv(nullptr, &message), -E_INVALID_ARGS);
|
| H A D | distributeddb_mock_sync_module_test.cpp | 966 EXPECT_EQ(abilitySync.AckRecv(message, &syncTaskContext), -E_BUSY);
1003 EXPECT_EQ(abilitySync.AckRecv(message, &syncTaskContext), -E_BUSY);
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/ |
| H A D | time_sync.h | 89 int AckRecv(const Message *message, uint32_t targetSessionId = 0);
|
| H A D | ability_sync.h | 164 int AckRecv(const Message *message, ISyncTaskContext *context);
|
| H A D | time_sync.cpp | 369 int TimeSync::AckRecv(const Message *message, uint32_t targetSessionId) in AckRecv() function in DistributedDB::TimeSync
|
| H A D | ability_sync.cpp | 414 int AbilitySync::AckRecv(const Message *message, ISyncTaskContext *context) in AckRecv() function in DistributedDB::AbilitySync
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/singlever/ |
| H A D | single_ver_data_sync.h | 86 int AckRecv(SingleVerSyncTaskContext *context, const Message *message);
|
| H A D | single_ver_sync_state_machine.cpp | 601 int errCode = abilitySync_->AckRecv(inMsg, context_); in AbilitySyncResponseRecv()
744 int errCode = dataSync_->AckRecv(context_, inMsg); in HandleDataAckRecv()
895 int errCode = timeSync_->AckRecv(inMsg, context_->GetRequestSessionId()); in TimeMarkSyncRecv()
|
| H A D | single_ver_data_sync.cpp | 1180 int SingleVerDataSync::AckRecv(SingleVerSyncTaskContext *context, const Message *message) in AckRecv() function in DistributedDB::SingleVerDataSync
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/multiver/ |
| H A D | multi_ver_sync_state_machine.cpp | 331 errCode = timeSync_->AckRecv(inMsg); in TimeSyncPacketRecvCallback()
|