aboutsummaryrefslogtreecommitdiff
path: root/remuxer/src/trim_writer.rs
diff options
context:
space:
mode:
authormetamuffin <metamuffin@disroot.org>2023-01-29 14:45:25 +0100
committermetamuffin <metamuffin@disroot.org>2023-01-29 14:45:25 +0100
commitde8d69d2886ae50e28da210fc690c99457a804bb (patch)
treeb9d4fca9acd7d5fb844f4c76c8c338770d943df7 /remuxer/src/trim_writer.rs
parent0d9dc5672b0ba0c6c9988b0422837ceb00a5d7b8 (diff)
downloadjellything-de8d69d2886ae50e28da210fc690c99457a804bb.tar
jellything-de8d69d2886ae50e28da210fc690c99457a804bb.tar.bz2
jellything-de8d69d2886ae50e28da210fc690c99457a804bb.tar.zst
more seeking code + expire cookies
Diffstat (limited to 'remuxer/src/trim_writer.rs')
-rw-r--r--remuxer/src/trim_writer.rs18
1 files changed, 11 insertions, 7 deletions
diff --git a/remuxer/src/trim_writer.rs b/remuxer/src/trim_writer.rs
index 65d3589..bed90e7 100644
--- a/remuxer/src/trim_writer.rs
+++ b/remuxer/src/trim_writer.rs
@@ -4,7 +4,7 @@ use std::{
};
use anyhow::anyhow;
-use log::warn;
+use log::{trace, warn};
pub struct TrimWriter<W> {
inner: W,
@@ -36,12 +36,16 @@ impl<W: Write> Write for TrimWriter<W> {
));
}
- let buf = &buf[start..end];
- if !buf.is_empty() {
- self.inner.write_all(buf)?;
- self.position += buf.len()
- }
- Ok(buf.len())
+ let tbuf = &buf[start..end];
+ Ok(if !tbuf.is_empty() {
+ trace!("trim={start}..{end} avail={}", buf.len());
+ let sz = self.inner.write(tbuf)?;
+ self.position += sz;
+ sz
+ } else {
+ trace!("skip={}", buf.len());
+ buf.len()
+ })
}
fn flush(&mut self) -> std::io::Result<()> {