X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;f=opendaylight%2Fnetconf%2Fsal-netconf-connector%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fsal%2Fconnect%2Fnetconf%2Flistener%2FUncancellableFuture.java;fp=opendaylight%2Fnetconf%2Fsal-netconf-connector%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fsal%2Fconnect%2Fnetconf%2Flistener%2FUncancellableFuture.java;h=0000000000000000000000000000000000000000;hb=9ba2b4eca79bcc0e78099b133296801c8d45a6c4;hp=6219c4c68ef27b83586b411c2dac8b968be4dfd3;hpb=b2e81149739c87f0ecc2ce7f06448d7a5d3162b8;p=controller.git diff --git a/opendaylight/netconf/sal-netconf-connector/src/main/java/org/opendaylight/controller/sal/connect/netconf/listener/UncancellableFuture.java b/opendaylight/netconf/sal-netconf-connector/src/main/java/org/opendaylight/controller/sal/connect/netconf/listener/UncancellableFuture.java deleted file mode 100644 index 6219c4c68e..0000000000 --- a/opendaylight/netconf/sal-netconf-connector/src/main/java/org/opendaylight/controller/sal/connect/netconf/listener/UncancellableFuture.java +++ /dev/null @@ -1,52 +0,0 @@ -/* - * Copyright (c) 2014 Cisco Systems, Inc. and others. All rights reserved. - * - * This program and the accompanying materials are made available under the - * terms of the Eclipse Public License v1.0 which accompanies this distribution, - * and is available at http://www.eclipse.org/legal/epl-v10.html - */ -package org.opendaylight.controller.sal.connect.netconf.listener; - -import com.google.common.base.Preconditions; -import com.google.common.util.concurrent.AbstractFuture; -import javax.annotation.Nullable; -import javax.annotation.concurrent.GuardedBy; - -final class UncancellableFuture extends AbstractFuture { - @GuardedBy("this") - private boolean uncancellable = false; - - public UncancellableFuture(final boolean uncancellable) { - this.uncancellable = uncancellable; - } - - public synchronized boolean setUncancellable() { - if (isCancelled()) { - return false; - } - - uncancellable = true; - return true; - } - - public synchronized boolean isUncancellable() { - return uncancellable; - } - - @Override - public synchronized boolean cancel(final boolean mayInterruptIfRunning) { - return uncancellable ? false : super.cancel(mayInterruptIfRunning); - } - - @Override - public synchronized boolean set(@Nullable final V value) { - Preconditions.checkState(uncancellable); - return super.set(value); - } - - @Override - protected boolean setException(final Throwable throwable) { - Preconditions.checkState(uncancellable); - return super.setException(throwable); - } -}