(to test) error reporting and throttling at higher layer

1 files changed, 15 insertions, 1 deletions

diff --git a/src/garage/cli/util.rs b/src/garage/cli/util.rs
index 81361864..ddb353f9 100644
--- a/src/garage/cli/util.rs
+++ b/src/garage/cli/util.rs
@@ -242,7 +242,7 @@ pub fn print_worker_info(wi: HashMap<usize, WorkerInfo>) {
 	wi.sort_by_key(|(tid, info)| {
 		(
 			match info.status {
-				WorkerStatus::Busy => 0,
+				WorkerStatus::Busy | WorkerStatus::Throttled(_) => 0,
 				WorkerStatus::Idle => 1,
 				WorkerStatus::Done => 2,
 			},
@@ -256,6 +256,20 @@ pub fn print_worker_info(wi: HashMap<usize, WorkerInfo>) {
 		if let Some(i) = &info.info {
 			table.push(format!("\t\t{}", i));
 		}
+		if info.consecutive_errors > 0 {
+			table.push(format!(
+				"\t\t{} CONSECUTIVE ERRORS ({} total), last: {}",
+				info.consecutive_errors,
+				info.errors,
+				info.last_error.as_deref().unwrap_or("(?)")
+			));
+		} else if info.errors > 0 {
+			table.push(format!(
+				"\t\t{} errors, last: {}",
+				info.errors,
+				info.last_error.as_deref().unwrap_or("(?)")
+			));
+		}
 	}
 	format_table(table);
 }