fn blocking_read()

in core/src/layers/logging.rs [709:754]

• 45 lines of code
• 2 McCabe index (conditional complexity)

    fn blocking_read(&self, path: &str, args: OpRead) -> Result<(RpRead, Self::BlockingReader)> {
        debug!(
            target: LOGGING_TARGET,
            "service={} operation={} path={} range={} -> started",
            self.scheme,
            Operation::BlockingRead,
            path,
            args.range(),
        );

        self.inner
            .blocking_read(path, args.clone())
            .map(|(rp, r)| {
                debug!(
                    target: LOGGING_TARGET,
                    "service={} operation={} path={} range={} -> got reader",
                    self.scheme,
                    Operation::BlockingRead,
                    path,
                    args.range(),
                );
                let r = LoggingReader::new(
                    self.scheme,
                    Operation::BlockingRead,
                    path,
                    r,
                    self.failure_level,
                );
                (rp, r)
            })
            .map_err(|err| {
                if let Some(lvl) = self.err_level(&err) {
                    log!(
                        target: LOGGING_TARGET,
                        lvl,
                        "service={} operation={} path={} range={} -> {}: {err:?}",
                        self.scheme,
                        Operation::BlockingRead,
                        path,
                        args.range(),
                        self.err_status(&err)
                    );
                }
                err
            })
    }