Checkstyle inspections are fixed.
package com.orientechnologies.orient.core.storage.impl.local.paginated.atomicoperations;
-import com.orientechnologies.common.concur.lock.OInterruptedException;
import com.orientechnologies.common.concur.lock.OLockException;
import com.orientechnologies.common.concur.lock.OOneEntryPerKeyLockManager;
import com.orientechnologies.common.exception.OException;
@@ -45,7 +44,6 @@ import com.orientechnologies.orient.core.storage.impl.local.paginated.wal.OWrite
import java.io.IOException;
import java.util.Iterator;
import java.util.Objects;
-import java.util.concurrent.CountDownLatch;
/**
* @author Andrey Lomakin (a.lomakin-at-orientdb.com)
@@ -431,37 +429,4 @@ public class OAtomicOperationsManager {
lockManager.releaseLock(this, durableComponent.getLockName(), OOneEntryPerKeyLockManager.LOCK.SHARED);
}
- private static final class FreezeParameters {
- private final String message;
- private final Class<? extends OException> exceptionClass;
-
- FreezeParameters(String message, Class<? extends OException> exceptionClass) {
- this.message = message;
- this.exceptionClass = exceptionClass;
- }
- }
-
- private static final class WaitingListNode {
- /**
- * Latch which indicates that all links are created between add and existing list elements.
- */
- private final CountDownLatch linkLatch = new CountDownLatch(1);
-
- private final Thread item;
- private volatile WaitingListNode next;
-
- WaitingListNode(Thread item) {
- this.item = item;
- }
-
- void waitTillAllLinksWillBeCreated() {
- try {
- linkLatch.await();
- } catch (InterruptedException e) {
- throw OException.wrapException(
- new OInterruptedException("Thread was interrupted while was waiting for completion of 'waiting linked list' operation"),
- e);
- }
- }
- }
}
