| /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 in HWTEST_F()
[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 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 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 | 30 using namespace Communication;
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 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 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 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 | 31 using namespace Communication;
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 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 in StartVtpStreamChannelServer()
[all...] |
| /foundation/communication/dsoftbus/tests/sdk/transmission/trans_channel/udp/stream/libsoftbus_stream/stream_msg_manager_test/ |
| H A D | stream_msg_manager_test.cpp | 38 using namespace Communication;
39 using namespace Communication::SoftBus;
|
| /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;
|
| H A D | stream_adaptor_listener.h | 24 using Communication::SoftBus::IStreamManagerListener;
25 using Communication::SoftBus::IStream;
34 const Communication::SoftBus::StreamFrameInfo *inFrameInfo) in ConvertStreamFrameInfo()
|
| /foundation/communication/dsoftbus/sdk/transmission/session/cpp/src/ |
| H A D | session_callback_mock.cpp | 21 using namespace Communication::SoftBus;
|
| /foundation/communication/dsoftbus/sdk/transmission/trans_channel/udp/stream/libsoftbus_stream/ |
| H A D | stream_msg_manager.cpp | 18 namespace Communication { namespace
45 } // namespace Communication
|
| H A D | stream_msg_manager.h | 25 namespace Communication { namespace
41 } // namespace Communication
|
| H A D | stream_packetizer.h | 25 namespace Communication { namespace
58 } // namespace Communication
|
| H A D | common_inner.h | 22 namespace Communication { namespace
94 } // namespace Communication
|
| /foundation/communication/dsoftbus/core/common/dfx/statistics/include/ |
| H A D | wifi_statistic.h | 22 namespace Communication { namespace
38 } // namespace Communication
|
| /foundation/communication/dsoftbus/sdk/transmission/trans_channel/udp/stream/libsoftbus_stream/include/ |
| H A D | i_stream_msg_manager.h | 23 namespace Communication { namespace
47 } // namespace Communication
|
| /foundation/communication/dsoftbus/sdk/transmission/session/cpp/include/ |
| H A D | ISessionListener.h | 23 namespace Communication { namespace
41 } // namespace Communication
|