| /ohos5.0/foundation/communication/dsoftbus/sdk/transmission/trans_channel/udp/stream/libsoftbus_stream/include/ |
| H A D | i_stream.h | 46 class IStream {
48 IStream() = default;
49 virtual ~IStream() = default;
51 static std::unique_ptr<IStream> MakeCommonStream(StreamData &data, const StreamFrameInfo &info);
52 static std::unique_ptr<IStream> MakeSliceStream(StreamData &data, const StreamFrameInfo &info);
53 static std::unique_ptr<IStream> MakeRawStream(StreamData &data, const StreamFrameInfo &info);
54 …static std::unique_ptr<IStream> MakeRawStream(const char *buf, ssize_t bufLen, const StreamFrameIn…
|
| H A D | i_stream_manager.h | 33 virtual void OnStreamReceived(std::unique_ptr<IStream> stream) = 0;
64 virtual bool Send(std::unique_ptr<IStream>) = 0;
|
| /ohos5.0/foundation/communication/dsoftbus/sdk/transmission/trans_channel/udp/stream/libsoftbus_stream/ |
| H A D | i_stream_socket.h | 38 virtual void OnStreamReceived(std::unique_ptr<IStream> stream) = 0;
75 virtual bool Send(std::unique_ptr<IStream> stream) = 0;
100 virtual std::unique_ptr<IStream> TakeStream() in TakeStream()
114 virtual void PutStream(std::unique_ptr<IStream> stream) in PutStream()
143 std::queue<std::unique_ptr<IStream>> streamReceiveBuffer_;
|
| H A D | raw_stream_data.cpp | 26 std::unique_ptr<IStream> IStream::MakeRawStream(StreamData &data, const StreamFrameInfo &info) in MakeRawStream()
35 std::unique_ptr<IStream> IStream::MakeRawStream(const char *buf, ssize_t bufLen, const StreamFrameI… in MakeRawStream()
|
| H A D | stream_packetizer.h | 29 StreamPacketizer(int streamType, std::unique_ptr<IStream> data) in StreamPacketizer()
54 std::unique_ptr<IStream> originData_ = nullptr;
|
| H A D | stream_common_data.cpp | 22 std::unique_ptr<IStream> IStream::MakeCommonStream(StreamData &data, const StreamFrameInfo &info) in MakeCommonStream()
|
| H A D | stream_manager.h | 42 void OnStreamReceived(std::unique_ptr<IStream> stream) override in OnStreamReceived()
89 bool Send(std::unique_ptr<IStream> data) override;
|
| H A D | vtp_stream_socket.h | 66 bool Send(std::unique_ptr<IStream> stream) override;
107 …bool EncryptStreamPacket(std::unique_ptr<IStream> stream, std::unique_ptr<char[]> &data, ssize_t &…
118 std::unique_ptr<IStream> MakeStreamData(StreamData &data, const StreamFrameInfo &info) const;
|
| H A D | raw_stream_data.h | 27 class RawStreamData : public IStream {
|
| H A D | stream_common_data.h | 30 class StreamCommonData : public IStream {
|
| H A D | vtp_stream_socket.cpp | 591 bool VtpStreamSocket::EncryptStreamPacket(std::unique_ptr<IStream> stream, std::unique_ptr<char[]> … in EncryptStreamPacket()
614 bool VtpStreamSocket::Send(std::unique_ptr<IStream> stream) in Send()
1026 std::unique_ptr<IStream> VtpStreamSocket::MakeStreamData(StreamData &data, const StreamFrameInfo &i… in MakeStreamData()
1028 std::unique_ptr<IStream> stream = nullptr; in MakeStreamData()
1038 stream = IStream::MakeCommonStream(data, info); in MakeStreamData()
1042 stream = IStream::MakeRawStream(data, info); in MakeStreamData()
1155 std::unique_ptr<IStream> stream = MakeStreamData(data, info); in DoStreamRecv()
|
| /ohos5.0/drivers/peripheral/camera/vdi_base/v4l2/include/stream_operator/ |
| H A D | capture_request.h | 28 class IStream; variable
35 RetCode AddOwner(const std::weak_ptr<IStream>& owner);
75 std::map<int32_t, std::weak_ptr<IStream>> owners_ = {};
|
| H A D | istream.h | 37 class IStream {
39 virtual ~IStream() = default;
62 using StreamFactory = RegisterFactoty<IStream,
|
| H A D | stream_base.h | 26 class StreamBase : public IStream, public std::enable_shared_from_this<StreamBase> {
|
| H A D | stream_operator_vdi_impl.h | 82 std::unordered_map<int32_t, std::shared_ptr<IStream>> streamMap_ = {};
|
| /ohos5.0/foundation/communication/dsoftbus/sdk/transmission/trans_channel/udp/stream/adaptor/src/ |
| H A D | client_trans_udp_stream_interface.cpp | 50 std::unique_ptr<IStream> &stream) in CreateRawStream()
55 … stream = IStream::MakeRawStream(buf, bufLen, {}, Communication::SoftBus::Scene::SOFTBUS_SCENE); in CreateRawStream()
68 …stream = IStream::MakeRawStream(data.get(), dataLen, {}, Communication::SoftBus::Scene::SOFTBUS_SC… in CreateRawStream()
73 … std::shared_ptr<StreamAdaptor> &adaptor, std::unique_ptr<IStream> &stream, const StreamData *ext) in ProcessAdaptorAndEncrypt()
108 stream = IStream::MakeCommonStream(data, outFrameInfo); in ProcessAdaptorAndEncrypt()
133 std::unique_ptr<IStream> stream = nullptr; in SendVtpStream()
|
| /ohos5.0/foundation/communication/dsoftbus/tests/sdk/transmission/trans_channel/udp/stream/libsoftbus_stream/raw_stream_data_test/ |
| H A D | raw_stream_data_test.cpp | 146 std::shared_ptr<IStream> iStream;
155 std::unique_ptr<IStream> tmpIStream = nullptr;
175 std::shared_ptr<IStream> iStream;
178 std::unique_ptr<IStream> tmpIStream = nullptr;
|
| /ohos5.0/foundation/communication/dsoftbus/tests/sdk/transmission/trans_channel/udp/stream/libsoftbus_stream/stream_packetizer_test/ |
| H A D | stream_packetizer_test.cpp | 95 std::unique_ptr<IStream> stream = IStream::MakeCommonStream(data, frameInfo);
|
| /ohos5.0/foundation/communication/dsoftbus/sdk/transmission/trans_channel/udp/stream/adaptor/include/ |
| H A D | stream_adaptor_listener.h | 25 using Communication::SoftBus::IStream;
45 void OnStreamReceived(std::unique_ptr<IStream> stream) override in OnStreamReceived()
|
| /ohos5.0/foundation/multimedia/audio_framework/services/audio_service/server/include/ |
| H A D | i_capturer_stream.h | 30 class ICapturerStream : public IStream {
|
| H A D | i_stream.h | 63 class IStream {
|
| H A D | i_renderer_stream.h | 30 class IRendererStream : public IStream {
|
| /ohos5.0/drivers/peripheral/camera/vdi_base/v4l2/src/stream_operator/ |
| H A D | stream_operator_vdi_impl.cpp | 240 std::shared_ptr<IStream> stream = StreamFactory::Instance().CreateShared( in CreateStreams()
241 … IStream::g_availableStreamType[it.intent_], it.streamId_, it.intent_, pipelineCore_, messenger_); in CreateStreams()
268 IStream::g_availableStreamType[it.intent_].c_str()); in CreateStreams()
403 std::shared_ptr<IStream> stream = nullptr; in AttachBufferQueue()
438 std::shared_ptr<IStream> stream = nullptr; in DetachBufferQueue()
|
| H A D | capture_request.cpp | 40 RetCode CaptureRequest::AddOwner(const std::weak_ptr<IStream>& owner) in AddOwner()
|
| /ohos5.0/foundation/communication/dsoftbus/tests/sdk/transmission/trans_channel/udp/stream/libsoftbus_stream/stream_common_data_test/ |
| H A D | stream_common_data_test.cpp | 107 std::unique_ptr<IStream> tmpIStream = nullptr;
|