Home
last modified time | relevance | path

Searched refs:rtp (Results 1 - 19 of 19) sorted by relevance

/foundation/CastEngine/castengine_wifi_display/services/protocol/rtp/src/
H A Drtp_codec_h264.cpp47 void RtpDecoderH264::InputRtp(const RtpPacket::Ptr &rtp) in InputRtp() argument
49 RETURN_IF_NULL(rtp); in InputRtp()
50 auto frame = rtp->GetPayload(); in InputRtp()
51 int32_t length = rtp->GetPayloadSize(); in InputRtp()
52 auto stamp = rtp->GetStampMS(); in InputRtp()
53 auto seq = rtp->GetSeq(); in InputRtp()
60 UnpackStapA(rtp, frame + 1, length - 1, stamp); in InputRtp()
63 UnpackFuA(rtp, frame, length, stamp, seq); in InputRtp()
68 UnpackSingle(rtp, frame, length, stamp); in InputRtp()
87 bool RtpDecoderH264::UnpackSingle(const RtpPacket::Ptr &rtp, cons argument
100 UnpackStapA(const RtpPacket::Ptr &rtp, const uint8_t *ptr, ssize_t size, uint32_t stamp) UnpackStapA() argument
123 UnpackFuA(const RtpPacket::Ptr &rtp, const uint8_t *ptr, ssize_t size, uint32_t stamp, uint16_t seq) UnpackFuA() argument
168 OutputFrame(const RtpPacket::Ptr &rtp, const H264Frame::Ptr &frame) OutputFrame() argument
269 auto rtp = MakeRtp(nullptr, packetSize + 2, fuFlags->endBit_ && isMark, pts); // 2:fixed size PackRtpFu() local
291 auto rtp = MakeRtp(nullptr, len + 3, isMark, pts); // 3:fixed size PackRtpStapA() local
309 auto rtp = MakeRtp(data, len, isMark, pts); PackSingle() local
[all...]
H A Drtp_queue.cpp34 // hilog rtp packet is too small in InputRtp()
37 // todo jduge rtp size in InputRtp()
50 auto rtp = std::make_shared<RtpPacket>(); in InputRtp() local
51 rtp->ReplaceData(reinterpret_cast<char*>(ptr), len); in InputRtp()
52 rtp->sampleRate_ = sampleRate_; in InputRtp()
53 rtp->type_ = type; in InputRtp()
55 if (rtp->Size() != len) { in InputRtp()
58 MEDIA_LOGD("rtp payload size: %{public}zu.", rtp->GetPayloadSize()); in InputRtp()
60 if (ssrc_ != rtp in InputRtp()
[all...]
H A Drtp_unpack_impl.cpp77 void RtpUnpackImpl::OnRtpSorted(uint16_t seq, const RtpPacket::Ptr &rtp) in OnRtpSorted() argument
79 RETURN_IF_NULL(rtp); in OnRtpSorted()
80 if (rtpDecoder_[rtp->GetHeader()->pt_]) { in OnRtpSorted()
81 MEDIA_LOGD("rtpUnpackImpl::OnRtpSorted seq: %{public}d, pt: %{public}d.", rtp->GetSeq(), rtp->GetHeader()->pt_); in OnRtpSorted()
86 nextOutSeq_ = rtp->GetSeq() + 1; in OnRtpSorted()
89 rtpDecoder_[rtp->GetHeader()->pt_]->InputRtp(rtp); in OnRtpSorted()
H A Drtp_maker.cpp50 auto rtp = std::make_shared<RtpPacket>(); in MakeRtp() local
51 rtp->SetCapacity(size); in MakeRtp()
52 rtp->SetSize(size); in MakeRtp()
54 auto header = rtp->GetHeader(); in MakeRtp()
67 auto rtpData = rtp->Data(); in MakeRtp()
75 return rtp; in MakeRtp()
H A Drtp_codec_g711.cpp27 void RtpDecoderG711::InputRtp(const RtpPacket::Ptr &rtp) in InputRtp() argument
29 RETURN_IF_NULL(rtp); in InputRtp()
31 auto payload_size = rtp->GetPayloadSize(); in InputRtp()
35 auto payload = rtp->GetPayload(); in InputRtp()
36 auto stamp = rtp->GetStampMS(); in InputRtp()
37 auto seq = rtp->GetSeq(); in InputRtp()
49 MEDIA_LOGD("rtp lose: %{public}d -> %{public}d.", lastSeq_, seq); in InputRtp()
H A Drtp_codec_aac.cpp43 void RtpDecoderAAC::InputRtp(const RtpPacket::Ptr &rtp) in InputRtp() argument
45 RETURN_IF_NULL(rtp); in InputRtp()
47 auto stamp = rtp->GetStampMS(); in InputRtp()
49 auto ptr = rtp->GetPayload(); in InputRtp()
51 auto end = ptr + rtp->GetPayloadSize(); in InputRtp()
70 rtp->GetSeq(), rtp->GetPayloadSize(), auHeaderCount, stamp, dtsInc_); in InputRtp()
216 auto rtp = MakeRtp(data, len, mark, stamp); in MakeAACRtp() local
218 onRtpPack_(rtp); in MakeAACRtp()
H A Drtp_pack_impl.cpp63 rtpEncoder_->SetOnRtpPack([this](const RtpPacket::Ptr &rtp) { onRtpPack_(rtp); }); in InitEncoder()
H A Drtp_codec_ts.cpp66 void RtpDecoderTs::InputRtp(const RtpPacket::Ptr &rtp) in InputRtp() argument
69 RETURN_IF_NULL(rtp); in InputRtp()
78 auto payload_size = rtp->GetPayloadSize(); in InputRtp()
84 dataQueue_.emplace(rtp); in InputRtp()
184 auto &rtp = dataQueue_.front(); in ReadPacket() local
185 auto data = rtp->GetPayload(); in ReadPacket()
186 int length = rtp->GetPayloadSize(); in ReadPacket()
188 SHARING_LOGE("rtp length exceed buf_size!"); in ReadPacket()
406 auto rtp = in WritePacket() local
408 encoder->onRtpPack_(rtp); in WritePacket()
[all...]
/foundation/CastEngine/castengine_wifi_display/tests/unittest/protocol/rtp/
H A Drtp_unit_test.cpp20 #include "protocol/rtp/include/adts.h"
21 #include "protocol/rtp/include/rtp_codec_aac.h"
22 #include "protocol/rtp/include/rtp_codec_g711.h"
23 #include "protocol/rtp/include/rtp_codec_h264.h"
24 #include "protocol/rtp/include/rtp_codec_ts.h"
25 #include "protocol/rtp/include/rtp_factory.h"
26 #include "protocol/rtp/include/rtp_maker.h"
27 #include "protocol/rtp/include/rtp_pack.h"
28 #include "protocol/rtp/include/rtp_pack_impl.h"
29 #include "protocol/rtp/includ
123 const auto rtp = std::make_shared<RtpPacket>(); HWTEST_F() local
225 const auto rtp = std::make_shared<RtpPacket>(); HWTEST_F() local
311 const auto rtp = std::make_shared<RtpPacket>(); HWTEST_F() local
355 const auto rtp = std::make_shared<RtpPacket>(); HWTEST_F() local
367 const auto rtp = std::make_shared<RtpPacket>(); HWTEST_F() local
395 const auto rtp = std::make_shared<RtpPacket>(); HWTEST_F() local
424 const auto rtp = std::make_shared<RtpPacket>(); HWTEST_F() local
599 const auto rtp = std::make_shared<RtpPacket>(); HWTEST_F() local
630 const auto rtp = std::make_shared<RtpPacket>(); HWTEST_F() local
1184 auto rtp = std::make_shared<RtpPacket>(); HWTEST_F() local
[all...]
/foundation/CastEngine/castengine_wifi_display/tests/demo/rtp/
H A Drtp_enc_demo.cpp290 aacPack->SetOnRtpPack([=](const RtpPacket::Ptr &rtp) { in main()
291 printf("rtp packed seq: %d, timestamp: %d, size: %d", rtp->GetSeq(), rtp->GetStamp(), rtp->Size()); in main()
292 SendRTP((char *)rtp->Data(), rtp->Size()); in main()
308 avcPack->SetOnRtpPack([=](const RtpPacket::Ptr &rtp) { in main()
309 printf("rtp packed seq: %d, timestamp: %d, size: %d", rtp in main()
[all...]
H A Dh264_rtp_dec_demo.cpp89 const char *aacrtp = "/aac.rtp"; in main()
98 aacPack->SetOnRtpPack([=](const RtpPacket::Ptr &rtp) { in main()
99 printf("rtp packed seq: %d, timestamp: %d, size: %d\n", rtp->GetSeq(), rtp->GetStamp(), rtp->Size()); in main()
100 fwrite(rtp->Data(), rtp->Size(), 1, faacrtp); in main()
/foundation/CastEngine/castengine_wifi_display/services/protocol/rtp/include/
H A Drtp_codec_h264.h33 void InputRtp(const RtpPacket::Ptr &rtp) override;
39 bool UnpackStapA(const RtpPacket::Ptr &rtp, const uint8_t *ptr, ssize_t size, uint32_t stamp);
40 bool UnpackSingle(const RtpPacket::Ptr &rtp, const uint8_t *ptr, ssize_t size, uint32_t stamp);
41 bool UnpackFuA(const RtpPacket::Ptr &rtp, const uint8_t *ptr, ssize_t size, uint32_t stamp, uint16_t seq);
43 void OutputFrame(const RtpPacket::Ptr &rtp, const H264Frame::Ptr &frame);
H A Drtp_codec.h31 virtual void InputRtp(const RtpPacket::Ptr &rtp) = 0;
44 using OnRtpPack = std::function<void(const RtpPacket::Ptr &rtp)>;
H A Drtp_pack.h27 // Pack a rtp packget callback
28 using OnRtpPack = std::function<void(const RtpPacket::Ptr &rtp)>;
38 * @param cb pack a rtp packget callback
H A Drtp_unpack_impl.h41 void OnRtpSorted(uint16_t seq, const RtpPacket::Ptr &rtp);
H A Drtp_codec_aac.h36 void InputRtp(const RtpPacket::Ptr &rtp) override;
H A Drtp_codec_g711.h32 void InputRtp(const RtpPacket::Ptr &rtp) override;
H A Drtp_codec_ts.h41 void InputRtp(const RtpPacket::Ptr &rtp) override;
/foundation/CastEngine/castengine_wifi_display/services/impl/wfd/wfd_source/
H A Dwfd_rtp_producer.cpp217 SHARING_LOGE("init rtp packer failed."); in ProducerInit()
239 tsPacker_->SetOnRtpPack([=](const RtpPacket::Ptr &rtp) { in InitTsRtpPacker()
240 MEDIA_LOGD("rtp packed seq: %{public}d timestamp: %{public}d size: %{public}d.", rtp->GetSeq(), rtp->GetStamp(), in InitTsRtpPacker()
241 rtp->Size()); in InitTsRtpPacker()
242 SendDataBuffer(rtp); in InitTsRtpPacker()

Completed in 12 milliseconds