import com.google.common.util.concurrent.MoreExecutors;
import java.util.concurrent.Semaphore;
import java.util.concurrent.TimeUnit;
-import javax.annotation.Nullable;
import org.opendaylight.openflowplugin.applications.frsync.SemaphoreKeeper;
import org.opendaylight.openflowplugin.applications.frsync.SyncReactor;
import org.opendaylight.openflowplugin.applications.frsync.util.PathUtil;
final long stampBeforeGuard,
final long stampAfterGuard,
final NodeId nodeId) {
- return new FutureCallback<Boolean>() {
+ return new FutureCallback<>() {
@Override
- public void onSuccess(@Nullable final Boolean result) {
+ public void onSuccess(final Boolean result) {
if (LOG.isDebugEnabled()) {
final long stampFinished = System.nanoTime();
LOG.debug("Syncup finished {} took:{} rpc:{} wait:{}", nodeId.getValue(),