some changes

delete

store changes

save changes

saving

Save changes again lol

Save changes

add round robin

Author: cjqzhao

grpc/src/client/load_balancing/child_manager.rs

@@ -50,6 +50,7 @@ pub struct ChildManager<T> {
     update_sharder: Box<dyn ResolverUpdateSharder<T>>,
     pending_work: Arc<Mutex<HashSet<usize>>>,
     runtime: Arc<dyn Runtime>,
+    updated: bool,
 }
 
 struct Child<T> {
@@ -94,6 +95,7 @@ impl<T> ChildManager<T> {
             children: Default::default(),
             pending_work: Default::default(),
             runtime,
+            updated: false,
         }
     }
 
@@ -158,8 +160,14 @@ impl<T> ChildManager<T> {
         // Update the tracked state if the child produced an update.
         if let Some(state) = channel_controller.picker_update {
             self.children[child_idx].state = state;
+            self.updated = true;
         };
     }
+
+    /// Returns true if a child has produced an update and resets flag to false.
+    pub fn has_updated(&mut self) -> bool {
+        mem::take(&mut self.updated)
+    }
 }
 
 impl<T: PartialEq + Hash + Eq + Send + Sync + 'static> LbPolicy for ChildManager<T> {

grpc/src/client/load_balancing/test_utils.rs

@@ -276,4 +276,4 @@ impl LbPolicyBuilder for StubPolicyBuilder {
 
 pub fn reg_stub_policy(name: &'static str, funcs: StubPolicyFuncs) {
     super::GLOBAL_LB_REGISTRY.add_builder(StubPolicyBuilder { name, funcs })
-}
+}