Lines Matching refs:cache
10 cache::errors::CacheError,
11 cache::Cache,
439 pub cache: Mutex<Option<Cache>>, field
445 cache: Mutex::new(None), in new()
449 pub async fn set_cache(&self, cache: Cache) { in set_cache()
450 *self.cache.lock().await = Some(cache); in set_cache()
458 if let Some(cache) = &mut *self.cache.lock().await { in save_video_data()
459 cache.save_video_data(chunk_body, timestamp).await?; in save_video_data()
469 if let Some(cache) = &mut *self.cache.lock().await { in save_audio_data()
470 cache.save_audio_data(chunk_body, timestamp).await?; in save_audio_data()
476 if let Some(cache) = &mut *self.cache.lock().await { in save_metadata()
477 cache.save_metadata(chunk_body, timestamp); in save_metadata()
497 if let Some(cache) = &mut *self.cache.lock().await { in send_prior_data()
498 if let Some(meta_body_data) = cache.get_metadata() { in send_prior_data()
503 if let Some(audio_seq_data) = cache.get_audio_seq() { in send_prior_data()
508 if let Some(video_seq_data) = cache.get_video_seq() { in send_prior_data()
518 if let Some(gops_data) = cache.get_gops_data() { in send_prior_data()
535 if let Some(cache) = &mut *self.cache.lock().await { in get_statistic_data()
536 return Some(cache.av_statistics.get_avstatistic_data().await); in get_statistic_data()