Skip to content

Commit

Permalink
Merge pull request #184 from vfdev-5/typos
Browse files Browse the repository at this point in the history
  • Loading branch information
QuantumEntangledAndy authored Mar 31, 2024
2 parents 6b97311 + 606c978 commit cfd7ac6
Showing 1 changed file with 4 additions and 4 deletions.
8 changes: 4 additions & 4 deletions src/rtsp/mod.rs
Original file line number Diff line number Diff line change
Expand Up @@ -104,7 +104,7 @@ pub(crate) async fn main(_opt: Opt, reactor: NeoReactor) -> Result<()> {
loop {
thread_config.changed().await?;
if let Err(e) = thread_rtsp.set_up_tls(&thread_config.borrow().clone()) {
log::error!("Could not seup TLS: {e}");
log::error!("Could not setup TLS: {e}");
}
}
} => v
Expand All @@ -128,7 +128,7 @@ pub(crate) async fn main(_opt: Opt, reactor: NeoReactor) -> Result<()> {

let config = thread_config.borrow().clone();
if let Err(e) = apply_users(&thread_rtsp, &curr_users).await {
log::error!("Could not seup TLS: {e}");
log::error!("Could not setup TLS: {e}");
}

if config.certificate.is_none() && !curr_users.is_empty() {
Expand Down Expand Up @@ -162,7 +162,7 @@ pub(crate) async fn main(_opt: Opt, reactor: NeoReactor) -> Result<()> {

for name in config_names.iter() {
if ! cameras.contains_key(name) {
log::info!("{name}: Rtsp Staring");
log::info!("{name}: Rtsp Starting");
let local_cancel = CancellationToken::new();
cameras.insert(name.clone(),local_cancel.clone() );
let thread_global_cancel = thread_cancel2.clone();
Expand All @@ -186,7 +186,7 @@ pub(crate) async fn main(_opt: Opt, reactor: NeoReactor) -> Result<()> {

for (running_name, token) in cameras.iter() {
if ! config_names.contains(running_name) {
log::debug!("Rtsp::main Cancel1");
log::debug!("Rtsp::main Cancel!");
token.cancel();
}
}
Expand Down

0 comments on commit cfd7ac6

Please sign in to comment.