djsundog/ffplayout
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

sync check returns true or false,

Browse Source 
To led the main function handle out of sync. Delta gives also total delta. Cleanup...
This commit is contained in:
jb-alvarado 2022-03-01 21:12:16 +01:00
parent 41ee75dae8
commit 7993cf3f1d
1 changed files with 18 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

29
src/utils/mod.rs
View File

@ -2,7 +2,9 @@ use chrono::prelude::*;
use chrono::Duration; use chrono::Duration;
use ffprobe::{ffprobe, Format, Stream}; use ffprobe::{ffprobe, Format, Stream};
use serde::{Deserialize, Serialize}; use serde::{Deserialize, Serialize};
use std::{fs::metadata, process, time, time::UNIX_EPOCH}; use std::{fs::metadata, time, time::UNIX_EPOCH};
use simplelog::*;
mod arg_parse; mod arg_parse;
mod config; mod config;
@ -43,7 +45,7 @@ impl Media {
let duration: f64 = match &probe.clone().format.unwrap().duration { let duration: f64 = match &probe.clone().format.unwrap().duration {
Some(dur) => dur.parse().unwrap(), Some(dur) => dur.parse().unwrap(),
None => 0.0 None => 0.0,
}; };
Self { Self {
@ -66,9 +68,9 @@ impl Media {
self.probe = Some(MediaProbe::new(self.source.clone())) self.probe = Some(MediaProbe::new(self.source.clone()))
} }
fn add_filter(&mut self, config: &Config, last: bool, next: bool) { fn add_filter(&mut self, config: &Config) {
let mut node = self.clone(); let mut node = self.clone();
self.filter = Some(filter_chains(&mut node, &config, last, next)); self.filter = Some(filter_chains(&mut node, &config));
} }
} }
@ -148,14 +150,14 @@ pub fn get_sec() -> f64 {
+ (local.nanosecond() as f64 / 1000000000.0) + (local.nanosecond() as f64 / 1000000000.0)
} }
pub fn get_date(seek: bool, start: f64, next: f64) -> String { pub fn get_date(seek: bool, start: f64, next_start: f64) -> String {
let local: DateTime<Local> = Local::now(); let local: DateTime<Local> = Local::now();
if seek && start > get_sec() { if seek && start > get_sec() {
return (local - Duration::days(1)).format("%Y-%m-%d").to_string(); return (local - Duration::days(1)).format("%Y-%m-%d").to_string();
} }
if start == 0.0 && next >= 86400.0 { if start == 0.0 && next_start >= 86400.0 {
return (local + Duration::days(1)).format("%Y-%m-%d").to_string(); return (local + Duration::days(1)).format("%Y-%m-%d").to_string();
} }
@ -202,7 +204,7 @@ pub fn is_close(a: f64, b: f64, to: f64) -> bool {
false false
} }
pub fn get_delta(begin: &f64, config: &Config) -> f64 { pub fn get_delta(begin: &f64, config: &Config) -> (f64, f64) {
let mut current_time = get_sec(); let mut current_time = get_sec();
let start = time_to_sec(&config.playlist.day_start); let start = time_to_sec(&config.playlist.day_start);
let length = time_to_sec(&config.playlist.length); let length = time_to_sec(&config.playlist.length);
@ -224,14 +226,19 @@ pub fn get_delta(begin: &f64, config: &Config) -> f64 {
current_delta -= 86400.0 current_delta -= 86400.0
} }
current_delta let ref_time = target_length + start;
let total_delta = ref_time - begin + current_delta;
(current_delta, total_delta)
} }
pub fn check_sync(delta: f64, config: &Config) { pub fn check_sync(delta: f64, config: &Config) -> bool {
if delta.abs() > config.general.stop_threshold && config.general.stop_threshold > 0.0 { if delta.abs() > config.general.stop_threshold && config.general.stop_threshold > 0.0 {
println!("Start time out of sync for '{}' seconds", delta); error!("Start time out of sync for <yellow>{}</> seconds", delta);
process::exit(0x0100); return false
} }
true
} }
pub fn gen_dummy(duration: f64, config: &Config) -> (String, Vec<String>) { pub fn gen_dummy(duration: f64, config: &Config) -> (String, Vec<String>) {