/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/ |
H A D | virtual_time_sync_communicator.cpp | 54 uint32_t VirtualTimeSyncCommunicator::GetCommunicatorMtuSize() const in GetCommunicatorMtuSize() function in DistributedDB::VirtualTimeSyncCommunicator 59 uint32_t VirtualTimeSyncCommunicator::GetCommunicatorMtuSize(const std::string &target) const in GetCommunicatorMtuSize() function in DistributedDB::VirtualTimeSyncCommunicator 61 return GetCommunicatorMtuSize(); in GetCommunicatorMtuSize()
|
H A D | mock_communicator.h | 29 MOCK_CONST_METHOD0(GetCommunicatorMtuSize, uint32_t(void)); 30 MOCK_CONST_METHOD1(GetCommunicatorMtuSize, uint32_t(const std::string &));
|
H A D | distributeddb_communicator_proxy_test.cpp | 233 EXPECT_CALL(mainComm_, GetCommunicatorMtuSize()).WillOnce(Return(DBConstant::MIN_MTU_SIZE)); 234 EXPECT_EQ(commProxy_->GetCommunicatorMtuSize(), DBConstant::MIN_MTU_SIZE); 240 …EXPECT_CALL(extComm_, GetCommunicatorMtuSize(DEVICE_C)).WillOnce(Return(DBConstant::MAX_MTU_SIZE)); 241 EXPECT_EQ(commProxy_->GetCommunicatorMtuSize(DEVICE_C), DBConstant::MAX_MTU_SIZE);
|
H A D | virtual_time_sync_communicator.h | 48 uint32_t GetCommunicatorMtuSize() const override; 49 uint32_t GetCommunicatorMtuSize(const std::string &target) const override;
|
H A D | virtual_communicator.cpp | 125 uint32_t VirtualCommunicator::GetCommunicatorMtuSize() const in GetCommunicatorMtuSize() function in DistributedDB::VirtualCommunicator 130 uint32_t VirtualCommunicator::GetCommunicatorMtuSize(const std::string &target) const in GetCommunicatorMtuSize() function in DistributedDB::VirtualCommunicator 132 return GetCommunicatorMtuSize(); in GetCommunicatorMtuSize()
|
H A D | virtual_communicator.h | 48 uint32_t GetCommunicatorMtuSize() const override; 49 uint32_t GetCommunicatorMtuSize(const std::string &target) const override;
|
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/ |
H A D | communicator_proxy.cpp | 103 uint32_t CommunicatorProxy::GetCommunicatorMtuSize() const in GetCommunicatorMtuSize() function in DistributedDB::CommunicatorProxy 108 return mainComm_->GetCommunicatorMtuSize(); in GetCommunicatorMtuSize() 111 uint32_t CommunicatorProxy::GetCommunicatorMtuSize(const std::string &target) const in GetCommunicatorMtuSize() function in DistributedDB::CommunicatorProxy 122 uint32_t mtuSize = targetCommunicator->GetCommunicatorMtuSize(target); in GetCommunicatorMtuSize() 128 return mainComm_->GetCommunicatorMtuSize(target); in GetCommunicatorMtuSize()
|
H A D | communicator_proxy.h | 38 uint32_t GetCommunicatorMtuSize() const override; 39 uint32_t GetCommunicatorMtuSize(const std::string &target) const override;
|
H A D | remote_executor.cpp | 917 packetSize = communicator->GetCommunicatorMtuSize(device) * 9 / 10; // get the 9/10 of the size in GetPacketSize()
|
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/communicator/include/ |
H A D | icommunicator.h | 63 virtual uint32_t GetCommunicatorMtuSize() const = 0; 64 virtual uint32_t GetCommunicatorMtuSize(const std::string &target) const = 0;
|
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/communicator/src/ |
H A D | communicator.h | 44 uint32_t GetCommunicatorMtuSize() const override; 45 uint32_t GetCommunicatorMtuSize(const std::string &target) const override;
|
H A D | communicator.cpp | 68 uint32_t Communicator::GetCommunicatorMtuSize() const in GetCommunicatorMtuSize() function in DistributedDB::Communicator 73 uint32_t Communicator::GetCommunicatorMtuSize(const std::string &target) const in GetCommunicatorMtuSize() function in DistributedDB::Communicator
|
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/singlever/ |
H A D | single_ver_data_sync.cpp | 1706 …mtuSize_ = communicateHandle_->GetCommunicatorMtuSize(deviceId_) * 9 / 10; // get the 9/10 of the … in UpdateMtuSize()
|