private void waitForStarted ( ) { debug ( "GuestNode#waitForStarted(): Waiting for other clusters started" ) ; while ( true ) { boolean othersStarted = true ; for ( Object key : clustersProperties . keySet ( ) ) { String clusterName = ( String ) key ; Long startedAt = region . get ( createStartedAtKey ( clusterName ) ) ; debug ( "GuestNode#waitForStarted(): Checking startedAt: startedAt = " + startedAt + ", processingStartedAt = " + processingStartedAt ) ; if ( ( startedAt == null ) || ( startedAt . longValue ( ) < processingStartedAt ) ) { othersStarted = false ; break ; } } if ( othersStarted ) { break ; } try { TimeUnit . MILLISECONDS . sleep ( CHECK_PERIOD ) ; } catch ( InterruptedException e ) { } } debug ( "GuestNode#waitForStarted(): Other clusters started" ) ; }
Wait until the other clients started