diff --git a/src/concurrent_processor.rs b/src/concurrent_processor.rs index abaeaca..986773e 100644 --- a/src/concurrent_processor.rs +++ b/src/concurrent_processor.rs @@ -114,7 +114,7 @@ impl Drop for CancelToken { fn drop(&mut self) { if self.receiver.is_none() { let completed = PROCESS_MAP.remove(&self.path).is_none(); - self.span.record("completed", &completed); + self.span.record("completed", completed); } } } diff --git a/src/process.rs b/src/process.rs index 057d809..c0e072a 100644 --- a/src/process.rs +++ b/src/process.rs @@ -212,8 +212,8 @@ where if let Ok(err) = res { let display = format!("{}", err); let debug = format!("{:?}", err); - span.record("exception.message", &display.as_str()); - span.record("exception.details", &debug.as_str()); + span.record("exception.message", display.as_str()); + span.record("exception.details", debug.as_str()); return Poll::Ready(Err(err)); } } @@ -223,8 +223,8 @@ where if let Err(err) = &res { let display = format!("{}", err); let debug = format!("{:?}", err); - span.record("exception.message", &display.as_str()); - span.record("exception.details", &debug.as_str()); + span.record("exception.message", display.as_str()); + span.record("exception.details", debug.as_str()); } return Poll::Ready(res); } diff --git a/src/range.rs b/src/range.rs index 3b36bda..706c97f 100644 --- a/src/range.rs +++ b/src/range.rs @@ -17,7 +17,7 @@ pub(crate) fn chop_bytes( if let Some((start, end)) = byte_range.to_satisfiable_range(length) { // END IS INCLUSIVE let end = end as usize + 1; - return Ok(once(ready(Ok(bytes.slice(start as usize..end as usize))))); + return Ok(once(ready(Ok(bytes.slice(start as usize..end))))); } Err(UploadError::Range.into()) diff --git a/src/upload_manager/session.rs b/src/upload_manager/session.rs index 9274697..ec4de36 100644 --- a/src/upload_manager/session.rs +++ b/src/upload_manager/session.rs @@ -89,7 +89,7 @@ where debug!("Remove hash/id -> alias mapping"); let id = String::from_utf8_lossy(&id); let key = alias_key(&hash, &id); - let _ = manager.inner.main_tree.remove(&key); + let _ = manager.inner.main_tree.remove(key); } let _ = manager.check_delete_files(store, hash).await;