Searched refs:DBStatusAdapter (Results 1 – 15 of 15) sorted by relevance
24 DBStatusAdapter::DBStatusAdapter() in DBStatusAdapter() function in DistributedDB::DBStatusAdapter42 bool DBStatusAdapter::IsSupport(const std::string &devInfo) in IsSupport()60 int DBStatusAdapter::GetLocalDBInfos(std::vector<DBInfo> &dbInfos) in GetLocalDBInfos()79 void DBStatusAdapter::SetDBStatusChangeCallback(const RemoteDBChangeCallback &remote, in SetDBStatusChangeCallback()148 void DBStatusAdapter::TargetOffline(const std::string &device) in TargetOffline()215 bool DBStatusAdapter::IsSendLabelExchange() in IsSendLabelExchange()236 std::shared_ptr<DBInfoHandle> DBStatusAdapter::GetDBInfoHandle() const in GetDBInfoHandle()255 void DBStatusAdapter::ClearAllCache() in ClearAllCache()272 void DBStatusAdapter::NotifyRemoteOffline() in NotifyRemoteOffline()324 int DBStatusAdapter::GetLocalDeviceId(std::string &deviceId) in GetLocalDeviceId()[all …]
38 std::shared_ptr<DBStatusAdapter> statusAdapter);126 std::shared_ptr<DBStatusAdapter> statusAdapter_;
36 std::shared_ptr<DBStatusAdapter> statusAdapter) in CommunicatorLinker()
55 int CommunicatorAggregator::Initialize(IAdapter *inAdapter, const std::shared_ptr<DBStatusAdapter> … in Initialize()
909 std::shared_ptr<DBStatusAdapter> adapterA = std::make_shared<DBStatusAdapter>();913 std::shared_ptr<DBStatusAdapter> adapterB = std::make_shared<DBStatusAdapter>();988 std::shared_ptr<DBStatusAdapter> adapterA = std::make_shared<DBStatusAdapter>();992 std::shared_ptr<DBStatusAdapter> adapterB = std::make_shared<DBStatusAdapter>();1046 std::shared_ptr<DBStatusAdapter> adapterA = std::make_shared<DBStatusAdapter>();1049 std::shared_ptr<DBStatusAdapter> adapterB = std::make_shared<DBStatusAdapter>();1112 std::shared_ptr<DBStatusAdapter> adapterA = std::make_shared<DBStatusAdapter>();1116 std::shared_ptr<DBStatusAdapter> adapterB = std::make_shared<DBStatusAdapter>();1161 std::shared_ptr<DBStatusAdapter> adapterA = std::make_shared<DBStatusAdapter>();1214 std::shared_ptr<DBStatusAdapter> adapterA = std::make_shared<DBStatusAdapter>();[all …]
42 const std::shared_ptr<DistributedDB::DBStatusAdapter> &adapter);
26 bool SetUpEnv(EnvHandle &inEnv, const string &inName, const std::shared_ptr<DBStatusAdapter> &adapt… in SetUpEnv()
27 class DBStatusAdapter {29 DBStatusAdapter();30 ~DBStatusAdapter() = default;31 DISABLE_COPY_ASSIGN_MOVE(DBStatusAdapter);
36 …virtual int Initialize(IAdapter *inAdapter, const std::shared_ptr<DBStatusAdapter> &statusAdapter)…
57 …int Initialize(IAdapter *inAdapter, const std::shared_ptr<DBStatusAdapter> &statusAdapter) overrid…205 std::shared_ptr<DBStatusAdapter> dbStatusAdapter_;
109 const std::shared_ptr<DBStatusAdapter> statusAdapter = GetDBStatusAdapter(); in GetCommunicatorAggregator()798 std::shared_ptr<DBStatusAdapter> dbStatusAdapter = GetDBStatusAdapter(); in SetDBInfoHandle()810 std::shared_ptr<DBStatusAdapter> dbStatusAdapter = GetDBStatusAdapter(); in NotifyDBInfos()816 std::shared_ptr<DBStatusAdapter> RuntimeContextImpl::GetDBStatusAdapter() in GetDBStatusAdapter()820 dbStatusAdapter_ = std::make_unique<DBStatusAdapter>(); in GetDBStatusAdapter()831 std::shared_ptr<DBStatusAdapter> dbStatusAdapter = GetDBStatusAdapter(); in RecordRemoteSubscribe()843 std::shared_ptr<DBStatusAdapter> dbStatusAdapter = GetDBStatusAdapter(); in RemoveRemoteSubscribe()855 std::shared_ptr<DBStatusAdapter> dbStatusAdapter = GetDBStatusAdapter(); in RemoveRemoteSubscribe()867 std::shared_ptr<DBStatusAdapter> dbStatusAdapter = GetDBStatusAdapter(); in RemoveRemoteSubscribe()880 std::shared_ptr<DBStatusAdapter> dbStatusAdapter = GetDBStatusAdapter(); in RemoveRemoteSubscribe()[all …]
193 std::shared_ptr<DBStatusAdapter> GetDBStatusAdapter();262 std::shared_ptr<DBStatusAdapter> dbStatusAdapter_;
31 …int Initialize(IAdapter *inAdapter, const std::shared_ptr<DBStatusAdapter> &statusAdapter) overrid…
28 const std::shared_ptr<DBStatusAdapter> &statusAdapter) in Initialize()
68 …int Initialize(IAdapter *inAdapter, const std::shared_ptr<DBStatusAdapter> &statusAdapter) override in Initialize()