Home
last modified time | relevance | path

Searched refs:RequestRecv (Results 1 – 8 of 8) sorted by relevance

/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/
H A Ddistributeddb_ability_sync_test.cpp441 EXPECT_EQ(async.RequestRecv(nullptr, context), -E_INVALID_ARGS);
442 EXPECT_EQ(async.RequestRecv(&msg1, nullptr), -E_INVALID_ARGS);
448 EXPECT_EQ(async.RequestRecv(&msg1, context), -E_INVALID_ARGS);
465 EXPECT_EQ(async.RequestRecv(&msg1, context), -E_SECURITY_OPTION_CHECK_ERROR);
475 EXPECT_EQ(async.RequestRecv(&msg1, context), -E_VERSION_NOT_SUPPORT);
484 EXPECT_EQ(async.RequestRecv(&msg1, context), -E_SECURITY_OPTION_CHECK_ERROR);
H A Dvirtual_time_sync_communicator.cpp116 errCode = dstTimeSync_->RequestRecv(msgTmp); in SendMessage()
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/
H A Dtime_sync.h91 int RequestRecv(const Message *message);
H A Dability_sync.h166 int RequestRecv(const Message *message, ISyncTaskContext *context);
H A Dtime_sync.cpp407 int TimeSync::RequestRecv(const Message *message) in RequestRecv() function in DistributedDB::TimeSync
H A Dability_sync.cpp443 int AbilitySync::RequestRecv(const Message *message, ISyncTaskContext *context) in RequestRecv() function in DistributedDB::AbilitySync
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/multiver/
H A Dmulti_ver_sync_state_machine.cpp328 errCode = timeSync_->RequestRecv(inMsg); in TimeSyncPacketRecvCallback()
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/singlever/
H A Dsingle_ver_sync_state_machine.cpp586 int errCode = abilitySync_->RequestRecv(inMsg, context_); in AbilitySyncRecv()
893 return timeSync_->RequestRecv(inMsg); in TimeMarkSyncRecv()