diff options
| author | Trinity Pointard <trinity.pointard@gmail.com> | 2021-04-07 13:39:34 +0200 |
|---|---|---|
| committer | Trinity Pointard <trinity.pointard@gmail.com> | 2021-04-07 13:39:34 +0200 |
| commit | 718ae005486baeed358d56cc7cd319fedd1e76eb (patch) | |
| tree | ba5e6e91380236e21f697381277817049d6e6d58 /src/rpc/membership.rs | |
| parent | c8906f200bf907272bf9fba7d183df4332fa085b (diff) | |
| download | garage-718ae005486baeed358d56cc7cd319fedd1e76eb.tar.gz garage-718ae005486baeed358d56cc7cd319fedd1e76eb.zip | |
change some more comments and revert changes on TableSchema
Diffstat (limited to 'src/rpc/membership.rs')
| -rw-r--r-- | src/rpc/membership.rs | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/src/rpc/membership.rs b/src/rpc/membership.rs index 4fce1a7b..5f7bbc96 100644 --- a/src/rpc/membership.rs +++ b/src/rpc/membership.rs @@ -417,8 +417,8 @@ impl System { } } else if let Some(id) = id_option { if let Some(st) = status.nodes.get_mut(id) { - // TODO this might double-increment the value as the counter is already - // incremented for any kind of failure in rpc_client + // we need to increment failure counter as call was done using by_addr so the + // counter was not auto-incremented st.num_failures.fetch_add(1, Ordering::SeqCst); if !st.is_up() { warn!("Node {:?} seems to be down.", id); |