aboutsummaryrefslogtreecommitdiff
path: root/transcoder
diff options
context:
space:
mode:
Diffstat (limited to 'transcoder')
-rw-r--r--transcoder/src/lib.rs11
1 files changed, 6 insertions, 5 deletions
diff --git a/transcoder/src/lib.rs b/transcoder/src/lib.rs
index c49f52c..665f470 100644
--- a/transcoder/src/lib.rs
+++ b/transcoder/src/lib.rs
@@ -6,8 +6,8 @@
#![feature(exit_status_error)]
use serde::{Deserialize, Serialize};
-use std::sync::LazyLock;
-use tokio::sync::{Mutex, Semaphore};
+use std::sync::{LazyLock, Mutex};
+use tokio::sync::Semaphore;
pub mod fragment;
pub mod image;
@@ -27,13 +27,14 @@ pub struct Config {
pub x264_preset: Option<String>,
}
+pub static CONF_PRELOAD: Mutex<Option<Config>> = Mutex::new(None);
static CONF: LazyLock<Config> = LazyLock::new(|| {
CONF_PRELOAD
- .blocking_lock()
+ .lock()
+ .unwrap()
.take()
- .expect("cache config not preloaded. logic error")
+ .expect("transcoder config not preloaded. logic error")
});
-static CONF_PRELOAD: Mutex<Option<Config>> = Mutex::const_new(None);
static LOCAL_IMAGE_TRANSCODING_TASKS: Semaphore = Semaphore::const_new(8);
static LOCAL_VIDEO_TRANSCODING_TASKS: Semaphore = Semaphore::const_new(2);