| /foundation/distributeddatamgr/data_object/frameworks/innerkitsimpl/src/communicator/ |
| H A D | app_pipe_mgr.cpp | 21 Status AppPipeMgr::StartWatchDataChange(const AppDataChangeListener *observer, const PipeInfo &pipeInfo)
in StartWatchDataChange() argument
24 if (observer == nullptr || pipeInfo.pipeId.empty()) {
in StartWatchDataChange()
29 auto it = dataBusMap_.find(pipeInfo.pipeId);
in StartWatchDataChange()
35 return it->second->StartWatchDataChange(observer, pipeInfo);
in StartWatchDataChange()
39 Status AppPipeMgr::StopWatchDataChange(const AppDataChangeListener *observer, const PipeInfo &pipeInfo)
in StopWatchDataChange() argument
42 if (observer == nullptr || pipeInfo.pipeId.empty()) {
in StopWatchDataChange()
47 auto it = dataBusMap_.find(pipeInfo.pipeId);
in StopWatchDataChange()
53 return it->second->StopWatchDataChange(observer, pipeInfo);
in StopWatchDataChange()
57 Status AppPipeMgr::SendData(const PipeInfo &pipeInfo, const DeviceId &deviceId, const DataInfo &dataInfo,
in SendData() argument
61 || pipeInfo in SendData()
80 Start(const PipeInfo &pipeInfo) Start() argument
105 Stop(const PipeInfo &pipeInfo) Stop() argument
127 IsSameStartedOnPeer(const struct PipeInfo &pipeInfo, const struct DeviceId &peer) IsSameStartedOnPeer() argument
[all...] |
| H A D | communication_provider_impl.cpp | 40 const AppDeviceStatusChangeListener *observer, const PipeInfo &pipeInfo)
in StartWatchDeviceChange()
42 return appDeviceHandler_.StartWatchDeviceChange(observer, pipeInfo);
in StartWatchDeviceChange()
46 const AppDeviceStatusChangeListener *observer, const PipeInfo &pipeInfo)
in StopWatchDeviceChange()
48 return appDeviceHandler_.StopWatchDeviceChange(observer, pipeInfo);
in StopWatchDeviceChange()
61 Status CommunicationProviderImpl::StartWatchDataChange(const AppDataChangeListener *observer, const PipeInfo &pipeInfo)
in StartWatchDataChange() argument
63 return appPipeMgr_.StartWatchDataChange(observer, pipeInfo);
in StartWatchDataChange()
66 Status CommunicationProviderImpl::StopWatchDataChange(const AppDataChangeListener *observer, const PipeInfo &pipeInfo)
in StopWatchDataChange() argument
68 return appPipeMgr_.StopWatchDataChange(observer, pipeInfo);
in StopWatchDataChange()
71 Status CommunicationProviderImpl::SendData(const PipeInfo &pipeInfo, const DeviceId &deviceId,
in SendData() argument
74 return appPipeMgr_.SendData(pipeInfo, deviceI in SendData()
39 StartWatchDeviceChange( const AppDeviceStatusChangeListener *observer, const PipeInfo &pipeInfo) StartWatchDeviceChange() argument
45 StopWatchDeviceChange( const AppDeviceStatusChangeListener *observer, const PipeInfo &pipeInfo) StopWatchDeviceChange() argument
77 Start(const PipeInfo &pipeInfo) Start() argument
82 Stop(const PipeInfo &pipeInfo) Stop() argument
87 IsSameStartedOnPeer(const PipeInfo &pipeInfo, const DeviceId &peer) const IsSameStartedOnPeer() argument
[all...] |
| H A D | app_pipe_handler.cpp | 31 AppPipeHandler::AppPipeHandler(const PipeInfo &pipeInfo) : pipeInfo_(pipeInfo)
in AppPipeHandler() argument
37 Status AppPipeHandler::SendData(const PipeInfo &pipeInfo, const DeviceId &deviceId, const DataInfo &dataInfo,
in SendData() argument
40 return softbusAdapter_->SendData(pipeInfo, deviceId, dataInfo, totalLength, info);
in SendData()
43 Status AppPipeHandler::StartWatchDataChange(const AppDataChangeListener *observer, const PipeInfo &pipeInfo)
in StartWatchDataChange() argument
45 return softbusAdapter_->StartWatchDataChange(observer, pipeInfo);
in StartWatchDataChange()
49 __attribute__((unused)) const AppDataChangeListener *observer, const PipeInfo &pipeInfo)
in StopWatchDataChange()
51 return softbusAdapter_->StopWatchDataChange(observer, pipeInfo);
in StopWatchDataChange()
55 const struct PipeInfo &pipeInfo, __attribute__((unused)) const struct DeviceId &peer)
in IsSameStartedOnPeer()
57 return softbusAdapter_->IsSameStartedOnPeer(pipeInfo, pee in IsSameStartedOnPeer()
48 StopWatchDataChange( __attribute__((unused)) const AppDataChangeListener *observer, const PipeInfo &pipeInfo) StopWatchDataChange() argument
54 IsSameStartedOnPeer( const struct PipeInfo &pipeInfo, __attribute__((unused)) const struct DeviceId &peer) IsSameStartedOnPeer() argument
[all...] |
| H A D | app_device_handler.cpp | 38 const AppDeviceStatusChangeListener *observer, __attribute__((unused)) const PipeInfo &pipeInfo)
in StartWatchDeviceChange()
40 return softbusAdapter_->StartWatchDeviceChange(observer, pipeInfo);
in StartWatchDeviceChange()
44 const AppDeviceStatusChangeListener *observer, __attribute__((unused)) const PipeInfo &pipeInfo)
in StopWatchDeviceChange()
46 return softbusAdapter_->StopWatchDeviceChange(observer, pipeInfo);
in StopWatchDeviceChange()
37 StartWatchDeviceChange( const AppDeviceStatusChangeListener *observer, __attribute__((unused)) const PipeInfo &pipeInfo) StartWatchDeviceChange() argument
43 StopWatchDeviceChange( const AppDeviceStatusChangeListener *observer, __attribute__((unused)) const PipeInfo &pipeInfo) StopWatchDeviceChange() argument
|
| H A D | softbus_adapter_standard.cpp | 70 const AppDeviceStatusChangeListener *observer, __attribute__((unused)) const PipeInfo &pipeInfo)
in StartWatchDeviceChange()
88 const AppDeviceStatusChangeListener *observer, __attribute__((unused)) const PipeInfo &pipeInfo)
in StopWatchDeviceChange()
327 Status SoftBusAdapter::StartWatchDataChange(const AppDataChangeListener *observer, const PipeInfo &pipeInfo)
in StartWatchDataChange() argument
334 auto it = dataChangeListeners_.find(pipeInfo.pipeId);
in StartWatchDataChange()
339 LOG_DEBUG("current appid %{public}s", pipeInfo.pipeId.c_str());
in StartWatchDataChange()
340 dataChangeListeners_.insert({ pipeInfo.pipeId, observer });
in StartWatchDataChange()
345 __attribute__((unused)) const AppDataChangeListener *observer, const PipeInfo &pipeInfo)
in StopWatchDataChange()
349 if (dataChangeListeners_.erase(pipeInfo.pipeId)) {
in StopWatchDataChange()
352 LOG_WARN("stop data observer error, pipeInfo:%{public}s", pipeInfo in StopWatchDataChange()
69 StartWatchDeviceChange( const AppDeviceStatusChangeListener *observer, __attribute__((unused)) const PipeInfo &pipeInfo) StartWatchDeviceChange() argument
87 StopWatchDeviceChange( const AppDeviceStatusChangeListener *observer, __attribute__((unused)) const PipeInfo &pipeInfo) StopWatchDeviceChange() argument
344 StopWatchDataChange( __attribute__((unused)) const AppDataChangeListener *observer, const PipeInfo &pipeInfo) StopWatchDataChange() argument
356 SendData(const PipeInfo &pipeInfo, const DeviceId &deviceId, const DataInfo &dataInfo, uint32_t totalLength, const MessageInfo &info) SendData() argument
398 GetSocket(const PipeInfo &pipeInfo, const DeviceId &deviceId) GetSocket() argument
459 CreateClientSocket(const PipeInfo &pipeInfo, const DeviceId &deviceId) CreateClientSocket() argument
525 IsSameStartedOnPeer( const struct PipeInfo &pipeInfo, __attribute__((unused)) const struct DeviceId &peer) IsSameStartedOnPeer() argument
560 NotifyDataListeners( const uint8_t *ptr, const int size, const std::string &deviceId, const PipeInfo &pipeInfo) NotifyDataListeners() argument
634 NotifyDataListeners(const uint8_t *ptr, const int size, const std::string &deviceId, const PipeInfo &pipeInfo) NotifyDataListeners() argument
[all...] |
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/adapter/communicator/src/ |
| H A D | app_pipe_mgr.cpp | 25 Status AppPipeMgr::StartWatchDataChange(const AppDataChangeListener *observer, const PipeInfo &pipeInfo) in StartWatchDataChange() argument
28 if (observer == nullptr || pipeInfo.pipeId.empty()) { in StartWatchDataChange()
33 auto it = dataBusMap_.find(pipeInfo.pipeId); in StartWatchDataChange()
39 return it->second->StartWatchDataChange(observer, pipeInfo); in StartWatchDataChange()
43 Status AppPipeMgr::StopWatchDataChange(const AppDataChangeListener *observer, const PipeInfo &pipeInfo) in StopWatchDataChange() argument
46 if (observer == nullptr || pipeInfo.pipeId.empty()) { in StopWatchDataChange()
51 auto it = dataBusMap_.find(pipeInfo.pipeId); in StopWatchDataChange()
57 return it->second->StopWatchDataChange(observer, pipeInfo); in StopWatchDataChange()
61 Status AppPipeMgr::SendData(const PipeInfo &pipeInfo, const DeviceId &deviceId, const DataInfo &dataInfo, in SendData() argument
65 pipeInfo in SendData()
84 Start(const PipeInfo &pipeInfo) Start() argument
109 Stop(const PipeInfo &pipeInfo) Stop() argument
127 IsSameStartedOnPeer(const struct PipeInfo &pipeInfo, const struct DeviceId &peer) IsSameStartedOnPeer() argument
148 SetMessageTransFlag(const PipeInfo &pipeInfo, bool flag) SetMessageTransFlag() argument
[all...] |
| H A D | communication_provider_impl.cpp | 41 Status CommunicationProviderImpl::StartWatchDataChange(const AppDataChangeListener *observer, const PipeInfo &pipeInfo) in StartWatchDataChange() argument
43 return appPipeMgr_.StartWatchDataChange(observer, pipeInfo); in StartWatchDataChange()
46 Status CommunicationProviderImpl::StopWatchDataChange(const AppDataChangeListener *observer, const PipeInfo &pipeInfo) in StopWatchDataChange() argument
48 return appPipeMgr_.StopWatchDataChange(observer, pipeInfo); in StopWatchDataChange()
51 Status CommunicationProviderImpl::SendData(const PipeInfo &pipeInfo, const DeviceId &deviceId, const DataInfo &dataInfo, in SendData() argument
54 return appPipeMgr_.SendData(pipeInfo, deviceId, dataInfo, totalLength, info); in SendData()
57 Status CommunicationProviderImpl::Start(const PipeInfo &pipeInfo) in Start() argument
59 return appPipeMgr_.Start(pipeInfo); in Start()
62 Status CommunicationProviderImpl::Stop(const PipeInfo &pipeInfo) in Stop() argument
64 return appPipeMgr_.Stop(pipeInfo); in Stop()
67 IsSameStartedOnPeer(const PipeInfo &pipeInfo, const DeviceId &peer) const IsSameStartedOnPeer() argument
72 SetMessageTransFlag(const PipeInfo &pipeInfo, bool flag) SetMessageTransFlag() argument
77 Broadcast(const PipeInfo &pipeInfo, const LevelInfo &levelInfo) Broadcast() argument
82 ListenBroadcastMsg(const PipeInfo &pipeInfo, std::function<void(const std::string &, const LevelInfo &)> listener) ListenBroadcastMsg() argument
[all...] |
| H A D | app_pipe_handler.cpp | 39 AppPipeHandler::AppPipeHandler(const PipeInfo &pipeInfo) in AppPipeHandler() argument
40 : pipeInfo_(pipeInfo) in AppPipeHandler()
46 Status AppPipeHandler::SendData(const PipeInfo &pipeInfo, const DeviceId &deviceId, const DataInfo &dataInfo, in SendData() argument
49 return softbusAdapter_->SendData(pipeInfo, deviceId, dataInfo, totalLength, info); in SendData()
52 Status AppPipeHandler::StartWatchDataChange(const AppDataChangeListener *observer, const PipeInfo &pipeInfo) in StartWatchDataChange() argument
54 return softbusAdapter_->StartWatchDataChange(observer, pipeInfo); in StartWatchDataChange()
58 const PipeInfo &pipeInfo) in StopWatchDataChange()
60 return softbusAdapter_->StopWatchDataChange(observer, pipeInfo); in StopWatchDataChange()
63 bool AppPipeHandler::IsSameStartedOnPeer(const struct PipeInfo &pipeInfo, in IsSameStartedOnPeer() argument
66 return softbusAdapter_->IsSameStartedOnPeer(pipeInfo, pee in IsSameStartedOnPeer()
57 StopWatchDataChange(__attribute__((unused))const AppDataChangeListener *observer, const PipeInfo &pipeInfo) StopWatchDataChange() argument
69 SetMessageTransFlag(const PipeInfo &pipeInfo, bool flag) SetMessageTransFlag() argument
[all...] |
| H A D | communication_provider_impl.h | 33 Status StartWatchDataChange(const AppDataChangeListener *observer, const PipeInfo &pipeInfo) override;
36 Status StopWatchDataChange(const AppDataChangeListener *observer, const PipeInfo &pipeInfo) override;
39 Status SendData(const PipeInfo &pipeInfo, const DeviceId &deviceId, const DataInfo &dataInfo,
43 Status Start(const PipeInfo &pipeInfo) override;
46 Status Stop(const PipeInfo &pipeInfo) override;
48 bool IsSameStartedOnPeer(const PipeInfo &pipeInfo, const DeviceId &peer) const override;
49 void SetMessageTransFlag(const struct PipeInfo &pipeInfo, bool flag) override;
51 Status Broadcast(const PipeInfo &pipeInfo, const LevelInfo &levelInfo) override;
52 int32_t ListenBroadcastMsg(const PipeInfo &pipeInfo,
|
| H A D | app_pipe_mgr.h | 33 Status StartWatchDataChange(const AppDataChangeListener *observer, const PipeInfo &pipeInfo);
36 Status StopWatchDataChange(const AppDataChangeListener *observer, const PipeInfo &pipeInfo);
39 Status SendData(const PipeInfo &pipeInfo, const DeviceId &deviceId, const DataInfo &dataInfo,
42 Status Start(const PipeInfo &pipeInfo);
44 Status Stop(const PipeInfo &pipeInfo);
46 bool IsSameStartedOnPeer(const struct PipeInfo &pipeInfo, const struct DeviceId &peer);
48 void SetMessageTransFlag(const PipeInfo &pipeInfo, bool flag);
|
| H A D | app_pipe_handler.h | 38 explicit AppPipeHandler(const PipeInfo &pipeInfo);
41 Status StartWatchDataChange(const AppDataChangeListener *observer, const PipeInfo &pipeInfo);
43 Status StopWatchDataChange(const AppDataChangeListener *observer, const PipeInfo &pipeInfo);
45 Status SendData(const PipeInfo &pipeInfo, const DeviceId &deviceId, const DataInfo &dataInfo,
47 bool IsSameStartedOnPeer(const struct PipeInfo &pipeInfo, const struct DeviceId &peer);
49 void SetMessageTransFlag(const PipeInfo &pipeInfo, bool flag);
|
| H A D | softbus_adapter.h | 49 Status StartWatchDataChange(const AppDataChangeListener *observer, const PipeInfo &pipeInfo);
52 Status StopWatchDataChange(const AppDataChangeListener *observer, const PipeInfo &pipeInfo);
55 Status SendData(const PipeInfo &pipeInfo, const DeviceId &deviceId, const DataInfo &dataInfo, uint32_t length,
58 bool IsSameStartedOnPeer(const struct PipeInfo &pipeInfo, const struct DeviceId &peer);
60 void SetMessageTransFlag(const PipeInfo &pipeInfo, bool flag);
66 void NotifyDataListeners(const uint8_t *data, int size, const std::string &deviceId, const PipeInfo &pipeInfo);
76 Status Broadcast(const PipeInfo &pipeInfo, const LevelInfo &levelInfo);
78 int32_t ListenBroadcastMsg(const PipeInfo &pipeInfo,
95 void Reuse(const PipeInfo &pipeInfo, const DeviceId &deviceId,
|
| H A D | softbus_adapter_standard.cpp | 61 const PipeInfo &pipeInfo);
142 Status SoftBusAdapter::StartWatchDataChange(const AppDataChangeListener *observer, const PipeInfo &pipeInfo) in StartWatchDataChange() argument
149 auto ret = dataChangeListeners_.Insert(pipeInfo.pipeId, observer); in StartWatchDataChange()
159 const PipeInfo &pipeInfo) in StopWatchDataChange()
162 if (dataChangeListeners_.Erase(pipeInfo.pipeId) != 0) { in StopWatchDataChange()
165 ZLOGW("stop data observer error, pipeInfo:%{public}s", pipeInfo.pipeId.c_str()); in StopWatchDataChange()
169 void SoftBusAdapter::Reuse(const PipeInfo &pipeInfo, const DeviceId &deviceId, in Reuse() argument
173 auto connect = std::make_shared<SoftBusClient>(pipeInfo, deviceId, qosType); in Reuse()
192 Status SoftBusAdapter::SendData(const PipeInfo &pipeInfo, cons argument
158 StopWatchDataChange(__attribute__((unused)) const AppDataChangeListener *observer, const PipeInfo &pipeInfo) StopWatchDataChange() argument
400 IsSameStartedOnPeer(const struct PipeInfo &pipeInfo, __attribute__((unused)) const struct DeviceId &peer) IsSameStartedOnPeer() argument
408 SetMessageTransFlag(const PipeInfo &pipeInfo, bool flag) SetMessageTransFlag() argument
433 NotifyDataListeners(const uint8_t *data, int size, const std::string &deviceId, const PipeInfo &pipeInfo) NotifyDataListeners() argument
452 Broadcast(const PipeInfo &pipeInfo, const LevelInfo &levelInfo) Broadcast() argument
477 ListenBroadcastMsg(const PipeInfo &pipeInfo, std::function<void(const std::string &, const LevelInfo &)> listener) ListenBroadcastMsg() argument
547 NotifyDataListeners(const uint8_t *data, const int size, const std::string &deviceId, const PipeInfo &pipeInfo) NotifyDataListeners() argument
[all...] |
| /foundation/distributeddatamgr/data_object/frameworks/innerkitsimpl/test/unittest/src/ |
| H A D | app_pipe_mgr_test.cpp | 68 PipeInfo pipeInfo = { "" };
in HWTEST_F() local
71 auto ret = appPipeMgr->StartWatchDataChange(observer, pipeInfo);
in HWTEST_F()
82 PipeInfo pipeInfo = { "pipId01" };
in HWTEST_F() local
85 auto ret = appPipeMgr->StartWatchDataChange(observer, pipeInfo);
in HWTEST_F()
96 PipeInfo pipeInfo = { "pipId01" };
in HWTEST_F() local
98 auto ret = appPipeMgr.StartWatchDataChange(nullptr, pipeInfo);
in HWTEST_F()
109 PipeInfo pipeInfo = { "pipId01" };
in HWTEST_F() local
111 auto ret = appPipeMgr.Start(pipeInfo);
in HWTEST_F()
114 ret = appPipeMgr.StartWatchDataChange(&observer, pipeInfo);
in HWTEST_F()
125 PipeInfo pipeInfo in HWTEST_F() local
138 PipeInfo pipeInfo = { "pipId01" }; HWTEST_F() local
152 PipeInfo pipeInfo = { "pipId02" }; HWTEST_F() local
170 PipeInfo pipeInfo = {}; HWTEST_F() local
183 PipeInfo pipeInfo = { "INVALID_SESSION_NAME" }; HWTEST_F() local
196 PipeInfo pipeInfo = { "pipInfo01" }; HWTEST_F() local
211 PipeInfo pipeInfo = { "pipInfo01" }; HWTEST_F() local
228 PipeInfo pipeInfo = { "pipInfo01" }; HWTEST_F() local
241 PipeInfo pipeInfo = { "REMOVE_FAILED_SESSION_NAME" }; HWTEST_F() local
256 PipeInfo pipeInfo = {}; HWTEST_F() local
299 PipeInfo pipeInfo = { "pipInfo02" }; HWTEST_F() local
318 PipeInfo pipeInfo = { "pipInfo02" }; HWTEST_F() local
339 PipeInfo pipeInfo = { "pipInfo01" }; HWTEST_F() local
353 PipeInfo pipeInfo = { "pipInfo02" }; HWTEST_F() local
367 PipeInfo pipeInfo = { "pipInfo02" }; HWTEST_F() local
[all...] |
| H A D | communicator_test.cpp | 81 PipeInfo pipeInfo = { "pipInfo001" };
in HWTEST_F() local
84 auto ret = softBusAdapter.StartWatchDeviceChange(&listener, pipeInfo);
in HWTEST_F()
95 PipeInfo pipeInfo = { "pipInfo002" };
in HWTEST_F() local
97 auto ret = softBusAdapter.StartWatchDeviceChange(nullptr, pipeInfo);
in HWTEST_F()
108 PipeInfo pipeInfo = { "pipInfo003" };
in HWTEST_F() local
111 auto ret = softBusAdapter.StartWatchDeviceChange(&listener, pipeInfo);
in HWTEST_F()
113 ret = softBusAdapter.StartWatchDeviceChange(&listener, pipeInfo);
in HWTEST_F()
124 PipeInfo pipeInfo = { "pipInfo001" };
in HWTEST_F() local
127 auto ret = softBusAdapter.StartWatchDeviceChange(&listener, pipeInfo);
in HWTEST_F()
129 ret = softBusAdapter.StopWatchDeviceChange(&listener, pipeInfo);
in HWTEST_F()
140 PipeInfo pipeInfo = { "pipInfo002" }; HWTEST_F() local
156 PipeInfo pipeInfo = { "pipInfo003" }; HWTEST_F() local
174 PipeInfo pipeInfo = { "pipInfo001" }; HWTEST_F() local
193 PipeInfo pipeInfo = { "pipInfo001" }; HWTEST_F() local
212 PipeInfo pipeInfo = { "pipInfo001" }; HWTEST_F() local
230 PipeInfo pipeInfo = { "pipInfo001" }; HWTEST_F() local
244 PipeInfo pipeInfo = { "pipInfo001" }; HWTEST_F() local
258 PipeInfo pipeInfo = { "pipInfo002" }; HWTEST_F() local
273 PipeInfo pipeInfo = { "pipInfo002" }; HWTEST_F() local
286 PipeInfo pipeInfo = { "pipInfo001" }; HWTEST_F() local
302 PipeInfo pipeInfo = { "pipInfo001" }; HWTEST_F() local
490 PipeInfo pipeInfo = {"INVALID_SESSION_NAME"}; HWTEST_F() local
537 PipeInfo pipeInfo = { "OnServerBytesReceived_001" }; HWTEST_F() local
[all...] |
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/adapter/include/communicator/ |
| H A D | communication_provider.h | 42 virtual Status StartWatchDataChange(const AppDataChangeListener *observer, const PipeInfo &pipeInfo) = 0;
45 virtual Status StopWatchDataChange(const AppDataChangeListener *observer, const PipeInfo &pipeInfo) = 0;
48 virtual Status SendData(const PipeInfo &pipeInfo, const DeviceId &deviceId, const DataInfo &dataInfo,
52 virtual Status Start(const PipeInfo &pipeInfo) = 0;
55 virtual Status Stop(const PipeInfo &pipeInfo) = 0;
57 // check peer device pipeInfo Process
58 virtual bool IsSameStartedOnPeer(const PipeInfo &pipeInfo, const DeviceId &peer) const = 0;
62 virtual void SetMessageTransFlag(const PipeInfo &pipeInfo, bool flag) = 0;
64 virtual Status Broadcast(const PipeInfo &pipeInfo, const LevelInfo &levelInfo) = 0;
65 virtual int32_t ListenBroadcastMsg(const PipeInfo &pipeInfo,
[all...] |
| /foundation/distributeddatamgr/data_object/frameworks/innerkitsimpl/include/communicator/ |
| H A D | communication_provider_impl.h | 34 Status StartWatchDeviceChange(const AppDeviceStatusChangeListener *observer, const PipeInfo &pipeInfo) override;
37 Status StopWatchDeviceChange(const AppDeviceStatusChangeListener *observer, const PipeInfo &pipeInfo) override;
40 Status StartWatchDataChange(const AppDataChangeListener *observer, const PipeInfo &pipeInfo) override;
43 Status StopWatchDataChange(const AppDataChangeListener *observer, const PipeInfo &pipeInfo) override;
46 Status SendData(const PipeInfo &pipeInfo, const DeviceId &deviceId, const DataInfo &DataInfo, uint32_t totalLength,
56 Status Start(const PipeInfo &pipeInfo) override;
59 Status Stop(const PipeInfo &pipeInfo) override;
61 bool IsSameStartedOnPeer(const PipeInfo &pipeInfo, const DeviceId &peer) const override;
|
| H A D | communication_provider.h | 38 virtual Status StartWatchDeviceChange(const AppDeviceStatusChangeListener *observer, const PipeInfo &pipeInfo) = 0;
42 virtual Status StopWatchDeviceChange(const AppDeviceStatusChangeListener *observer, const PipeInfo &pipeInfo) = 0;
46 virtual Status StartWatchDataChange(const AppDataChangeListener *observer, const PipeInfo &pipeInfo) = 0;
49 KVSTORE_API virtual Status StopWatchDataChange(const AppDataChangeListener *observer, const PipeInfo &pipeInfo) = 0;
53 virtual Status SendData(const PipeInfo &pipeInfo, const DeviceId &deviceId, const DataInfo &DataInfo,
63 KVSTORE_API virtual Status Start(const PipeInfo &pipeInfo) = 0;
66 KVSTORE_API virtual Status Stop(const PipeInfo &pipeInfo) = 0;
71 // check peer device pipeInfo Process
72 KVSTORE_API virtual bool IsSameStartedOnPeer(const PipeInfo &pipeInfo, const DeviceId &peer) const = 0;
|
| H A D | app_pipe_mgr.h | 38 Status StartWatchDataChange(const AppDataChangeListener *observer, const PipeInfo &pipeInfo);
41 Status StopWatchDataChange(const AppDataChangeListener *observer, const PipeInfo &pipeInfo);
44 Status SendData(const PipeInfo &pipeInfo, const DeviceId &deviceId, const DataInfo &dataInfo, uint32_t totalLength,
47 Status Start(const PipeInfo &pipeInfo);
49 Status Stop(const PipeInfo &pipeInfo);
51 bool IsSameStartedOnPeer(const struct PipeInfo &pipeInfo, const struct DeviceId &peer);
|
| H A D | app_pipe_handler.h | 34 explicit AppPipeHandler(const PipeInfo &pipeInfo);
37 Status StartWatchDataChange(const AppDataChangeListener *observer, const PipeInfo &pipeInfo);
39 Status StopWatchDataChange(const AppDataChangeListener *observer, const PipeInfo &pipeInfo);
41 Status SendData(const PipeInfo &pipeInfo, const DeviceId &deviceId, const DataInfo &dataInfo, uint32_t totalLength,
43 bool IsSameStartedOnPeer(const struct PipeInfo &pipeInfo, const struct DeviceId &peer);
|
| H A D | softbus_adapter.h | 42 Status StartWatchDeviceChange(const AppDeviceStatusChangeListener *observer, const PipeInfo &pipeInfo);
44 Status StopWatchDeviceChange(const AppDeviceStatusChangeListener *observer, const PipeInfo &pipeInfo);
55 Status StartWatchDataChange(const AppDataChangeListener *observer, const PipeInfo &pipeInfo);
58 Status StopWatchDataChange(const AppDataChangeListener *observer, const PipeInfo &pipeInfo);
61 Status SendData(const PipeInfo &pipeInfo, const DeviceId &deviceId, const DataInfo &dataInfo, uint32_t totalLength,
64 bool IsSameStartedOnPeer(const struct PipeInfo &pipeInfo, const struct DeviceId &peer);
72 void NotifyDataListeners(const uint8_t *ptr, const int size, const std::string &deviceId, const PipeInfo &pipeInfo);
97 int GetSocket(const PipeInfo &pipeInfo, const DeviceId &deviceId);
98 int CreateClientSocket(const PipeInfo &pipeInfo, const DeviceId &deviceId);
137 const uint8_t *ptr, const int size, const std::string &deviceId, const PipeInfo &pipeInfo);
[all...] |
| H A D | app_device_handler.h | 30 Status StartWatchDeviceChange(const AppDeviceStatusChangeListener *observer, const PipeInfo &pipeInfo);
32 Status StopWatchDeviceChange(const AppDeviceStatusChangeListener *observer, const PipeInfo &pipeInfo);
|
| /foundation/multimedia/audio_framework/services/audio_policy/server/src/service/config/ |
| H A D | audio_policy_parser.cpp | 166 void AudioPolicyParser::GetCommontAudioModuleInfo(PipeInfo &pipeInfo, AudioModuleInfo &audioModuleInfo) in GetCommontAudioModuleInfo() argument
168 audioModuleInfo.role = pipeInfo.paPropRole_; in GetCommontAudioModuleInfo()
170 for (auto sampleRate : pipeInfo.sampleRates_) { in GetCommontAudioModuleInfo()
173 for (auto channelLayout : pipeInfo.channelLayouts_) { in GetCommontAudioModuleInfo()
177 audioModuleInfo.lib = pipeInfo.lib_; in GetCommontAudioModuleInfo()
179 if (pipeInfo.streamPropInfos_.size() != 0) { in GetCommontAudioModuleInfo()
180 audioModuleInfo.rate = std::to_string((*pipeInfo.streamPropInfos_.begin()).sampleRate_); in GetCommontAudioModuleInfo()
181 audioModuleInfo.format = (*pipeInfo.streamPropInfos_.begin()).format_; in GetCommontAudioModuleInfo()
182 audioModuleInfo.channels = std::to_string((*pipeInfo.streamPropInfos_.begin()).channelLayout_); in GetCommontAudioModuleInfo()
183 audioModuleInfo.bufferSize = std::to_string((*pipeInfo in GetCommontAudioModuleInfo()
360 ParsePipeInfos(xmlNode &node, PipeInfo &pipeInfo) ParsePipeInfos() argument
412 ParseStreamProps(xmlNode &node, PipeInfo &pipeInfo) ParseStreamProps() argument
451 ParseConfigs(xmlNode &node, PipeInfo &pipeInfo) ParseConfigs() argument
473 HandleConfigFlagAndUsage(ConfigInfo &configInfo, PipeInfo &pipeInfo) HandleConfigFlagAndUsage() argument
[all...] |
| H A D | audio_adapter_info.cpp | 27 for (auto &pipeInfo : pipeInfos_) { in GetPipeByName()
28 if (pipeInfo.name_ == pipeName) { in GetPipeByName()
29 return &pipeInfo; in GetPipeByName()
|
| /foundation/multimedia/audio_framework/services/audio_policy/server/include/service/config/ |
| H A D | audio_policy_parser.h | 66 void ParsePipeInfos(xmlNode &node, PipeInfo &pipeInfo);
67 void ParseStreamProps(xmlNode &node, PipeInfo &pipeInfo);
68 void ParseConfigs(xmlNode &node, PipeInfo &pipeInfo);
69 void HandleConfigFlagAndUsage(ConfigInfo &configInfo, PipeInfo &pipeInfo);
95 void GetCommontAudioModuleInfo(PipeInfo &pipeInfo, AudioModuleInfo &audioModuleInfo);
|