Zlmediakit 接收到 rtc包后的处理流程

2023-12-16 09:04

本文主要是介绍Zlmediakit 接收到 rtc包后的处理流程,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

 

客户端通过rtc 推流(视频为h264)到 ZlmediaKit 时,ZlmediaKit收到包后,到进行rtp 包排序的流程堆栈,方便了解逻辑

#0  mediakit::RtspMediaSourceImp::onWrite (this=0x7fffd0009d68, rtp=..., key_pos=false) at /root/src/tantao/cmds_master/cmds/src/Rtsp/RtspMediaSourceImp.h:55
#1  0x00000000015d9da9 in WebRtcPusher::onRecvRtp (this=0x7fffd001e890, track=..., rid=..., rtp=...) at /root/src/tantao/cmds_master/cmds/webrtc/WebRtcPusher.cpp:84
#2  0x0000000001527f7a in WebRtcTransportImp::onSortedRtp (this=0x7fffd001e890, track=..., rid=..., rtp=...) at /root/src/tantao/cmds_master/cmds/webrtc/WebRtcTransport.cpp:1077
#3  0x0000000001526ccc in WebRtcTransportImp::__lambda95::operator() (__closure=0x7fffd0024580, rtp=...) at /root/src/tantao/cmds_master/cmds/webrtc/WebRtcTransport.cpp:924
#4  0x00000000015323a6 in std::_Function_handler<void(std::shared_ptr<mediakit::RtpPacket>), WebRtcTransportImp::createRtpChannel(const string&, uint32_t, MediaTrack&)::__lambda95>::_M_invoke(const std::_Any_data &, std::shared_ptr<mediakit::RtpPacket>) (__functor=..., __args#0=...) at /usr/include/c++/4.8.2/functional:2071
#5  0x00000000014acca0 in std::function<void (std::shared_ptr<mediakit::RtpPacket>)>::operator()(std::shared_ptr<mediakit::RtpPacket>) const (this=0x7fffd0004440, __args#0=...)
    at /usr/include/c++/4.8.2/functional:2471
#6  0x00000000014ab531 in mediakit::RtpTrackImp::onRtpSorted (this=0x7fffd0004388, rtp=...) at /root/src/tantao/cmds_master/cmds/src/Rtsp/RtpReceiver.cpp:142
#7  0x00000000014aa499 in mediakit::RtpTrack::RtpTrack()::{lambda(unsigned short, std::shared_ptr<mediakit::RtpPacket>&)#1}::operator()(unsigned short, std::shared_ptr<mediakit::RtpPacket>&) const () at /root/src/tantao/cmds_master/cmds/src/Rtsp/RtpReceiver.cpp:18
#8  0x00000000014ab7ed in std::_Function_handler<void(short unsigned int, std::shared_ptr<mediakit::RtpPacket>&), mediakit::RtpTrack::RtpTrack()::__lambda25>::_M_invoke(const std::_Any_data &, unsigned short, std::shared_ptr<mediakit::RtpPacket> &) (__functor=..., __args#0=6408, __args#1=...) at /usr/include/c++/4.8.2/functional:2071
#9  0x00000000014adb11 in std::function<void (unsigned short, std::shared_ptr<mediakit::RtpPacket>&)>::operator()(unsigned short, std::shared_ptr<mediakit::RtpPacket>&) const (
    this=0x7fffd00043d8, __args#0=6408, __args#1=...) at /usr/include/c++/4.8.2/functional:2471
#10 0x00000000014ada1b in mediakit::PacketSortor<std::shared_ptr<mediakit::RtpPacket>, unsigned short, 1024ul, 32ul>::popIterator (this=0x7fffd0004390, it=...)
    at /root/src/tantao/cmds_master/cmds/src/Rtsp/RtpReceiver.h:123
#11 0x00000000014ad366 in mediakit::PacketSortor<std::shared_ptr<mediakit::RtpPacket>, unsigned short, 1024ul, 32ul>::popPacket (this=0x7fffd0004390)
    at /root/src/tantao/cmds_master/cmds/src/Rtsp/RtpReceiver.h:92
