Home
last modified time | relevance | path

Searched refs:ICommunicator (Results 1 – 25 of 53) sorted by relevance

123

/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/
H A Dcommunicator_proxy.h29 class CommunicatorProxy : public ICommunicator {
50 void SetMainCommunicator(ICommunicator *communicator);
53 void SetEqualCommunicator(ICommunicator *communicator, const std::string &identifier,
59 ICommunicator *mainComm_;
62 std::map<std::string, std::pair<std::string, ICommunicator *>> devCommMap_;
H A Dcommunicator_proxy.cpp88 std::map<std::string, ICommunicator *> tempMap; in Activate()
113 ICommunicator *targetCommunicator = nullptr; in GetCommunicatorMtuSize()
144 ICommunicator *targetCommunicator = nullptr; in GetTimeout()
177 ICommunicator *targetCommunicator = nullptr; in GetRemoteCommunicatorVersion()
206 ICommunicator *targetCommunicator = nullptr; in SendMessage()
228 void CommunicatorProxy::SetMainCommunicator(ICommunicator *communicator) in SetMainCommunicator()
234 void CommunicatorProxy::SetEqualCommunicator(ICommunicator *communicator, const std::string &identi… in SetEqualCommunicator()
H A Dsync_engine.h166 …void MessageReciveCallbackTask(ISyncTaskContext *context, const ICommunicator *communicator, Messa…
168 …void RemoteDataChangedTask(ISyncTaskContext *context, const ICommunicator *communicator, Message *…
170 void ScheduleTaskOut(ISyncTaskContext *context, const ICommunicator *communicator);
195 ICommunicator *AllocCommunicator(const std::string &identifier, int &errCode);
223 ICommunicator *communicator_;
235 std::map<std::string, ICommunicator *> equalCommunicators_;
H A Dremote_executor.h59 int Initialize(ISyncInterface *syncInterface, ICommunicator *communicator);
139 …int CheckSecurityOption(ISyncInterface *storage, ICommunicator *communicator, const SecurityOption…
145 ICommunicator *GetAndIncCommunicator() const;
165 ICommunicator *communicator_;
H A Ddevice_manager.h38 …int Initialize(ICommunicator *communicator, const std::function<void(std::string)> &onlineCallback,
71 ICommunicator *communicator_;
H A Dsync_state_machine.h50 ICommunicator *communicator) override;
163 ICommunicator *communicator_;
H A Dcommit_history_sync.h93 int Initialize(MultiVerKvDBSyncInterface *storagePtr, ICommunicator *communicateHandle);
141 ICommunicator *communicateHandle_;
H A Dtime_sync.h84 int Initialize(ICommunicator *communicator, const std::shared_ptr<Metadata> &metadata,
152 ICommunicator *communicateHandle_;
H A Disync_state_machine.h34 const std::shared_ptr<Metadata> &metadata, ICommunicator *communicator) = 0;
H A Dability_sync.h161 int Initialize(ICommunicator *inCommunicator, ISyncInterface *inStorage,
265 ICommunicator *communicator_;
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/communicator/include/
H A Dicommunicator_aggregator.h26 class ICommunicator; // Forward Declaration variable
45 virtual ICommunicator *AllocCommunicator(uint64_t commLabel, int &outErrorNo) = 0;
46 virtual ICommunicator *AllocCommunicator(const LabelType &commLabel, int &outErrorNo) = 0;
47 virtual void ReleaseCommunicator(ICommunicator *inCommunicator) = 0;
H A Dicommunicator.h52 class ICommunicator : public virtual RefObject {
86 virtual ~ICommunicator() {}; in ~ICommunicator()
H A Dcommunicator_aggregator.h62 ICommunicator *AllocCommunicator(uint64_t commLabel, int &outErrorNo) override;
63 ICommunicator *AllocCommunicator(const LabelType &commLabel, int &outErrorNo) override;
65 void ReleaseCommunicator(ICommunicator *inCommunicator) override;
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/
H A Dvirtual_communicator_aggregator.h26 class ICommunicator; // Forward Declaration variable
36 ICommunicator *AllocCommunicator(uint64_t commLabel, int &outErrorNo) override;
37 ICommunicator *AllocCommunicator(const LabelType &commLabel, int &outErrorNo) override;
39 void ReleaseCommunicator(ICommunicator *inCommunicator) override;
58 ICommunicator *AllocCommunicator(const std::string &deviceId, int &outErrorNo);
60 ICommunicator *GetCommunicator(const std::string &deviceId) const;
H A Dvirtual_communicator_aggregator.cpp38 ICommunicator *VirtualCommunicatorAggregator::AllocCommunicator(uint64_t commLabel, int &outErrorNo) in AllocCommunicator()
46 ICommunicator *VirtualCommunicatorAggregator::AllocCommunicator(const LabelType &commLabel, int &ou… in AllocCommunicator()
60 void VirtualCommunicatorAggregator::ReleaseCommunicator(ICommunicator *inCommunicator) in ReleaseCommunicator()
142 ICommunicator *VirtualCommunicatorAggregator::AllocCommunicator(const std::string &deviceId, int &o… in AllocCommunicator()
157 ICommunicator *VirtualCommunicatorAggregator::GetCommunicator(const std::string &deviceId) const in GetCommunicator()
H A Dmock_single_ver_data_sync.h50 void SetCommunicatorHandle(ICommunicator *communicator) in SetCommunicatorHandle()
H A Dmock_communicator.h23 class MockCommunicator : public ICommunicator {
H A Dgeneric_virtual_device.h50 ICommunicator *communicateHandle_;
H A Dvirtual_time_sync_communicator.h34 class VirtualTimeSyncCommunicator : public ICommunicator {
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/communicator/
H A Ddistributeddb_communicator_test.cpp113 ICommunicator *commA = g_envDeviceA.commAggrHandle->AllocCommunicator(LABEL_A, errorNo);
122 ICommunicator *commB = g_envDeviceA.commAggrHandle->AllocCommunicator(LABEL_B, errorNo);
920 ICommunicator *commAA = nullptr;
924 ICommunicator *commBB = nullptr;
999 ICommunicator *commAA = nullptr;
1055 ICommunicator *commAA = nullptr;
1058 ICommunicator *commBB = nullptr;
1122 ICommunicator *commAA = nullptr;
1125 ICommunicator *commBB = nullptr;
1179 ICommunicator *commAA = nullptr;
[all …]
H A Ddistributeddb_communicator_deep_test.cpp37 ICommunicator *g_commAA = nullptr;
38 ICommunicator *g_commAB = nullptr;
39 ICommunicator *g_commBB = nullptr;
40 ICommunicator *g_commBC = nullptr;
41 ICommunicator *g_commCC = nullptr;
42 ICommunicator *g_commCA = nullptr;
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/multiver/
H A Dvalue_slice_sync.h73 int Initialize(MultiVerKvDBSyncInterface *storagePtr, ICommunicator *communicateHandle);
121 ICommunicator *communicateHandle_;
H A Dmulti_ver_data_sync.h74 int Initialize(MultiVerKvDBSyncInterface *storagePtr, ICommunicator *communicateHandle);
130 ICommunicator *communicateHandle_;
H A Dmulti_ver_sync_task_context.h32 const std::shared_ptr<Metadata> &metadata, ICommunicator *communicator) override;
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/singlever/
H A Dsingle_ver_data_sync.h65 int Initialize(ISyncInterface *inStorage, ICommunicator *inCommunicateHandle,
256 ICommunicator* communicateHandle_;

123