| /foundation/filemanagement/dfs_service/services/cloudsyncservice/src/transport/softbus/ |
| H A D | softbus_adapter.cpp | 33 SoftbusAdapter &SoftbusAdapter::GetInstance() in GetInstance()
35 static SoftbusAdapter instance; in GetInstance()
39 int32_t SoftbusAdapter::CreateSessionServer(const char *packageName, const char *sessionName) in CreateSessionServer()
65 .OnBind = SoftbusAdapter::OnBind, in CreateSessionServer()
66 .OnShutdown = SoftbusAdapter::OnShutdown, in CreateSessionServer()
67 .OnBytes = SoftbusAdapter::OnBytes, in CreateSessionServer()
70 .OnFile = SoftbusAdapter::OnFile, in CreateSessionServer()
82 int32_t SoftbusAdapter::RemoveSessionServer(const char *packageName, const char *sessionName) in RemoveSessionServer()
85 int32_t socket = SoftbusAdapter in RemoveSessionServer()
[all...] |
| H A D | softbus_session.cpp | 53 int session = SoftbusAdapter::GetInstance().OpenSessionByP2P( in Start()
75 SoftbusAdapter::GetInstance().CloseSession(sessionId_); in Stop()
82 return SoftbusAdapter::GetInstance().SendBytes(sessionId_, data, dataLen); in SendData()
87 return SoftbusAdapter::GetInstance().SendFile(sessionId_, sFileList, dFileList); in SendFile()
114 if (!SoftbusAdapter::GetInstance().IsSessionOpened(sessionId)) { in WaitSessionOpened()
|
| H A D | session_manager.cpp | 44 auto ret = SoftbusAdapter::GetInstance().CreateSessionServer(SERVICE_NAME.c_str(), SESSION_NAME.c_str()); in CreateServer()
49 SoftbusAdapter::GetInstance().RegisterSessionListener(SESSION_NAME.c_str(), shared_from_this()); in CreateServer()
64 auto ret = SoftbusAdapter::GetInstance().RemoveSessionServer(SERVICE_NAME.c_str(), SESSION_NAME.c_str()); in RemoveServer()
70 SoftbusAdapter::GetInstance().UnRegisterSessionListener(SESSION_NAME.c_str()); in RemoveServer()
75 return SoftbusAdapter::GetInstance().SendBytes(sessionId, data, dataLen); in SendData()
|
| /foundation/ability/dmsfwk/services/dtbschedmgr/src/softbus_adapter/ |
| H A D | softbus_adapter_common.cpp | 22 const std::string TAG = "SoftbusAdapter";
25 IMPLEMENT_SINGLE_INSTANCE(SoftbusAdapter);
27 void SoftbusAdapter::Init() in Init()
32 void SoftbusAdapter::UnInit() in UnInit()
37 int32_t SoftbusAdapter::SendSoftbusEvent(std::shared_ptr<DSchedDataBuffer> buffer) in SendSoftbusEvent()
43 int32_t SoftbusAdapter::StopSoftbusEvent() in StopSoftbusEvent()
49 void SoftbusAdapter::OnBroadCastRecv(std::string& networkId, uint8_t* data, uint32_t dataLen) in OnBroadCastRecv()
55 int32_t SoftbusAdapter::RegisterSoftbusEventListener(const std::shared_ptr<SoftbusAdapterListener>& listener) in RegisterSoftbusEventListener()
61 int32_t SoftbusAdapter::UnregisterSoftbusEventListener(const std::shared_ptr<SoftbusAdapterListener>& listener) in UnregisterSoftbusEventListener()
|
| H A D | softbus_adapter.cpp | 28 const std::string TAG = "SoftbusAdapter";
35 IMPLEMENT_SINGLE_INSTANCE(SoftbusAdapter);
37 void SoftbusAdapter::Init() in Init()
43 eventThread_ = std::thread(&SoftbusAdapter::StartEvent, this); in Init()
50 void SoftbusAdapter::StartEvent() in StartEvent()
68 void SoftbusAdapter::UnInit() in UnInit()
81 int32_t SoftbusAdapter::SendSoftbusEvent(std::shared_ptr<DSchedDataBuffer> buffer) in SendSoftbusEvent()
96 int32_t SoftbusAdapter::DealSendSoftbusEvent(std::shared_ptr<DSchedDataBuffer> buffer, const int32_t retry) in DealSendSoftbusEvent()
123 int32_t SoftbusAdapter::RetrySendSoftbusEvent(std::shared_ptr<DSchedDataBuffer> buffer, const int32_t retry) in RetrySendSoftbusEvent()
143 int32_t SoftbusAdapter
[all...] |
| /foundation/ability/dmsfwk/services/dtbschedmgr/test/unittest/softbus_adapter/ |
| H A D | softbus_adapter_common_test.cpp | 59 uint32_t result = SoftbusAdapter::GetInstance().SendSoftbusEvent(buffer); in HWTEST_F()
72 uint32_t result = SoftbusAdapter::GetInstance().StopSoftbusEvent(); in HWTEST_F()
88 SoftbusAdapter::GetInstance().OnBroadCastRecv(networkId, sendData, sendDataLen); in HWTEST_F()
93 uint32_t result = SoftbusAdapter::GetInstance().RegisterSoftbusEventListener(listener); in HWTEST_F()
107 uint32_t result = SoftbusAdapter::GetInstance().UnregisterSoftbusEventListener(listener); in HWTEST_F()
121 uint32_t result = SoftbusAdapter::GetInstance().RegisterSoftbusEventListener(listener); in HWTEST_F()
134 SoftbusAdapter::GetInstance().pkgName_ = "oh"; in HWTEST_F()
135 uint32_t result = SoftbusAdapter::GetInstance().StopSoftbusEvent(); in HWTEST_F()
149 uint32_t result = SoftbusAdapter::GetInstance().RegisterSoftbusEventListener(listener); in HWTEST_F()
163 SoftbusAdapter in HWTEST_F()
[all...] |
| H A D | softbus_adapter_test.cpp | 63 uint32_t result = SoftbusAdapter::GetInstance().SendSoftbusEvent(buffer); in HWTEST_F()
78 uint32_t result = SoftbusAdapter::GetInstance().StopSoftbusEvent(); in HWTEST_F()
94 SoftbusAdapter::GetInstance().OnBroadCastRecv(networkId, sendData, sendDataLen); in HWTEST_F()
101 uint32_t result = SoftbusAdapter::GetInstance().RegisterSoftbusEventListener(listener); in HWTEST_F()
117 uint32_t result = SoftbusAdapter::GetInstance().UnregisterSoftbusEventListener(listener); in HWTEST_F()
131 uint32_t result = SoftbusAdapter::GetInstance().RegisterSoftbusEventListener(listener); in HWTEST_F()
144 SoftbusAdapter::GetInstance().pkgName_ = "oh"; in HWTEST_F()
147 uint32_t result = SoftbusAdapter::GetInstance().StopSoftbusEvent(); in HWTEST_F()
161 uint32_t result = SoftbusAdapter::GetInstance().RegisterSoftbusEventListener(listener); in HWTEST_F()
175 SoftbusAdapter in HWTEST_F()
[all...] |
| /foundation/distributedhardware/distributed_screen/services/softbusadapter/test/fuzztest/softbusadapter_fuzzer/ |
| H A D | softbusadapter_fuzzer.cpp | 56 std::shared_ptr<SoftbusAdapter> adapter = std::make_shared<SoftbusAdapter>(); in SoftbusAdapterFuzzTest()
75 std::shared_ptr<SoftbusAdapter> adapter = std::make_shared<SoftbusAdapter>(); in SoftbusOnBytesReceivedFuzzTest()
87 std::shared_ptr<SoftbusAdapter> adapter = std::make_shared<SoftbusAdapter>(); in SoftbusOnMessageReceivedFuzzTest()
97 std::shared_ptr<SoftbusAdapter> adapter = std::make_shared<SoftbusAdapter>(); in SoftbusOnSessionClosedFuzzTest()
114 std::shared_ptr<SoftbusAdapter> adapter = std::make_shared<SoftbusAdapter>(); in SoftbusOnSessionOpenedFuzzTest()
[all...] |
| /foundation/distributedhardware/distributed_screen/services/softbusadapter/src/ |
| H A D | softbus_adapter.cpp | 30 IMPLEMENT_SINGLE_INSTANCE(SoftbusAdapter);
33 SoftbusAdapter::GetInstance().OnSoftbusSessionOpened(sessionId, info); in ScreenOnSoftbusSessionOpened()
38 SoftbusAdapter::GetInstance().OnSoftbusSessionClosed(sessionId, reason); in ScreenOnSoftbusSessionClosed()
43 SoftbusAdapter::GetInstance().OnBytesReceived(sessionId, data, dataLen); in ScreenOnBytesReceived()
49 SoftbusAdapter::GetInstance().OnStreamReceived(sessionId, data, ext, frameInfo); in ScreenOnStreamReceived()
54 SoftbusAdapter::GetInstance().OnMessageReceived(sessionId, data, dataLen); in ScreenOnMessageReceived()
57 SoftbusAdapter::SoftbusAdapter() in SoftbusAdapter() function in OHOS::DistributedHardware::SoftbusAdapter
59 DHLOGI("SoftbusAdapter"); in SoftbusAdapter()
71 SoftbusAdapter
[all...] |
| /foundation/ability/dmsfwk/test/fuzztest/softbusadapter_fuzzer/ |
| H A D | softbusadapter_fuzzer.cpp | 36 SoftbusAdapter::GetInstance().SendSoftbusEvent(buffer); in FuzzSendSoftbusEvent()
37 SoftbusAdapter::GetInstance().StopSoftbusEvent(); in FuzzSendSoftbusEvent()
48 SoftbusAdapter::GetInstance().OnBroadCastRecv(networkId, newdata, dataLen); in FuzzOnBroadCastRecv()
50 SoftbusAdapter::GetInstance().RegisterSoftbusEventListener(listener); in FuzzOnBroadCastRecv()
51 SoftbusAdapter::GetInstance().UnregisterSoftbusEventListener(listener); in FuzzOnBroadCastRecv()
|
| /foundation/distributedhardware/distributed_screen/services/screentransport/screendatachannel/src/ |
| H A D | screen_data_channel_impl.cpp | 37 SoftbusAdapter::GetInstance().CreateSoftbusSessionServer(PKG_NAME, DATA_SESSION_NAME, peerDevId_); in CreateSession()
43 ret = SoftbusAdapter::GetInstance().RegisterSoftbusListener(softbusListener, DATA_SESSION_NAME, peerDevId_); in CreateSession()
50 SoftbusAdapter::GetInstance().CreateSoftbusSessionServer(PKG_NAME, JPEG_SESSION_NAME, peerDevId_); in CreateSession()
56 SoftbusAdapter::GetInstance().RegisterSoftbusListener(softbusListener, JPEG_SESSION_NAME, peerDevId_); in CreateSession()
75 int32_t ret = SoftbusAdapter::GetInstance().RemoveSoftbusSessionServer(PKG_NAME, DATA_SESSION_NAME, peerDevId_); in ReleaseSession()
80 ret = SoftbusAdapter::GetInstance().UnRegisterSoftbusListener(DATA_SESSION_NAME, peerDevId_); in ReleaseSession()
87 ret = SoftbusAdapter::GetInstance().RemoveSoftbusSessionServer(PKG_NAME, JPEG_SESSION_NAME, peerDevId_); in ReleaseSession()
92 ret = SoftbusAdapter::GetInstance().UnRegisterSoftbusListener(JPEG_SESSION_NAME, peerDevId_); in ReleaseSession()
112 int32_t ret = SoftbusAdapter::GetInstance().RegisterSoftbusListener(softbusListener, DATA_SESSION_NAME, peerDevId_); in OpenSession()
118 SoftbusAdapter in OpenSession()
[all...] |
| /foundation/ability/dmsfwk/services/dtbschedmgr/include/softbus_adapter/ |
| H A D | softbus_adapter.h | 29 class SoftbusAdapter { class
31 DECLARE_SINGLE_INSTANCE_BASE(SoftbusAdapter);
42 SoftbusAdapter() {} in SoftbusAdapter() function in OHOS::DistributedSchedule::SoftbusAdapter
|
| /foundation/distributedhardware/distributed_screen/services/softbusadapter/include/ |
| H A D | softbus_adapter.h | 38 class SoftbusAdapter { class
39 DECLARE_SINGLE_INSTANCE_BASE(SoftbusAdapter);
63 SoftbusAdapter();
64 ~SoftbusAdapter();
69 static const constexpr char *DSCREEN_LOG_TAG = "SoftbusAdapter";
|
| /foundation/filemanagement/dfs_service/services/cloudsyncservice/include/transport/softbus/ |
| H A D | softbus_adapter.h | 32 class SoftbusAdapter : public NoCopyable { class
34 static SoftbusAdapter &GetInstance();
71 SoftbusAdapter() = default;
|
| /foundation/distributedhardware/distributed_screen/services/softbusadapter/test/unittest/include/ |
| H A D | softbus_adapter_test.h | 40 SoftbusAdapter softbusAdapter;
|
| /foundation/ability/dmsfwk/services/dtbschedmgr/src/mission/ |
| H A D | dms_continue_send_manager.cpp | 61 SoftbusAdapter::GetInstance().Init(); in Init()
84 SoftbusAdapter::GetInstance().UnInit(); in UnInit()
252 int32_t ret = SoftbusAdapter::GetInstance().SendSoftbusEvent(buffer); in SendSoftbusEvent()
|
| H A D | dms_continue_recv_manager.cpp | 63 int32_t ret = SoftbusAdapter::GetInstance().RegisterSoftbusEventListener(missionBroadcastListener); in Init()
|