chore: demote per-packet debug logs to trace
This commit is contained in:
@@ -14,7 +14,7 @@ use tokio::{
|
|||||||
net::{TcpListener, TcpStream},
|
net::{TcpListener, TcpStream},
|
||||||
time::timeout,
|
time::timeout,
|
||||||
};
|
};
|
||||||
use tracing::{debug, info, warn};
|
use tracing::{debug, info, trace, warn};
|
||||||
|
|
||||||
use crate::{
|
use crate::{
|
||||||
StreamCodec, StreamSession,
|
StreamCodec, StreamSession,
|
||||||
@@ -406,7 +406,7 @@ impl Rtmp {
|
|||||||
let pkt_type = data[0] & 0x0F;
|
let pkt_type = data[0] & 0x0F;
|
||||||
match p.parse(&data, timestamp.value) {
|
match p.parse(&data, timestamp.value) {
|
||||||
Some(frame) => {
|
Some(frame) => {
|
||||||
debug!(
|
trace!(
|
||||||
pkt_type,
|
pkt_type,
|
||||||
is_keyframe = frame.is_keyframe,
|
is_keyframe = frame.is_keyframe,
|
||||||
ts = frame.timestamp_ms,
|
ts = frame.timestamp_ms,
|
||||||
@@ -419,7 +419,7 @@ impl Rtmp {
|
|||||||
.ok();
|
.ok();
|
||||||
}
|
}
|
||||||
None => {
|
None => {
|
||||||
debug!(
|
trace!(
|
||||||
pkt_type,
|
pkt_type,
|
||||||
"AV1 packet produced no frame (seq header or unknown type)"
|
"AV1 packet produced no frame (seq header or unknown type)"
|
||||||
);
|
);
|
||||||
|
|||||||
@@ -11,7 +11,7 @@ use tokio::{
|
|||||||
net::UdpSocket,
|
net::UdpSocket,
|
||||||
sync::mpsc::{self, Receiver},
|
sync::mpsc::{self, Receiver},
|
||||||
};
|
};
|
||||||
use tracing::{debug, error, info, warn};
|
use tracing::{debug, error, info, trace, warn};
|
||||||
|
|
||||||
pub struct WebRtcProxyConfig {
|
pub struct WebRtcProxyConfig {
|
||||||
pub proxy_port: i32,
|
pub proxy_port: i32,
|
||||||
@@ -97,7 +97,7 @@ impl WebrtcProxy {
|
|||||||
|
|
||||||
// By addr
|
// By addr
|
||||||
if let Some(tx) = by_addr.get(&from) {
|
if let Some(tx) = by_addr.get(&from) {
|
||||||
debug!(
|
trace!(
|
||||||
"proxy: routing {} bytes by addr {}:{} → channel",
|
"proxy: routing {} bytes by addr {}:{} → channel",
|
||||||
b,
|
b,
|
||||||
from.ip(),
|
from.ip(),
|
||||||
@@ -120,7 +120,7 @@ impl WebrtcProxy {
|
|||||||
};
|
};
|
||||||
|
|
||||||
let Some((part1, part2)) = self::WebrtcProxy::ufrag_pair(&data) else {
|
let Some((part1, part2)) = self::WebrtcProxy::ufrag_pair(&data) else {
|
||||||
debug!("huh, packet isnt stun or added as client.");
|
trace!("huh, packet isnt stun or added as client.");
|
||||||
continue;
|
continue;
|
||||||
};
|
};
|
||||||
// Try both parts of the STUN username — the first packet
|
// Try both parts of the STUN username — the first packet
|
||||||
|
|||||||
Reference in New Issue
Block a user