#12 0x00000000014acf76 in mediakit::PacketSortor<std::shared_ptr<mediakit::RtpPacket>, unsigned short, 1024ul, 32ul>::tryPopPacket (this=0x7fffd0004390)
    at /root/src/tantao/cmds_master/cmds/src/Rtsp/RtpReceiver.h:144
#13 0x00000000014acafd in mediakit::PacketSortor<std::shared_ptr<mediakit::RtpPacket>, unsigned short, 1024ul, 32ul>::sortPacket (this=0x7fffd0004390, seq=6440, packet=...)
    at /root/src/tantao/cmds_master/cmds/src/Rtsp/RtpReceiver.h:77
#14 0x00000000014ab1aa in mediakit::RtpTrack::inputRtp (this=0x7fffd0004388, type=mediakit::TrackAudio, sample_rate=8000, 
    ptr=0x1ee23b0 "\220\b\031(\244=\227Hd\246\241\006\276", <incomplete sequence \336>, len=192, absCaptureTime=186608650860798725)
    at /root/src/tantao/cmds_master/cmds/src/Rtsp/RtpReceiver.cpp:113
#15 0x00000000015352c6 in RtpChannel::inputRtp (this=0x7fffd0004388, type=mediakit::TrackAudio, sample_rate=8000, 
    ptr=0x1ee23b0 "\220\b\031(\244=\227Hd\246\241\006\276", <incomplete sequence \336>, len=192, is_rtx=false) at /root/src/tantao/cmds_master/cmds/webrtc/WebRtcTransport.cpp:704
#16 0x0000000001527607 in WrappedRtpTrack::inputRtp (this=0x7fffd0002d00, buf=0x1ee23b0 "\220\b\031(\244=\227Hd\246\241\006\276", <incomplete sequence \336>, len=192, stamp_ms=764, 
    rtp=0x1ee23b0) at /root/src/tantao/cmds_master/cmds/webrtc/WebRtcTransport.cpp:995
#17 0x000000000152745d in WebRtcTransportImp::onRtp (this=0x7fffd001e890, buf=0x1ee23b0 "\220\b\031(\244=\227Hd\246\241\006\276", <incomplete sequence \336>, len=192, stamp_ms=764)
    at /root/src/tantao/cmds_master/cmds/webrtc/WebRtcTransport.cpp:967
#18 0x0000000001521e9b in WebRtcTransport::inputSockData (this=0x7fffd001e890, buf=0x1ee23b0 "\220\b\031(\244=\227Hd\246\241\006\276", <incomplete sequence \336>, len=192, 
    tuple=0x7fffd0033978) at /root/src/tantao/cmds_master/cmds/webrtc/WebRtcTransport.cpp:331
#19 0x000000000151db17 in WebRtcSession::onRecv (this=0x7fffd00338a8, buffer=...) at /root/src/tantao/cmds_master/cmds/webrtc/WebRtcSession.cpp:70
#20 0x0000000001178df6 in toolkit::emitSessionRecv (session=..., buf=...) at /root/src/tantao/cmds_master/cmds/3rdpart/ZLToolKit/src/Network/UdpServer.cpp:134
#21 0x0000000001179a9f in toolkit::UdpServer::__lambda14::__lambda15::operator() (__closure=0x7fffd0002730, buf=..., addr=0x7fffe9dde760, addr_len=28)
    at /root/src/tantao/cmds_master/cmds/3rdpart/ZLToolKit/src/Network/UdpServer.cpp:257
#22 0x000000000117bc44 in std::_Function_handler<void(const std::shared_ptr<toolkit::Buffer>&, sockaddr*, int), toolkit::UdpServer::createSession(const PeerIdType&, const Ptr&, sockaddr*, int)::__lambda14::__lambda15>::_M_invoke(const std::_Any_data &, const std::shared_ptr<toolkit::Buffer> &, sockaddr *, int) (__functor=..., __args#0=..., __args#1=0x7fffe9dde760, 
    __args#2=28) at /usr/include/c++/4.8.2/functional:2071
#23 0x0000000001162e5b in std::function<void (std::shared_ptr<toolkit::Buffer> const&, sockaddr*, int)>::operator()(std::shared_ptr<toolkit::Buffer> const&, sockaddr*, int) const (
    this=0x7fffc8001b00, __args#0=..., __args#1=0x7fffe9dde760, __args#2=28) at /usr/include/c++/4.8.2/functional:2471

 

