bugfix:RReset failures for the roles have been removed

doc/changelog.rst

@@ -2,6 +2,14 @@ Verwalter Changes by Version
 ============================
 
 
+.. _changelog-0.11.2:
+
+Verwalter 0.11.2
+----------------
+
+* bugfix: reset failures for the roles have been removed
+
+
 .. _changelog-0.11.1:
 
 Verwalter 0.11.1

src/daemon/apply.rs

@@ -168,6 +168,7 @@ fn apply_schedule(hash: &String, is_new: bool,
         .unwrap_or(&empty);
     let string_schedule = format!("{}", scheduler_result);
 
+    state.reset_unused_roles(node_roles.keys());
     for (role_name, ref node_role_vars) in node_roles.iter() {
         let mut rlog = match dlog.role(&role_name, true) {
             Ok(l) => l,

src/daemon/shared.rs

@@ -5,6 +5,7 @@ use std::sync::atomic::AtomicBool;
 use std::time::{SystemTime};
 use std::collections::{HashMap, BTreeMap, HashSet};
 use std::collections::btree_map::Entry::{Occupied, Vacant};
+use std::mem;
 
 use futures::sync::oneshot;
 use async_slot as slot;
@@ -393,6 +394,19 @@ impl SharedState {
         role_errors.remove(role_name);
         FAILING_ROLES.set(role_errors.len() as i64);
     }
+    pub fn reset_unused_roles<T, I>(&self, roles: I)
+        where T: AsRef<str>, I: Iterator<Item=T>
+    {
+        let mut lock = self.lock();
+        let role_errors = Arc::make_mut(&mut lock.failed_roles);
+        let old_errors = mem::replace(role_errors, Default::default());
+        for name in roles {
+            if old_errors.contains(name.as_ref()) {
+                role_errors.insert(name.as_ref().into());
+            }
+        }
+        FAILING_ROLES.set(role_errors.len() as i64);
+    }
 }
 
 pub fn metrics() -> List {