private void gossip ( ) { // Check suspect nodes for failure timeouts. checkFailures ( ) ; // Check local metadata for changes. checkMetadata ( ) ; // Copy and clear the list of pending updates. if ( ! updates . isEmpty ( ) ) { List < ImmutableMember > updates = Lists . newArrayList ( this . updates . values ( ) ) ; this . updates . clear ( ) ; // Gossip the pending updates to peers. gossip ( updates ) ; } }
Gossips pending updates to the cluster .