euzu/tuliprox
1
0
Fork 0
mirror of https://github.com/euzu/tuliprox.git synced 2026-10-04 15:02:16 +02:00
Code Issues Packages Projects Releases 5 Wiki Activity

write operations optimized for less memory usage

Browse Source
This commit is contained in:
euzu
2025-12-11 19:27:56 +01:00
parent ab8e6c0d53
commit 1193fc2265
29 changed files with 320 additions and 187 deletions
Download Patch File Download Diff File Expand all files Collapse all files
backend/src/processing/processor/xtream_series.rs
+4 -2
View File
@@ -96,7 +96,8 @@ async fn playlist_resolve_series_info(cfg: &AppConfig, client: &reqwest::Client,
write_counter += 1;
// periodic flush to bound BufWriter memory
if write_counter.is_multiple_of(FLUSH_INTERVAL) {
if write_counter >= FLUSH_INTERVAL {
write_counter = 0;
if let Err(err) = content_writer.flush() {
errors.push(notify_err!(format!("Failed periodic flush of wal content writer {err}")));
}
@@ -202,7 +203,8 @@ async fn process_series_info(
}
write_counter +=1;
// periodic flush to bound BufWriter memory
if write_counter.is_multiple_of(FLUSH_INTERVAL) {
if write_counter <= FLUSH_INTERVAL {
write_counter = 0;
if let Err(err) = wal_writer.flush() {
errors.push(notify_err!(format!("Failed periodic flush of wal content writer {err}")));
}
backend/src/processing/processor/xtream_vod.rs
+2 -2
View File
@@ -109,9 +109,9 @@ pub async fn playlist_resolve_vod(app_config: &AppConfig, client: &reqwest::Clie
processed_info_ids.insert(provider_id, ts);
content_updated = true;
write_counter += 1;
// periodic flush to bound BufWriter memory
if write_counter.is_multiple_of(FLUSH_INTERVAL) {
if write_counter >= FLUSH_INTERVAL {
write_counter = 0;
if let Err(err) = content_writer.flush() {
errors.push(notify_err!(format!("Failed periodic flush of wal content writer {err}")));
}