| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/adapter/communicator/test/unittest/ |
| H A D | softbus_adapter_standard_test.cpp | 68 auto status = SoftBusAdapter::GetInstance()->StartWatchDataChange(nullptr, {});
in HWTEST_F()
85 auto status = SoftBusAdapter::GetInstance()->StartWatchDataChange(dataListener, appId);
in HWTEST_F()
102 auto status = SoftBusAdapter::GetInstance()->StartWatchDataChange(dataListener, appId);
in HWTEST_F()
119 auto status = SoftBusAdapter::GetInstance()->StopWatchDataChange(dataListener, appId);
in HWTEST_F()
136 auto status = SoftBusAdapter::GetInstance()->StopWatchDataChange(dataListener, appId);
in HWTEST_F()
152 auto secRegister = SoftBusAdapter::GetInstance()->StartWatchDataChange(dataListener, id);
in HWTEST_F()
158 Status status = SoftBusAdapter::GetInstance()->SendData(id, di, data, 11, { MessageType::DEFAULT });
in HWTEST_F()
160 SoftBusAdapter::GetInstance()->StopWatchDataChange(dataListener, id);
in HWTEST_F()
176 SoftBusAdapter::GetInstance()->StartWatchDataChange(dataListener, id);
in HWTEST_F()
178 auto size = SoftBusAdapter in HWTEST_F()
[all...] |
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/adapter/communicator/src/ |
| H A D | softbus_adapter_standard.cpp | 35 #define LOG_TAG "SoftBusAdapter"
49 static void SetDataHandler(SoftBusAdapter *handler);
65 static SoftBusAdapter *softBusAdapter_;
67 SoftBusAdapter *AppDataListenerWrap::softBusAdapter_;
68 std::shared_ptr<SoftBusAdapter> SoftBusAdapter::instance_;
83 SoftBusAdapter::GetInstance()->OnBroadcast({ uuid }, std::move(level)); in OnDataLevelChanged()
90 SoftBusAdapter::SoftBusAdapter() in SoftBusAdapter() function in OHOS::AppDistributedKv::SoftBusAdapter
123 SoftBusAdapter
[all...] |
| H A D | softbus_adapter.h | 36 class SoftBusAdapter : public AppDistributedKv::AppDeviceChangeListener { class
38 SoftBusAdapter();
39 ~SoftBusAdapter();
40 static std::shared_ptr<SoftBusAdapter> GetInstance();
103 static std::shared_ptr<SoftBusAdapter> instance_;
|
| H A D | communication_provider_impl.cpp | 79 return SoftBusAdapter::GetInstance()->Broadcast(pipeInfo, levelInfo); in Broadcast()
85 return SoftBusAdapter::GetInstance()->ListenBroadcastMsg(pipeInfo, std::move(listener)); in ListenBroadcastMsg()
|
| H A D | app_pipe_handler.h | 56 std::shared_ptr<SoftBusAdapter> softbusAdapter_ {};
|
| H A D | app_pipe_handler.cpp | 43 softbusAdapter_ = SoftBusAdapter::GetInstance(); in AppPipeHandler()
|
| H A D | process_communicator_impl.cpp | 161 return SoftBusAdapter::GetInstance()->GetMtuSize({ devInfo.identifier }); in GetMtuSize()
166 return SoftBusAdapter::GetInstance()->GetTimeout({ devInfo.identifier }); in GetTimeout()
|
| /foundation/distributeddatamgr/data_object/frameworks/innerkitsimpl/test/unittest/src/ |
| H A D | communicator_test.cpp | 51 SoftBusAdapter softBusAdapter_;
76 * @tc.desc: test SoftBusAdapter StartWatchDeviceChange. insert a normal observer
82 SoftBusAdapter softBusAdapter;
in HWTEST_F()
90 * @tc.desc: test SoftBusAdapter StartWatchDeviceChange. inserted observer is null
96 SoftBusAdapter softBusAdapter;
in HWTEST_F()
103 * @tc.desc: test SoftBusAdapter StartWatchDeviceChange. insert the same observer
109 SoftBusAdapter softBusAdapter;
in HWTEST_F()
119 * @tc.desc: test SoftBusAdapter StopWatchDeviceChange.
125 SoftBusAdapter softBusAdapter;
in HWTEST_F()
135 * @tc.desc: test SoftBusAdapter StopWatchDeviceChang
[all...] |
| /foundation/distributeddatamgr/data_object/frameworks/innerkitsimpl/src/communicator/ |
| H A D | softbus_adapter_standard.cpp | 40 SoftBusAdapter *AppDataListenerWrap::softBusAdapter_;
41 std::shared_ptr<SoftBusAdapter> SoftBusAdapter::instance_;
43 SoftBusAdapter::SoftBusAdapter()
in SoftBusAdapter() function in OHOS::ObjectStore::SoftBusAdapter
59 SoftBusAdapter::~SoftBusAdapter()
in ~SoftBusAdapter()
69 Status SoftBusAdapter::StartWatchDeviceChange(
in StartWatchDeviceChange()
87 Status SoftBusAdapter::StopWatchDeviceChange(
in StopWatchDeviceChange()
104 void SoftBusAdapter
[all...] |
| H A D | dev_manager.cpp | 35 explicit DMStateCallback(std::shared_ptr<SoftBusAdapter> softBusAdapter) : softBusAdapter_(softBusAdapter){};
in DMStateCallback()
42 std::shared_ptr<SoftBusAdapter> softBusAdapter_;
49 LOG_INFO("[Online] id:%{public}s, name:%{public}s, typeId:%{public}d", SoftBusAdapter::ToBeAnonymous(uuid).c_str(),
in OnDeviceOnline()
58 SoftBusAdapter::ToBeAnonymous(uuid).c_str(), deviceInfo.deviceName, deviceInfo.deviceTypeId);
in OnDeviceOffline()
65 LOG_INFO("[InfoChange] id:%{public}s, name:%{public}s", SoftBusAdapter::ToBeAnonymous(uuid).c_str(),
in OnDeviceChanged()
107 auto deviceStateCallback = std::make_shared<DMStateCallback>(SoftBusAdapter::GetInstance());
in Init()
146 LOG_WARN("GetEncryptedUuidByNetworkId error, nodeId:%{public}s", SoftBusAdapter::ToBeAnonymous(nodeId).c_str());
in GetUuidByNodeId()
|
| H A D | app_device_handler.cpp | 24 softbusAdapter_ = SoftBusAdapter::GetInstance();
in AppDeviceHandler()
|
| H A D | app_pipe_handler.cpp | 34 softbusAdapter_ = SoftBusAdapter::GetInstance();
in AppPipeHandler()
|
| /foundation/distributeddatamgr/data_object/frameworks/innerkitsimpl/include/communicator/ |
| H A D | softbus_adapter.h | 35 class SoftBusAdapter {
class
37 SoftBusAdapter();
38 ~SoftBusAdapter();
39 static std::shared_ptr<SoftBusAdapter> GetInstance();
103 static std::shared_ptr<SoftBusAdapter> instance_;
126 static void SetDataHandler(SoftBusAdapter *handler);
138 static SoftBusAdapter *softBusAdapter_;
|
| H A D | app_pipe_handler.h | 51 std::shared_ptr<SoftBusAdapter> softbusAdapter_{};
|
| H A D | app_device_handler.h | 44 std::shared_ptr<SoftBusAdapter> softbusAdapter_{};
|
| /foundation/distributeddatamgr/data_object/frameworks/innerkitsimpl/src/adaptor/ |
| H A D | flat_object_storage_engine.cpp | 86 statusWatcher->OnChanged(key, SoftBusAdapter::GetInstance()->ToNodeID(item.first), in OnComplete()
143 std::vector<DeviceInfo> devices = SoftBusAdapter::GetInstance()->GetDeviceList(); in CreateTable()
365 SoftBusAdapter::ToBeAnonymous(storeId).c_str(), item.second, in SetStatusNotifier()
366 SoftBusAdapter::ToBeAnonymous(SoftBusAdapter::GetInstance()->ToNodeID(item.first)).c_str()); in SetStatusNotifier()
370 statusWatcher_->OnChanged(storeId, SoftBusAdapter::GetInstance()->ToNodeID(item.first), in SetStatusNotifier()
377 statusWatcher_->OnChanged(storeId, SoftBusAdapter::GetInstance()->ToNodeID(deviceId), "offline"); in SetStatusNotifier()
|