import java.util.concurrent.TimeUnit;
import java.util.concurrent.atomic.AtomicReference;
import javax.annotation.Nonnull;
-import javax.annotation.Nullable;
import org.opendaylight.mdsal.singleton.common.api.ServiceGroupIdentifier;
import org.opendaylight.openflowplugin.api.OFConstants;
import org.opendaylight.openflowplugin.api.openflow.device.DeviceInfo;
private final class MasterRoleCallback implements FutureCallback<RpcResult<SetRoleOutput>> {
@Override
- public void onSuccess(@Nullable RpcResult<SetRoleOutput> setRoleOutputRpcResult) {
+ public void onSuccess(RpcResult<SetRoleOutput> setRoleOutputRpcResult) {
contextChainMastershipWatcher.onMasterRoleAcquired(
deviceInfo,
ContextChainMastershipState.MASTER_ON_DEVICE);
}
@Override
- public void onFailure(@Nonnull final Throwable throwable) {
+ public void onFailure(final Throwable throwable) {
if (!(throwable instanceof CancellationException)) {
contextChainMastershipWatcher.onNotAbleToStartMastershipMandatory(
deviceInfo,
private final class SlaveRoleCallback implements FutureCallback<RpcResult<SetRoleOutput>> {
@Override
- public void onSuccess(@Nullable final RpcResult<SetRoleOutput> result) {
+ public void onSuccess(final RpcResult<SetRoleOutput> result) {
contextChainMastershipWatcher.onSlaveRoleAcquired(deviceInfo);
LOG.debug("Role SLAVE was successfully set on device, node {}", deviceInfo);
}
@Override
- public void onFailure(@Nonnull final Throwable throwable) {
+ public void onFailure(final Throwable throwable) {
if (!(throwable instanceof CancellationException)) {
contextChainMastershipWatcher.onSlaveRoleNotAcquired(deviceInfo,
"Was not able to propagate SLAVE role on device. Error: " + throwable.toString());
}
}
}
-}
\ No newline at end of file
+}