This commit is contained in:
asonix 2022-11-26 11:17:53 -06:00
parent c2c5ce9373
commit 3325b222a2
2 changed files with 4 additions and 4 deletions

View File

@ -51,7 +51,7 @@ where
vacant.insert(Vec::new()); vacant.insert(Vec::new());
let span = tracing::info_span!( let span = tracing::info_span!(
"Processing image", "Processing image",
hash = &tracing::field::debug(&hex::encode(&hash)), hash = &tracing::field::debug(&hex::encode(hash)),
path = &tracing::field::debug(&path), path = &tracing::field::debug(&path),
completed = &tracing::field::Empty, completed = &tracing::field::Empty,
); );
@ -64,7 +64,7 @@ where
occupied.get_mut().push(tx); occupied.get_mut().push(tx);
let span = tracing::info_span!( let span = tracing::info_span!(
"Waiting for processed image", "Waiting for processed image",
hash = &tracing::field::debug(&hex::encode(&hash)), hash = &tracing::field::debug(&hex::encode(hash)),
path = &tracing::field::debug(&path), path = &tracing::field::debug(&path),
); );
(Some(rx), span) (Some(rx), span)
@ -122,7 +122,7 @@ impl Drop for CancelToken {
fn drop(&mut self) { fn drop(&mut self) {
if self.receiver.is_none() { if self.receiver.is_none() {
let completed = PROCESS_MAP.remove(&self.key).is_none(); let completed = PROCESS_MAP.remove(&self.key).is_none();
self.span.record("completed", &completed); self.span.record("completed", completed);
} }
} }
} }

View File

@ -474,7 +474,7 @@ impl ObjectStore {
hasher.update(&bytes); hasher.update(&bytes);
} }
let hash = hasher.finalize(); let hash = hasher.finalize();
let hash_string = base64::encode(&hash); let hash_string = base64::encode(hash);
drop(guard); drop(guard);
hash_string hash_string
}) })