private void awaitInitialization(){
  if (initLatch.getCount() > 0) {
    try {
      U.await(initLatch);
      if (initFailed)       throw new IllegalStateException("Failed to initialize data structures processor.");
    }
 catch (    IgniteInterruptedCheckedException e) {
      throw new IllegalStateException("Failed to initialize data structures processor " + "(thread has been interrupted).",e);
    }
  }
}

private void awaitInitialization ( ) { if ( initLatch . getCount ( ) > 0 ) { try { U . await ( initLatch ) ; if ( initFailed ) throw new IllegalStateException ( "Failed to initialize data structures processor." ) ; } catch ( IgniteInterruptedCheckedException e ) { throw new IllegalStateException ( "Failed to initialize data structures processor " + "(thread has been interrupted)." , e ) ; } } }
awaits for processor initialization .
