/foundation/communication/dsoftbus/tests/sdk/transmission/trans_channel/udp/stream/libsoftbus_stream/stream_manager_test/ |
H A D | stream_manager_test.cpp | 69 std::shared_ptr<Communication::SoftBus::IStreamManagerListener> streamListener; in HWTEST_F() 70 auto streamSocketListener = std::make_shared<Communication::SoftBus::StreamManager>(streamListener); in HWTEST_F() 73 Communication::SoftBus::IpAndPort *local = in HWTEST_F() 74 (Communication::SoftBus::IpAndPort*)SoftBusMalloc(sizeof(Communication::SoftBus::IpAndPort)); in HWTEST_F() 75 (void)memset_s(local, sizeof(Communication::SoftBus::IpAndPort), 0, sizeof(Communication::SoftBus::IpAndPort)); in HWTEST_F() 76 Communication::SoftBus::IpAndPort *remote = in HWTEST_F() 77 (Communication::SoftBus::IpAndPort*)SoftBusMalloc(sizeof(Communication::SoftBus in HWTEST_F() [all...] |
/foundation/communication/dsoftbus/tests/core/connection/wifi_direct_cpp/ |
H A D | wifi_direct_mock.cpp | 24 return OHOS::SoftBus::WifiDirectInterfaceMock::GetMock()->AuthGetDeviceUuid(authId, uuid, size); in AuthGetDeviceUuid() 29 return OHOS::SoftBus::WifiDirectInterfaceMock::GetMock()->AuthPostTransData(authHandle, dataInfo); in AuthPostTransData() 34 return OHOS::SoftBus::WifiDirectInterfaceMock::GetMock()->RegAuthTransListener(module, listener); in RegAuthTransListener() 39 return OHOS::SoftBus::WifiDirectInterfaceMock::GetMock()->Hid2dGetChannelListFor5G(chanList, len); in Hid2dGetChannelListFor5G() 44 return OHOS::SoftBus::WifiDirectInterfaceMock::GetMock()->GetP2pEnableStatus(state); in GetP2pEnableStatus() 49 return OHOS::SoftBus::WifiDirectInterfaceMock::GetMock()->LnnGetLocalStrInfo(key, info, len); in LnnGetLocalStrInfo() 54 return OHOS::SoftBus::WifiDirectInterfaceMock::GetMock()->LnnSetLocalStrInfo(key, info); in LnnSetLocalStrInfo() 59 return OHOS::SoftBus::WifiDirectInterfaceMock::GetMock()->LnnSetLocalNumInfo(key, info); in LnnSetLocalNumInfo() 64 return OHOS::SoftBus::WifiDirectInterfaceMock::GetMock()->LnnGetLocalNumU64Info(key, info); in LnnGetLocalNumU64Info() 69 return OHOS::SoftBus in LnnSyncP2pInfo() 316 namespace OHOS::SoftBus { global() namespace in OHOS [all...] |
H A D | wifi_direct_manager_test.cpp | 32 namespace OHOS::SoftBus { namespace in OHOS 145 link.SetState(OHOS::SoftBus::InnerLink::LinkState::CONNECTED); in HWTEST_F() 167 link.SetState(OHOS::SoftBus::InnerLink::LinkState::CONNECTED); in HWTEST_F() 172 link.SetState(OHOS::SoftBus::InnerLink::LinkState::CONNECTED); in HWTEST_F() 199 link.SetState(OHOS::SoftBus::InnerLink::LinkState::CONNECTED); in HWTEST_F() 205 link.SetState(OHOS::SoftBus::InnerLink::LinkState::CONNECTED); in HWTEST_F() 213 link.SetState(OHOS::SoftBus::InnerLink::LinkState::CONNECTED); in HWTEST_F() 237 link.SetState(OHOS::SoftBus::InnerLink::LinkState::CONNECTED); in HWTEST_F() 260 link.SetState(OHOS::SoftBus::InnerLink::LinkState::CONNECTED); in HWTEST_F() 267 link.SetState(OHOS::SoftBus in HWTEST_F() [all...] |
/foundation/communication/dsoftbus/core/connection/wifi_direct_cpp/ |
H A D | wifi_direct_manager.cpp | 79 OHOS::SoftBus::WifiDirectDfx::SetLinkType(*info); in SetElementTypeExtra() 140 OHOS::SoftBus::DurationStatistic::GetInstance().Start(info->requestId, in ConnectDevice() 141 OHOS::SoftBus::DurationStatisticCalculatorFactory::GetInstance().NewInstance(info->connectType)); in ConnectDevice() 142 OHOS::SoftBus::DurationStatistic::GetInstance().Record(info->requestId, OHOS::SoftBus::TOTAL_START); in ConnectDevice() 148 int32_t ret = OHOS::SoftBus::WifiDirectRoleOption::GetInstance().GetExpectedRole( in ConnectDevice() 151 ret = OHOS::SoftBus::WifiDirectSchedulerFactory::GetInstance().GetScheduler().ConnectDevice(*info, *callback); in ConnectDevice() 162 return OHOS::SoftBus::WifiDirectSchedulerFactory::GetInstance().GetScheduler().CancelConnectDevice(*info); in CancelConnectDevice() 169 return OHOS::SoftBus::WifiDirectSchedulerFactory::GetInstance().GetScheduler().DisconnectDevice(*info, *callback); in DisconnectDevice() 178 info->linkType, OHOS::SoftBus in ForceDisconnectDevice() [all...] |
/foundation/communication/dsoftbus/tests/core/connection/fuzztest/softbusnegotiatemessage_fuzzer/ |
H A D | softbusnegotiatemessage_fuzzer.cpp | 55 SoftBus::NegotiateMessage msg; in SoftBusNegotiateMessageUnmarshallingFuzzTest() 56 SoftBus::NegotiateMessage msg1; in SoftBusNegotiateMessageUnmarshallingFuzzTest() 60 msg1.SetMessageType(GetData<SoftBus::NegotiateMessageType>()); in SoftBusNegotiateMessageUnmarshallingFuzzTest() 61 msg1.SetIpv4InfoArray({ GetData<SoftBus::Ipv4Info>(), GetData<SoftBus::Ipv4Info>() }); in SoftBusNegotiateMessageUnmarshallingFuzzTest() 65 SoftBus::InterfaceInfo interfaceInfo; in SoftBusNegotiateMessageUnmarshallingFuzzTest() 67 std::vector<SoftBus::InterfaceInfo> interfaceArray; in SoftBusNegotiateMessageUnmarshallingFuzzTest() 70 SoftBus::LinkInfo linkInfo1; in SoftBusNegotiateMessageUnmarshallingFuzzTest() 74 auto protocol1 = SoftBus::WifiDirectProtocolFactory::CreateProtocol(SoftBus in SoftBusNegotiateMessageUnmarshallingFuzzTest() [all...] |
/foundation/communication/dsoftbus/tests/sdk/transmission/fuzztest/streamcommondata_fuzzer/ |
H A D | streamcommondata_fuzzer.cpp | 30 if ((data == nullptr) || (size < Communication::SoftBus::MAX_STREAM_LEN)) { in InitStreamDataTest() 33 char *buf = new char[Communication::SoftBus::MAX_STREAM_LEN + 1]; in InitStreamDataTest() 38 if (memcpy_s(buf, Communication::SoftBus::MAX_STREAM_LEN + 1, in InitStreamDataTest() 39 data, Communication::SoftBus::MAX_STREAM_LEN) != EOK) { in InitStreamDataTest() 44 char *ext = new char[Communication::SoftBus::MAX_STREAM_LEN + 1]; in InitStreamDataTest() 51 if (memcpy_s(ext, Communication::SoftBus::MAX_STREAM_LEN + 1, in InitStreamDataTest() 52 data, Communication::SoftBus::MAX_STREAM_LEN) != EOK) { in InitStreamDataTest() 60 Communication::SoftBus::StreamCommonData streamcommondata; in InitStreamDataTest() 61 streamcommondata.InitStreamData(std::move(inputbuf), Communication::SoftBus::MAX_STREAM_LEN + 1, in InitStreamDataTest() 62 std::move(inputext), Communication::SoftBus in InitStreamDataTest() [all...] |
/foundation/communication/dsoftbus/tests/sdk/transmission/fuzztest/rawstreamdata_fuzzer/ |
H A D | rawstreamdata_fuzzer.cpp | 29 if ((data == nullptr) || (size < Communication::SoftBus::MAX_STREAM_LEN)) { in InitStreamDataTest() 32 char *buf = new char[Communication::SoftBus::MAX_STREAM_LEN + 1]; in InitStreamDataTest() 37 if (memcpy_s(buf, Communication::SoftBus::MAX_STREAM_LEN + 1, in InitStreamDataTest() 38 data, Communication::SoftBus::MAX_STREAM_LEN) != EOK) { in InitStreamDataTest() 43 char *ext = new char[Communication::SoftBus::MAX_STREAM_LEN + 1]; in InitStreamDataTest() 50 if (memcpy_s(ext, Communication::SoftBus::MAX_STREAM_LEN + 1, in InitStreamDataTest() 51 data, Communication::SoftBus::MAX_STREAM_LEN) != EOK) { in InitStreamDataTest() 59 Communication::SoftBus::RawStreamData rawstreamdata; in InitStreamDataTest() 60 rawstreamdata.InitStreamData(std::move(inputbuf), Communication::SoftBus::MAX_STREAM_LEN + 1, in InitStreamDataTest() 61 std::move(inputext), Communication::SoftBus in InitStreamDataTest() [all...] |
/foundation/communication/dsoftbus/tests/sdk/transmission/trans_channel/udp/stream/libsoftbus_stream/vtp_stream_socket_test/ |
H A D | vtp_stream_socket_test.cpp | 31 using namespace SoftBus; 73 Communication::SoftBus::IpAndPort *local = in HWTEST_F() 74 (Communication::SoftBus::IpAndPort*)SoftBusMalloc(sizeof(Communication::SoftBus::IpAndPort)); in HWTEST_F() 76 (void)memset_s(local, sizeof(Communication::SoftBus::IpAndPort), 0, sizeof(Communication::SoftBus::IpAndPort)); in HWTEST_F() 82 std::shared_ptr<Communication::SoftBus::VtpStreamSocket> vtpStreamSocket = in HWTEST_F() 83 std::make_shared<Communication::SoftBus::VtpStreamSocket>(); in HWTEST_F() 107 std::shared_ptr<Communication::SoftBus::VtpStreamSocket> vtpStreamSocket = in HWTEST_F() 108 std::make_shared<Communication::SoftBus in HWTEST_F() [all...] |
/foundation/communication/dsoftbus/tests/sdk/transmission/fuzztest/streammsgmanager_fuzzer/ |
H A D | streammsgmanager_fuzzer.cpp | 30 Communication::SoftBus::HistoryStats stats; in SendTest() 33 Communication::SoftBus::StreamMsgManager streamMsgManager; in SendTest() 34 streamMsgManager.Send((const Communication::SoftBus::HistoryStats &)stats); in SendTest() 42 Communication::SoftBus::HistoryStats stats; in RecvTest() 45 Communication::SoftBus::StreamMsgManager streamMsgManager; in RecvTest() 46 streamMsgManager.Recv((const Communication::SoftBus::HistoryStats &)stats); in RecvTest() 54 Communication::SoftBus::HistoryStats stats; in UpdateTest() 57 Communication::SoftBus::StreamMsgManager streamMsgManager; in UpdateTest() 58 streamMsgManager.Update((const Communication::SoftBus::HistoryStats &)stats); in UpdateTest()
|
/foundation/communication/dsoftbus/tests/sdk/transmission/trans_channel/udp/stream/libsoftbus_stream/stream_depacketizer_test/ |
H A D | stream_depacketizer_test.cpp | 65 int32_t streamType_ = Communication::SoftBus::COMMON_VIDEO_STREAM; in HWTEST_F() 66 std::shared_ptr<Communication::SoftBus::StreamDepacketizer> streamDepacketizer = in HWTEST_F() 67 std::make_shared<Communication::SoftBus::StreamDepacketizer>(streamType_); in HWTEST_F() 93 int32_t streamType_ = Communication::SoftBus::COMMON_VIDEO_STREAM; in HWTEST_F() 94 std::shared_ptr<Communication::SoftBus::StreamDepacketizer> streamDepacketizer = in HWTEST_F() 95 std::make_shared<Communication::SoftBus::StreamDepacketizer>(streamType_); in HWTEST_F() 97 char header[Communication::SoftBus::MAX_STREAM_LEN - OVERHEAD_LEN + 1] = {0}; in HWTEST_F() 98 char buffer[Communication::SoftBus::MAX_STREAM_LEN - OVERHEAD_LEN + 1] = {0}; in HWTEST_F() 102 streamDepacketizer->streamType_ = Communication::SoftBus::COMMON_VIDEO_STREAM; in HWTEST_F() 105 streamDepacketizer->streamType_ = Communication::SoftBus in HWTEST_F() [all...] |
/foundation/communication/dsoftbus/tests/sdk/transmission/fuzztest/streamdepacketizer_fuzzer/ |
H A D | streamdepacketizer_fuzzer.cpp | 31 if ((data == nullptr) || (size < Communication::SoftBus::MAX_STREAM_LEN - OVERHEAD_LEN)) { in DepacketizeHeaderTest() 34 char tmp[Communication::SoftBus::MAX_STREAM_LEN - OVERHEAD_LEN + 1] = {0}; in DepacketizeHeaderTest() 39 Communication::SoftBus::StreamDepacketizer decode(1); in DepacketizeHeaderTest() 45 if ((data == nullptr) || (size < Communication::SoftBus::MAX_STREAM_LEN - OVERHEAD_LEN)) { in DepacketizeBufferTest() 48 char tmp[Communication::SoftBus::MAX_STREAM_LEN - OVERHEAD_LEN + 1] = {0}; in DepacketizeBufferTest() 53 Communication::SoftBus::StreamDepacketizer decode(1); in DepacketizeBufferTest()
|
/foundation/communication/dsoftbus/tests/sdk/transmission/trans_channel/udp/stream/libsoftbus_stream/vtp_instance_test/ |
H A D | vtp_instance_test.cpp | 55 int32_t ret = Communication::SoftBus::UpdateVtpLogLevel(); in HWTEST_F() 67 std::shared_ptr<Communication::SoftBus::VtpInstance> vtpInstance = in HWTEST_F() 68 std::make_shared<Communication::SoftBus::VtpInstance>(); in HWTEST_F() 82 std::shared_ptr<Communication::SoftBus::VtpInstance> vtpInstance = in HWTEST_F() 83 std::make_shared<Communication::SoftBus::VtpInstance>(); in HWTEST_F() 98 std::shared_ptr<Communication::SoftBus::VtpInstance> vtpInstance = in HWTEST_F() 99 std::make_shared<Communication::SoftBus::VtpInstance>(); in HWTEST_F() 119 std::shared_ptr<Communication::SoftBus::VtpInstance> vtpInstance = in HWTEST_F() 120 std::make_shared<Communication::SoftBus::VtpInstance>(); in HWTEST_F()
|
/foundation/communication/dsoftbus/tests/sdk/transmission/trans_channel/manager/ |
H A D | client_trans_session_impl_test.cpp | 45 class ISessionListenerTest : public Communication::SoftBus::ISessionListener { 50 int32_t OnSessionOpened(std::shared_ptr<Communication::SoftBus::Session> session) in OnSessionOpened() 55 void OnSessionClosed(std::shared_ptr<Communication::SoftBus::Session> session) in OnSessionClosed() 60 void OnMessageReceived(std::shared_ptr<Communication::SoftBus::Session> session, const char *data, ssize_t len) in OnMessageReceived() 65 void OnBytesReceived(std::shared_ptr<Communication::SoftBus::Session> session, const char *data, ssize_t len) in OnBytesReceived() 70 bool OnDataAvailable(std::shared_ptr<Communication::SoftBus::Session> session, uint32_t status) in OnDataAvailable() 101 Communication::SoftBus::SessionServiceImpl testSessionServiceImpl; in HWTEST_F() 102 std::shared_ptr<Communication::SoftBus::ISessionListener> listern = std::make_shared<ISessionListenerTest>(); in HWTEST_F() 131 Communication::SoftBus::SessionServiceImpl testSessionServiceImpl; in HWTEST_F() 133 std::shared_ptr<Communication::SoftBus in HWTEST_F() [all...] |
/foundation/communication/dsoftbus/tests/sdk/transmission/trans_channel/udp/stream/libsoftbus_stream/raw_stream_data_test/ |
H A D | raw_stream_data_test.cpp | 32 using namespace SoftBus; 148 Communication::SoftBus::StreamData *data = in HWTEST_F() 149 (Communication::SoftBus::StreamData *)SoftBusCalloc(sizeof(Communication::SoftBus::StreamData)); in HWTEST_F() 151 Communication::SoftBus::StreamFrameInfo *info = in HWTEST_F() 152 (Communication::SoftBus::StreamFrameInfo *)SoftBusCalloc(sizeof(Communication::SoftBus::StreamFrameInfo)); in HWTEST_F() 180 Communication::SoftBus::StreamData *indata = in HWTEST_F() 181 (Communication::SoftBus::StreamData *)SoftBusCalloc(sizeof(Communication::SoftBus in HWTEST_F() [all...] |
/foundation/communication/dsoftbus/tests/sdk/transmission/fuzztest/vtpstreamsocket_fuzzer/ |
H A D | vtpstreamsocket_fuzzer.cpp | 26 Communication::SoftBus::VtpStreamSocket vtpStreamSocket; 35 Communication::SoftBus::IpAndPort ipPort; in VtpCreateClientTest() 49 Communication::SoftBus::IpAndPort ipPort; in VtpCreateServerTest() 70 Communication::SoftBus::IpAndPort ipPort; in VtpConnectTest() 81 Communication::SoftBus::StreamAttr tmp; in VtpSetOptionTest() 103 std::shared_ptr<Communication::SoftBus::IStreamSocketListener> receiver = nullptr; in VtpSetStreamListenerTest()
|
/foundation/communication/dsoftbus/tests/sdk/transmission/fuzztest/sessionserviceimpl_fuzzer/ |
H A D | sessionserviceimpl_fuzzer.cpp | 27 Communication::SoftBus::SessionServiceImpl sessionService; in SessionTest() 35 std::shared_ptr<Communication::SoftBus::Session> session = in SessionTest() 49 Communication::SoftBus::SessionServiceImpl sessionService; in RemovePermissionTest() 59 Communication::SoftBus::SessionServiceImpl sessionService; in ReceivedCallbackTest()
|
/foundation/communication/dsoftbus/tests/sdk/transmission/fuzztest/sessionimpl_fuzzer/ |
H A D | sessionimpl_fuzzer.cpp | 26 Communication::SoftBus::SessionImpl session; in SessionTest() 42 Communication::SoftBus::SessionImpl session; in SetOpeTest() 61 Communication::SoftBus::SessionImpl session; in SendBytesTest()
|
/foundation/communication/dsoftbus/sdk/transmission/trans_channel/udp/stream/adaptor/src/ |
H A D | client_trans_udp_stream_interface.cpp | 37 Communication::SoftBus::StreamFrameInfo *outFrameInfo) in ConvertStreamFrameInfo() 42 outFrameInfo->frameType = (Communication::SoftBus::FrameType)(inFrameInfo->frameType); in ConvertStreamFrameInfo() 55 stream = IStream::MakeRawStream(buf, bufLen, {}, Communication::SoftBus::Scene::SOFTBUS_SCENE); in CreateRawStream() 68 stream = IStream::MakeRawStream(data.get(), dataLen, {}, Communication::SoftBus::Scene::SOFTBUS_SCENE); in CreateRawStream() 82 if (inData->bufLen < 0 || inData->bufLen > Communication::SoftBus::MAX_STREAM_LEN || in ProcessAdaptorAndEncrypt() 83 (ext != nullptr && (ext->bufLen < 0 || ext->bufLen > Communication::SoftBus::MAX_STREAM_LEN))) { in ProcessAdaptorAndEncrypt() 86 Communication::SoftBus::StreamData data = { in ProcessAdaptorAndEncrypt() 106 Communication::SoftBus::StreamFrameInfo outFrameInfo; in ProcessAdaptorAndEncrypt() 194 Communication::SoftBus::IpAndPort ipPort; in StartVtpStreamChannelServer() 198 int32_t ret = newAdaptor->GetStreamManager()->CreateStreamServerChannel(ipPort, Communication::SoftBus in StartVtpStreamChannelServer() [all...] |
/foundation/communication/dsoftbus/core/common/dfx/statistics/instant/ |
H A D | wifi_statistic.cpp | 70 OHOS::SoftBus::WifiDirectAnonymizeMac(wifiLinkedInfo.bssid).c_str()); in GetStaInfo() 113 OHOS::SoftBus::WifiDirectAnonymizeMac(stationList[i].bssid).c_str()); in GetSoftApInfo() 146 OHOS::SoftBus::WifiDirectAnonymizeMac(groupInfo.GetOwner().GetRandomDeviceAddress()).c_str()); in GetP2PInfo() 158 OHOS::SoftBus::WifiDirectAnonymizeMac(gcList[i].GetRandomDeviceAddress()).c_str()); in GetP2PInfo() 166 } // namespace SoftBus
|
/foundation/communication/dsoftbus/tests/core/connection/wifi_direct_cpp/entity/ |
H A D | p2p_connect_state_test.cpp | 31 OHOS::SoftBus::P2pConnectState *g_p2pConnectStateInstance;
32 namespace OHOS::SoftBus {
namespace in OHOS
|
H A D | p2p_available_state_test.cpp | 29 OHOS::SoftBus::P2pAvailableState *g_p2pAvailableStateInstance;
30 namespace OHOS::SoftBus {
namespace in OHOS
|
/foundation/communication/dsoftbus/tests/core/connection/fuzztest/wifidirectprotocol_fuzzer/ |
H A D | protocol_fuzzer.cpp | 27 namespace OHOS::SoftBus { namespace in OHOS 82 } // namespace OHOS::SoftBus 86 OHOS::SoftBus::JsonProtocolParseFuzzTest(data, size); in LLVMFuzzerTestOneInput() 87 OHOS::SoftBus::TlvProtocolParseFuzzTest(data, size); in LLVMFuzzerTestOneInput()
|
H A D | protocol_fuzzer.h | 21 namespace OHOS::SoftBus { namespace in OHOS
|
/foundation/communication/dsoftbus/core/connection/wifi_direct_cpp/event/ |
H A D | wifi_direct_event_base.h | 18 namespace OHOS::SoftBus { namespace in OHOS
|
/foundation/communication/dsoftbus/sdk/transmission/trans_channel/udp/stream/adaptor/include/ |
H A D | stream_adaptor.h | 52 std::shared_ptr<Communication::SoftBus::IStreamManager> GetStreamManager(); 63 std::shared_ptr<Communication::SoftBus::IStreamManager> streamManager_ = nullptr;
|