这篇关于Zlmediakit 接收到 rtc包后的处理流程的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/499936

相关文章

Nginx分布式部署流程分析

《Nginx分布式部署流程分析》文章介绍Nginx在分布式部署中的反向代理和负载均衡作用,用于分发请求、减轻服务器压力及解决session共享问题,涵盖配置方法、策略及Java项目应用,并提及分布式事... 目录分布式部署NginxJava中的代理代理分为正向代理和反向代理正向代理反向代理Nginx应用场景

解决docker目录内存不足扩容处理方案

《解决docker目录内存不足扩容处理方案》文章介绍了Docker存储目录迁移方法:因系统盘空间不足,需将Docker数据迁移到更大磁盘(如/home/docker),通过修改daemon.json配... 目录1、查看服务器所有磁盘的使用情况2、查看docker镜像和容器存储目录的空间大小3、停止dock

Spring Boot分层架构详解之从Controller到Service再到Mapper的完整流程(用户管理系统为例)

《SpringBoot分层架构详解之从Controller到Service再到Mapper的完整流程(用户管理系统为例)》本文将以一个实际案例(用户管理系统)为例,详细解析SpringBoot中Co... 目录引言:为什么学习Spring Boot分层架构?第一部分:Spring Boot的整体架构1.1

5 种使用Python自动化处理PDF的实用方法介绍

《5种使用Python自动化处理PDF的实用方法介绍》自动化处理PDF文件已成为减少重复工作、提升工作效率的重要手段,本文将介绍五种实用方法,从内置工具到专业库,帮助你在Python中实现PDF任务... 目录使用内置库(os、subprocess)调用外部工具使用 PyPDF2 进行基本 PDF 操作使用

nodejs打包作为公共包使用的完整流程

《nodejs打包作为公共包使用的完整流程》在Node.js项目中,打包和部署是发布应用的关键步骤,:本文主要介绍nodejs打包作为公共包使用的相关资料,文中通过代码介绍的非常详细,需要的朋友可... 目录前言一、前置准备二、创建与编码三、一键构建四、本地“白嫖”测试(可选)五、发布公共包六、常见踩坑提醒

分析 Java Stream 的 peek使用实践与副作用处理方案

《分析JavaStream的peek使用实践与副作用处理方案》StreamAPI的peek操作是中间操作,用于观察元素但不终止流,其副作用风险包括线程安全、顺序混乱及性能问题,合理使用场景有限... 目录一、peek 操作的本质:有状态的中间操作二、副作用的定义与风险场景1. 并行流下的线程安全问题2. 顺

Ubuntu向多台主机批量传输文件的流程步骤

《Ubuntu向多台主机批量传输文件的流程步骤》:本文主要介绍在Ubuntu中批量传输文件到多台主机的方法,需确保主机互通、用户名密码统一及端口开放,通过安装sshpass工具,准备包含目标主机信... 目录Ubuntu 向多台主机批量传输文件1.安装 sshpass2.准备主机列表文件3.创建一个批处理脚

Python异常处理之避免try-except滥用的3个核心原则

《Python异常处理之避免try-except滥用的3个核心原则》在Python开发中,异常处理是保证程序健壮性的关键机制,本文结合真实案例与Python核心机制,提炼出避免异常滥用的三大原则,有需... 目录一、精准打击:只捕获可预见的异常类型1.1 通用异常捕获的陷阱1.2 精准捕获的实践方案1.3

Pandas处理缺失数据的方式汇总

《Pandas处理缺失数据的方式汇总》许多教程中的数据与现实世界中的数据有很大不同,现实世界中的数据很少是干净且同质的,本文我们将讨论处理缺失数据的一些常规注意事项,了解Pandas如何表示缺失数据,... 目录缺失数据约定的权衡Pandas 中的缺失数据None 作为哨兵值NaN:缺失的数值数据Panda

C++中处理文本数据char与string的终极对比指南

《C++中处理文本数据char与string的终极对比指南》在C++编程中char和string是两种用于处理字符数据的类型,但它们在使用方式和功能上有显著的不同,:本文主要介绍C++中处理文本数... 目录1. 基本定义与本质2. 内存管理3. 操作与功能4. 性能特点5. 使用场景6. 相互转换核心区别