in core/src/layers/logging.rs [756:798]
fn blocking_write(&self, path: &str, args: OpWrite) -> Result<(RpWrite, Self::BlockingWriter)> {
debug!(
target: LOGGING_TARGET,
"service={} operation={} path={} -> started",
self.scheme,
Operation::BlockingWrite,
path,
);
self.inner
.blocking_write(path, args)
.map(|(rp, w)| {
debug!(
target: LOGGING_TARGET,
"service={} operation={} path={} -> start writing",
self.scheme,
Operation::BlockingWrite,
path,
);
let w = LoggingWriter::new(
self.scheme,
Operation::BlockingWrite,
path,
w,
self.failure_level,
);
(rp, w)
})
.map_err(|err| {
if let Some(lvl) = self.err_level(&err) {
log!(
target: LOGGING_TARGET,
lvl,
"service={} operation={} path={} -> {}: {err:?}",
self.scheme,
Operation::BlockingWrite,
path,
self.err_status(&err)
);
}
err
})
}