public void awaitAllAcksReceived() throws IgniteInterruptedCheckedException {
  lock.lock();
  try {
    while (!ackMap.isEmpty())     U.await(allAcksRcvCond);
  }
  finally {
    lock.unlock();
  }
}

public void awaitAllAcksReceived ( ) throws IgniteInterruptedCheckedException { lock . lock ( ) ; try { while ( ! ackMap . isEmpty ( ) ) U . await ( allAcksRcvCond ) ; } finally { lock . unlock ( ) ; } }
await all pending data blockes to be acked .
