YangWX/crossdesk
1
0
Fork 0
mirror of https://github.com/kunkundi/crossdesk.git synced 2025-10-26 20:25:34 +08:00
Code Issues Packages Projects Releases Wiki Activity

[fix] fix inbound rtp statistics

Browse Source
This commit is contained in:
dijunkun
2025-01-06 17:18:49 +08:00
parent 0737eee95a
commit 601fedfd76
3 changed files with 13 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
src/channel/audio_channel_receive.cpp
View File

@@ -20,8 +20,6 @@ void AudioChannelReceive::Initialize(RtpPacket::PAYLOAD_TYPE payload_type) {
rtp_audio_receiver_->SetOnReceiveData( rtp_audio_receiver_->SetOnReceiveData(
[this](const char *data, size_t size) -> void { [this](const char *data, size_t size) -> void {
ice_io_statistics_->UpdateAudioInboundBytes((uint32_t)size);
if (on_receive_audio_) { if (on_receive_audio_) {
on_receive_audio_(data, size); on_receive_audio_(data, size);
} }
@@ -51,6 +49,10 @@ void AudioChannelReceive::Initialize(RtpPacket::PAYLOAD_TYPE payload_type) {
void AudioChannelReceive::Destroy() {} void AudioChannelReceive::Destroy() {}
int AudioChannelReceive::OnReceiveRtpPacket(const char *data, size_t size) { int AudioChannelReceive::OnReceiveRtpPacket(const char *data, size_t size) {
if (ice_io_statistics_) {
ice_io_statistics_->UpdateAudioInboundBytes((uint32_t)size);
}
if (rtp_audio_receiver_) { if (rtp_audio_receiver_) {
rtp_audio_receiver_->InsertRtpPacket(RtpPacket((uint8_t *)data, size)); rtp_audio_receiver_->InsertRtpPacket(RtpPacket((uint8_t *)data, size));
} }

6
src/channel/data_channel_receive.cpp
View File

@@ -21,8 +21,6 @@ void DataChannelReceive::Initialize(RtpPacket::PAYLOAD_TYPE payload_type) {
rtp_data_receiver_->SetOnReceiveData( rtp_data_receiver_->SetOnReceiveData(
[this](const char *data, size_t size) -> void { [this](const char *data, size_t size) -> void {
ice_io_statistics_->UpdateDataInboundBytes((uint32_t)size);
if (on_receive_data_) { if (on_receive_data_) {
on_receive_data_(data, size); on_receive_data_(data, size);
} }
@@ -52,6 +50,10 @@ void DataChannelReceive::Initialize(RtpPacket::PAYLOAD_TYPE payload_type) {
void DataChannelReceive::Destroy() {} void DataChannelReceive::Destroy() {}
int DataChannelReceive::OnReceiveRtpPacket(const char *data, size_t size) { int DataChannelReceive::OnReceiveRtpPacket(const char *data, size_t size) {
if (ice_io_statistics_) {
ice_io_statistics_->UpdateDataInboundBytes((uint32_t)size);
}
if (rtp_data_receiver_) { if (rtp_data_receiver_) {
rtp_data_receiver_->InsertRtpPacket(RtpPacket((uint8_t *)data, size)); rtp_data_receiver_->InsertRtpPacket(RtpPacket((uint8_t *)data, size));
} }

8
src/channel/video_channel_receive.cpp
View File

@@ -20,8 +20,6 @@ void VideoChannelReceive::Initialize(RtpPacket::PAYLOAD_TYPE payload_type) {
rtp_video_receiver_->SetOnReceiveCompleteFrame( rtp_video_receiver_->SetOnReceiveCompleteFrame(
[this](VideoFrame &video_frame) -> void { [this](VideoFrame &video_frame) -> void {
ice_io_statistics_->UpdateVideoInboundBytes(
(uint32_t)video_frame.Size());
on_receive_complete_frame_(video_frame); on_receive_complete_frame_(video_frame);
}); });
@@ -41,7 +39,7 @@ void VideoChannelReceive::Initialize(RtpPacket::PAYLOAD_TYPE payload_type) {
return -2; return -2;
} }
ice_io_statistics_->UpdateVideoInboundBytes((uint32_t)size); ice_io_statistics_->UpdateVideoOutboundBytes((uint32_t)size);
return ice_agent_->Send(data, size); return ice_agent_->Send(data, size);
}); });
@@ -51,6 +49,10 @@ void VideoChannelReceive::Initialize(RtpPacket::PAYLOAD_TYPE payload_type) {
void VideoChannelReceive::Destroy() {} void VideoChannelReceive::Destroy() {}
int VideoChannelReceive::OnReceiveRtpPacket(const char *data, size_t size) { int VideoChannelReceive::OnReceiveRtpPacket(const char *data, size_t size) {
if (ice_io_statistics_) {
ice_io_statistics_->UpdateVideoInboundBytes((uint32_t)size);
}
if (rtp_video_receiver_) { if (rtp_video_receiver_) {
rtp_video_receiver_->InsertRtpPacket(RtpPacket((uint8_t *)data, size)); rtp_video_receiver_->InsertRtpPacket(RtpPacket((uint8_t *)data, size));
} }