Review

19

/Users/svenamann/Documents/MUBench/mubench.pipeline/../checkouts/lucene/1918/original-src/org/apache/lucene/store/FSDirectory.java

sync(String)

class FSDirectory {
  public void sync(String name) throws IOException {
    ensureOpen();
    File fullFile = new File(directory, name);
    boolean success = false;
    int retryCount = 0;
    IOException exc = null;
    while(!success && retryCount < 5) {
      retryCount++;
      RandomAccessFile file = null;
      try {
        try {
          file = new RandomAccessFile(fullFile, "rw");
          file.getFD().sync();
          success = true;
        } finally {
          if (file != null)
            file.close();
        }
      } catch (IOException ioe) {
        if (exc == null)
          exc = ioe;
        try {
          // Pause 5 msec
          Thread.sleep(5);
        } catch (InterruptedException ie) {
          // In 3.0 we will change this to throw
          // InterruptedException instead
          Thread.currentThread().interrupt();
          throw new RuntimeException(ie);
        }
      }
    }
    if (!success)
      // Throw original exception
      throw exc;
  }

}