!7

cprint TestFileBasedLock {
  switchable File file;
  switchable double timeout = 10;
  transient FileBasedLock lock1, lock2;
  transient S contents; // contents for lock file
  
  start-thread {
    if (file == null)
      setField(file := javaxCachesDir("Lock Test/lockfile-" + aGlobalID()));
    print("Using file: " + file);
    
    contents = null;
    regularTest();
    crashTest();
    
    contents = "hello";
    regularTest();
    crashTest();
    print("All OK!");
  }
  
  FileBasedLock makeLock() {
    FileBasedLock lock = new(file);
    if (contents != null)
      lock.contentsForLockFile(contents);
    lock.verbose = true;
    lock.timeout = timeout;
    ret lock;
  }
  
  void regularTest() {
    afterwards { cleanMeUp(); }
    lock1 = makeLock();
    lock2 = makeLock();
    assertTrueVerbose("Locking lock1", lock1.tryToLock());
    
    // Check lock file contents
    assertEquals(unnull(contents), loadTextFile(file));
    
    assertFalseVerbose("Locking lock2", lock2.tryToLock());
    print("Waiting for timeout (" + (timeout+1) + "s)");
    sleepSeconds(timeout+1);
    assertFalseVerbose("Locking lock2", lock2.tryToLock());
    close(lock1);
    assertTrueVerbose("Locking lock2", lock2.tryToLock());
    close(lock2);
    print("\nRegular test OK!\n");
  }
  
  void crashTest {
    afterwards { cleanMeUp(); }
    lock1 = makeLock();
    lock2 = makeLock();
    assertTrueVerbose("Locking lock1", lock1.tryToLock());
    assertFalseVerbose("Locking lock2", lock2.tryToLock());
    lock1._simulateCrash();
    print("Waiting for timeout (" + (timeout+1) + "s)");
    sleepSeconds(timeout+1);
    assertTrueVerbose("Locking lock2", lock2.tryToLock());
    closeAll(lock1, lock2);
    print("\nCrash test OK!\n");
  }
  
  void cleanMeUp {
    closeAll(lock1, lock2);
  }
}