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

相关文章

Java中Springboot集成Kafka实现消息发送和接收功能

《Java中Springboot集成Kafka实现消息发送和接收功能》Kafka是一个高吞吐量的分布式发布-订阅消息系统,主要用于处理大规模数据流,它由生产者、消费者、主题、分区和代理等组件构成,Ka... 目录一、Kafka 简介二、Kafka 功能三、POM依赖四、配置文件五、生产者六、消费者一、Kaf

使用MongoDB进行数据存储的操作流程

《使用MongoDB进行数据存储的操作流程》在现代应用开发中,数据存储是一个至关重要的部分,随着数据量的增大和复杂性的增加,传统的关系型数据库有时难以应对高并发和大数据量的处理需求,MongoDB作为... 目录什么是MongoDB?MongoDB的优势使用MongoDB进行数据存储1. 安装MongoDB

Go语言使用Buffer实现高性能处理字节和字符

《Go语言使用Buffer实现高性能处理字节和字符》在Go中,bytes.Buffer是一个非常高效的类型,用于处理字节数据的读写操作,本文将详细介绍一下如何使用Buffer实现高性能处理字节和... 目录1. bytes.Buffer 的基本用法1.1. 创建和初始化 Buffer1.2. 使用 Writ

Python视频处理库VidGear使用小结

《Python视频处理库VidGear使用小结》VidGear是一个高性能的Python视频处理库,本文主要介绍了Python视频处理库VidGear使用小结,文中通过示例代码介绍的非常详细,对大家的... 目录一、VidGear的安装二、VidGear的主要功能三、VidGear的使用示例四、VidGea

Python结合requests和Cheerio处理网页内容的操作步骤

《Python结合requests和Cheerio处理网页内容的操作步骤》Python因其简洁明了的语法和强大的库支持,成为了编写爬虫程序的首选语言之一,requests库是Python中用于发送HT... 目录一、前言二、环境搭建三、requests库的基本使用四、Cheerio库的基本使用五、结合req

使用Python处理CSV和Excel文件的操作方法

《使用Python处理CSV和Excel文件的操作方法》在数据分析、自动化和日常开发中,CSV和Excel文件是非常常见的数据存储格式,ython提供了强大的工具来读取、编辑和保存这两种文件,满足从基... 目录1. CSV 文件概述和处理方法1.1 CSV 文件格式的基本介绍1.2 使用 python 内

Python实现NLP的完整流程介绍

《Python实现NLP的完整流程介绍》这篇文章主要为大家详细介绍了Python实现NLP的完整流程,文中的示例代码讲解详细,具有一定的借鉴价值,感兴趣的小伙伴可以跟随小编一起学习一下... 目录1. 编程安装和导入必要的库2. 文本数据准备3. 文本预处理3.1 小写化3.2 分词(Tokenizatio

如何使用celery进行异步处理和定时任务(django)

《如何使用celery进行异步处理和定时任务(django)》文章介绍了Celery的基本概念、安装方法、如何使用Celery进行异步任务处理以及如何设置定时任务,通过Celery,可以在Web应用中... 目录一、celery的作用二、安装celery三、使用celery 异步执行任务四、使用celery

SpringBoot操作spark处理hdfs文件的操作方法

《SpringBoot操作spark处理hdfs文件的操作方法》本文介绍了如何使用SpringBoot操作Spark处理HDFS文件,包括导入依赖、配置Spark信息、编写Controller和Ser... 目录SpringBoot操作spark处理hdfs文件1、导入依赖2、配置spark信息3、cont

SpringBoot使用minio进行文件管理的流程步骤

《SpringBoot使用minio进行文件管理的流程步骤》MinIO是一个高性能的对象存储系统,兼容AmazonS3API,该软件设计用于处理非结构化数据,如图片、视频、日志文件以及备份数据等,本文... 目录一、拉取minio镜像二、创建配置文件和上传文件的目录三、启动容器四、浏览器登录 minio五、