@@ -1401,7 +1401,7 @@ impl AggregationUpdateQueue {
14011401 task : lost_follower_id,
14021402 } ) ;
14031403 }
1404- // notify uppers about new follower
1404+ // notify uppers about lost follower
14051405 if !upper_ids. is_empty ( ) {
14061406 self . push ( AggregationUpdateJob :: InnerOfUppersLostFollower {
14071407 upper_ids,
@@ -1554,7 +1554,7 @@ impl AggregationUpdateQueue {
15541554 task : lost_follower_id,
15551555 } ) ;
15561556 }
1557- // notify uppers about new follower
1557+ // notify uppers about lost follower
15581558 if !upper_ids. is_empty ( ) {
15591559 self . push ( AggregationUpdateJob :: InnerOfUppersLostFollower {
15601560 upper_ids,
@@ -2445,7 +2445,7 @@ const MAX_YIELD_DURATION: Duration = Duration::from_millis(1);
24452445const MAX_RETRIES : u16 = 10000 ;
24462446
24472447/// Retry the passed function for a few milliseconds, while yielding to other threads.
2448- /// Returns an error if the function was not ablue to complete and the timeout was reached.
2448+ /// Returns an error if the function was not able to complete and the timeout was reached.
24492449///
24502450/// Each graph modification will only lock one or two tasks at a time, but updates usually also
24512451/// require follow-up updates to connected tasks. So an update will "slowly" propagate through the
@@ -2456,7 +2456,7 @@ const MAX_RETRIES: u16 = 10000;
24562456/// update yet). So we will retry (with this method) removals until the thing is there. So this is
24572457/// basically a busy loop that waits for the "add" update to complete. If the busy loop is not
24582458/// sucessful, the update is added to the end of the queue again. This is important as the "add"
2459- /// update might even be in the curreent thread and in the same queue. If that's the case yielding
2459+ /// update might even be in the current thread and in the same queue. If that's the case yielding
24602460/// won't help and the update need to be requeued.
24612461fn retry_loop ( mut f : impl FnMut ( ) -> ControlFlow < ( ) > ) -> Result < ( ) , RetryTimeout > {
24622462 let mut time: Option < Instant > = None ;
0 commit comments