diff options
author | metamuffin <metamuffin@disroot.org> | 2023-01-29 14:45:25 +0100 |
---|---|---|
committer | metamuffin <metamuffin@disroot.org> | 2023-01-29 14:45:25 +0100 |
commit | de8d69d2886ae50e28da210fc690c99457a804bb (patch) | |
tree | b9d4fca9acd7d5fb844f4c76c8c338770d943df7 /remuxer/src/trim_writer.rs | |
parent | 0d9dc5672b0ba0c6c9988b0422837ceb00a5d7b8 (diff) | |
download | jellything-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.rs | 18 |
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<()> { |