Signed-off-by: Ian Jackson <ijackson@chiark.greenend.org.uk>
(reqs.len() < ic.target_requests_outstanding.sat() ||
(reqs.len() < ic.max_requests_outstanding.sat() &&
! upbound.is_empty()))
- // xxx backpressure, if too much in rx_queue
=>
{
submit_request(&c, &mut req_num, &mut reqs,
// SPDX-License-Identifier: GPL-3.0-or-later
// There is NO WARRANTY.
-/*
-#![allow(unused_imports)] // xxx
-#![allow(unreachable_code)] // xxx
-#![allow(dead_code)] // xxx
-#![allow(unused_variables)] // xxx
-*/
-
#![feature(io_error_more)] // EK::IsADirectory
pub mod prelude;
let now = Instant::now();
match r {
Ok(t) => {
- // xxx something something success
Some(t)
},
Err(e) => {
- // xxx something something error
let m = (||{
let mut m = self.ic.to_string();
if let Some(req_num) = req_num {