ouyang/hbb_common
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

minor change

Browse Source
This commit is contained in:
lc
2025-11-15 00:27:09 +08:00
parent 955e49dc4b
commit 3a919aef54
3 changed files with 16 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
examples/webrtc.rs
View File

@@ -20,7 +20,10 @@ use webrtc::peer_connection::math_rand_alpha;
async fn main() -> Result<()> { async fn main() -> Result<()> {
#[cfg(not(feature = "webrtc"))] #[cfg(not(feature = "webrtc"))]
if true { if true {
println!("The webrtc feature is not enabled. Please enable the webrtc feature to run this example."); println!(
"The webrtc feature is not enabled. \
Please enable the webrtc feature to run this example."
);
return Ok(()); return Ok(());
} }
let app = Command::new("webrtc-stream") let app = Command::new("webrtc-stream")

2
examples/webrtc_dummy.rs
View File

@@ -42,4 +42,4 @@ impl WebRTCStream {
} }
} }
fn main() {} fn _main() {}

18
src/webrtc.rs
View File

@@ -218,8 +218,8 @@ impl WebRTCStream {
log::debug!("WebRTC session stream closed"); log::debug!("WebRTC session stream closed");
let mut lock = SESSIONS.lock().await; let mut lock = SESSIONS.lock().await;
match Self::get_key_for_peer(&pc_for_close2, start_local_offer).await.ok() { match Self::get_key_for_peer(&pc_for_close2, start_local_offer).await {
Some(k) => { Ok(k) => {
lock.remove(&k); lock.remove(&k);
log::debug!( log::debug!(
"WebRTC session removed key from cache: {} current len: {}", "WebRTC session removed key from cache: {} current len: {}",
@@ -227,7 +227,7 @@ impl WebRTCStream {
lock.len() lock.len()
); );
} }
None => return, Err(_e) => {}
} }
} }
_ => {} _ => {}
@@ -421,7 +421,8 @@ mod tests {
"" ""
); );
sdp_str = "v=0 sdp_str = "\
v=0
o=- 7400546379179479477 208696200 IN IP4 0.0.0.0 o=- 7400546379179479477 208696200 IN IP4 0.0.0.0
s=- s=-
t=0 0 t=0 0
@@ -443,7 +444,8 @@ a=ice-pwd:BtIqlWHfwhsJdFiBROeLuEbNmYfHxRfT".to_owned();
"sha-256 97:52:D6:1F:1E:87:6C:DA:B8:21:95:64:A5:85:89:FA:02:71:C7:4D:B3:FD:25:92:40:FB:6B:65:24:3C:79:88" "sha-256 97:52:D6:1F:1E:87:6C:DA:B8:21:95:64:A5:85:89:FA:02:71:C7:4D:B3:FD:25:92:40:FB:6B:65:24:3C:79:88"
); );
sdp_str = "v=0 sdp_str = "\
v=0
o=- 7400546379179479477 208696200 IN IP4 0.0.0.0 o=- 7400546379179479477 208696200 IN IP4 0.0.0.0
s=- s=-
t=0 0 t=0 0
@@ -465,7 +467,8 @@ a=ice-pwd:BtIqlWHfwhsJdFiBROeLuEbNmYfHxRfT".to_owned();
"sha-256 97:52:D6:1F:1E:87:6C:DA:B8:21:95:64:A5:85:89:FA:02:71:C7:4D:B3:FD:25:92:40:FB:6B:65:24:3C:79:88" "sha-256 97:52:D6:1F:1E:87:6C:DA:B8:21:95:64:A5:85:89:FA:02:71:C7:4D:B3:FD:25:92:40:FB:6B:65:24:3C:79:88"
); );
sdp_str = "v=0 sdp_str = "\
v=0
o=- 7400546379179479477 208696200 IN IP4 0.0.0.0 o=- 7400546379179479477 208696200 IN IP4 0.0.0.0
s=- s=-
t=0 0 t=0 0
@@ -488,7 +491,8 @@ a=ice-pwd:BtIqlWHfwhsJdFiBROeLuEbNmYfHxRfT"
"can not find fingerprint attribute" "can not find fingerprint attribute"
); );
sdp_str = "v=0 sdp_str = "\
v=0
o=- 7400546379179479477 208696200 IN IP4 0.0.0.0 o=- 7400546379179479477 208696200 IN IP4 0.0.0.0
s=- s=-
t=0 0 t=0 0