if size > data.chunk_size {
bail!("fixed writer '{}' - got large chunk ({} > {}", data.name, size, data.chunk_size);
- } else if size < data.chunk_size {
+ }
+
+ if size < data.chunk_size {
data.small_chunk_count += 1;
if data.small_chunk_count > 1 {
bail!("fixed writer '{}' - detected multiple end chunks (chunk size too small)");
fn poll_next(self: Pin<&mut Self>, cx: &mut Context) -> Poll<Option<Result<BytesMut, S::Error>>> {
let this = self.get_mut();
loop {
- if this.buffer.len() == this.chunk_size {
- return Poll::Ready(Some(Ok(this.buffer.split())));
- } else if this.buffer.len() > this.chunk_size {
- let result = this.buffer.split_to(this.chunk_size);
- return Poll::Ready(Some(Ok(result)));
+ if this.buffer.len() >= this.chunk_size {
+ return Poll::Ready(Some(Ok(this.buffer.split_to(this.chunk_size))));
}
match ready!(Pin::new(&mut this.input).try_poll_next(cx)) {
}
}
+ #[allow(clippy::comparison_chain)]
if let Some(netmask) = netmask {
if address_list.len() > 1 {
bail!("unable to apply netmask to multiple addresses (please use cidr notation)");
for &perm in &[ACL_READ, ACL_WRITE, ACL_EXECUTE] {
res = unsafe { acl_get_perm(permset, perm) };
- if res < 0 {
+ if res < 0 {
return Err(Errno::last());
- } else if res > 0 {
+ }
+
+ if res == 1 {
permissions |= perm as u64;
}
}