import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
-public class CleanUpJob implements Callable<List<ListenableFuture<Void>>> {
+public class CleanUpJob implements Callable<List<? extends ListenableFuture<?>>> {
private static final Logger LOG = LoggerFactory.getLogger(CleanUpJob.class);
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
-public class IdHolderSyncJob implements Callable<List<ListenableFuture<Void>>> {
+public class IdHolderSyncJob implements Callable<List<? extends ListenableFuture<?>>> {
private static final Logger LOG = LoggerFactory.getLogger(IdHolderSyncJob.class);
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
-public class LocalPoolCreateJob implements Callable<List<ListenableFuture<Void>>> {
+public class LocalPoolCreateJob implements Callable<List<? extends ListenableFuture<?>>> {
private static final Logger LOG = LoggerFactory.getLogger(LocalPoolCreateJob.class);
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
-public class LocalPoolDeleteJob implements Callable<List<ListenableFuture<Void>>> {
+public class LocalPoolDeleteJob implements Callable<List<? extends ListenableFuture<?>>> {
private static final Logger LOG = LoggerFactory.getLogger(LocalPoolDeleteJob.class);
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
-public class UpdateIdEntryJob implements Callable<List<ListenableFuture<Void>>> {
+public class UpdateIdEntryJob implements Callable<List<? extends ListenableFuture<?>>> {
private static final Logger LOG = LoggerFactory.getLogger(UpdateIdEntryJob.class);
coordinator.enqueueJob(interfaceName, parentRefUpdateWorker, IfmConstants.JOB_MAX_RETRIES);
}
- public class ParentRefUpdateWorker implements Callable<List<ListenableFuture<Void>>> {
+ public class ParentRefUpdateWorker implements Callable<List<? extends ListenableFuture<?>>> {
String interfaceName;
String parentInterfaceName;
Boolean readInterfaceBeforeWrite;
}
}
- private class InterfaceStateUpdateWorker implements Callable<List<ListenableFuture<Void>>> {
+ private class InterfaceStateUpdateWorker implements Callable<List<? extends ListenableFuture<?>>> {
private final InstanceIdentifier<FlowCapableNodeConnector> key;
private final FlowCapableNodeConnector fcNodeConnectorOld;
private final FlowCapableNodeConnector fcNodeConnectorNew;
}
}
- private class InterfaceStateRemoveWorker implements Callable<List<ListenableFuture<Void>>> {
+ private class InterfaceStateRemoveWorker implements Callable<List<? extends ListenableFuture<?>>> {
private final NodeConnectorId nodeConnectorIdNew;
private NodeConnectorId nodeConnectorIdOld;
private final FlowCapableNodeConnector fcNodeConnectorOld;
});
}
- private class RendererStateAddWorker implements Callable<List<ListenableFuture<Void>>> {
+ private class RendererStateAddWorker implements Callable<List<? extends ListenableFuture<?>>> {
InstanceIdentifier<OvsdbBridgeAugmentation> instanceIdentifier;
OvsdbBridgeAugmentation bridgeNew;
}
}
- private class RendererStateRemoveWorker implements Callable<List<ListenableFuture<Void>>> {
+ private class RendererStateRemoveWorker implements Callable<List<? extends ListenableFuture<?>>> {
InstanceIdentifier<OvsdbBridgeAugmentation> instanceIdentifier;
OvsdbBridgeAugmentation bridgeNew;
}
}
- private class RendererStateUpdateWorker implements Callable<List<ListenableFuture<Void>>> {
+ private class RendererStateUpdateWorker implements Callable<List<? extends ListenableFuture<?>>> {
InstanceIdentifier<OvsdbBridgeAugmentation> instanceIdentifier;
OvsdbBridgeAugmentation bridgeNew;
OvsdbBridgeAugmentation bridgeOld;
update(identifier, null, tpNew);
}
- private class RendererStateUpdateWorker implements Callable<List<ListenableFuture<Void>>> {
+ private class RendererStateUpdateWorker implements Callable<List<? extends ListenableFuture<?>>> {
OvsdbTerminationPointAugmentation terminationPointNew;
RendererStateUpdateWorker(OvsdbTerminationPointAugmentation tpNew) {
}
}
- private class RendererStateRemoveWorker implements Callable<List<ListenableFuture<Void>>> {
+ private class RendererStateRemoveWorker implements Callable<List<? extends ListenableFuture<?>>> {
OvsdbTerminationPointAugmentation terminationPointOld;
RendererStateRemoveWorker(OvsdbTerminationPointAugmentation tpNew) {
return ifState;
}
- private static class VlanMemberStateRemoveWorker implements Callable<List<ListenableFuture<Void>>> {
+ private static class VlanMemberStateRemoveWorker implements Callable<List<? extends ListenableFuture<?>>> {
private final ManagedNewTransactionRunner txRunner;
private final InterfaceManagerCommonUtils interfaceManagerCommonUtils;
private final Uint64 dpId;
return newAug != null && !newAug.equals(oldAug);
}
- private static class VlanMemberStateUpdateWorker implements Callable<List<ListenableFuture<Void>>> {
+ private static class VlanMemberStateUpdateWorker implements Callable<List<? extends ListenableFuture<?>>> {
private final ManagedNewTransactionRunner txRunner;
private final OperStatus operStatus;
coordinator.enqueueJob(serviceKey.getInterfaceName(), configWorker, IfmConstants.JOB_MAX_RETRIES);
}
- private class RendererConfigAddWorker implements Callable<List<ListenableFuture<Void>>> {
+ private class RendererConfigAddWorker implements Callable<List<? extends ListenableFuture<?>>> {
private final String interfaceName;
Class<? extends ServiceModeBase> serviceMode;
FlowBasedServicesConfigAddable flowBasedServicesAddable;
}
}
- private class RendererConfigRemoveWorker implements Callable<List<ListenableFuture<Void>>> {
+ private class RendererConfigRemoveWorker implements Callable<List<? extends ListenableFuture<?>>> {
private final String interfaceName;
Class<? extends ServiceModeBase> serviceMode;
FlowBasedServicesConfigRemovable flowBasedServicesConfigRemovable;
close();
}
- private class RendererStateInterfaceBindWorker implements Callable<List<ListenableFuture<Void>>> {
+ private class RendererStateInterfaceBindWorker implements Callable<List<? extends ListenableFuture<?>>> {
Interface iface;
FlowBasedServicesStateAddable flowBasedServicesStateAddable;
Class<? extends ServiceModeBase> serviceMode;
}
}
- private static class RendererStateInterfaceBindWorker implements Callable<List<ListenableFuture<Void>>> {
+ private static class RendererStateInterfaceBindWorker implements Callable<List<? extends ListenableFuture<?>>> {
private final String iface;
final Uint64 dpnId;
final FlowBasedServicesStateAddable flowBasedServicesStateAddable;
return logicTunnelGroupName;
}
- private static class ItmTunnelAggregationWorker implements Callable<List<ListenableFuture<Void>>> {
+ private static class ItmTunnelAggregationWorker implements Callable<List<? extends ListenableFuture<?>>> {
private final String logicTunnelGroupName;
private final Uint64 srcDpnId;
jobCoordinator.enqueueJob(logicTunnelName, addWorker);
}
- private static class ItmTunnelAggregationDeleteWorker implements Callable<List<ListenableFuture<Void>>> {
+ private static class ItmTunnelAggregationDeleteWorker implements Callable<List<? extends ListenableFuture<?>>> {
private final String logicTunnelName;
private final Uint64 srcDpnId;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
-public class ItmMonitorIntervalWorker implements Callable<List<ListenableFuture<Void>>> {
+public class ItmMonitorIntervalWorker implements Callable<List<? extends ListenableFuture<?>>> {
private static final Logger LOG = LoggerFactory.getLogger(ItmMonitorIntervalWorker.class) ;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
-public class ItmMonitorToggleWorker implements Callable<List<ListenableFuture<Void>>> {
+public class ItmMonitorToggleWorker implements Callable<List<? extends ListenableFuture<?>>> {
private static final Logger LOG = LoggerFactory.getLogger(ItmMonitorToggleWorker.class);
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
-public class ItmMonitorWorker implements Callable<List<ListenableFuture<Void>>> {
+public class ItmMonitorWorker implements Callable<List<? extends ListenableFuture<?>>> {
private static final Logger LOG = LoggerFactory.getLogger(ItmMonitorWorker.class);
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
-public class ItmTepAddWorker implements Callable<List<ListenableFuture<Void>>> {
+public class ItmTepAddWorker implements Callable<List<? extends ListenableFuture<?>>> {
private static final Logger LOG = LoggerFactory.getLogger(ItmTepAddWorker.class);
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
-public class ItmTepRemoveWorker implements Callable<List<ListenableFuture<Void>>> {
+public class ItmTepRemoveWorker implements Callable<List<? extends ListenableFuture<?>>> {
private static final Logger LOG = LoggerFactory.getLogger(ItmTepRemoveWorker.class);
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
-public class ItmTepsNotHostedAddWorker implements Callable<List<ListenableFuture<Void>>> {
+public class ItmTepsNotHostedAddWorker implements Callable<List<? extends ListenableFuture<?>>> {
private static final Logger LOG = LoggerFactory.getLogger(ItmTepsNotHostedAddWorker.class);
private final List<UnknownVteps> vtepsList;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
-public class ItmTepsNotHostedMoveWorker implements Callable<List<ListenableFuture<Void>>> {
+public class ItmTepsNotHostedMoveWorker implements Callable<List<? extends ListenableFuture<?>>> {
private static final Logger LOG = LoggerFactory.getLogger(ItmTepsNotHostedMoveWorker.class);
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
-public class ItmTepsNotHostedRemoveWorker implements Callable<List<ListenableFuture<Void>>> {
+public class ItmTepsNotHostedRemoveWorker implements Callable<List<? extends ListenableFuture<?>>> {
private static final Logger LOG = LoggerFactory.getLogger(ItmTepsNotHostedRemoveWorker.class);
tx.merge(id, ifaceBuilderChild.build(), CREATE_MISSING_PARENTS);
}
- private class TunnelAggregationUpdateWorker implements Callable<List<ListenableFuture<Void>>> {
+ private class TunnelAggregationUpdateWorker implements Callable<List<? extends ListenableFuture<?>>> {
private final Interface ifStateOrigin;
private final Interface ifStateUpdated;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
-public class OvsdbTepAddWorker implements Callable<List<ListenableFuture<Void>>> {
+public class OvsdbTepAddWorker implements Callable<List<? extends ListenableFuture<?>>> {
private static final Logger LOG = LoggerFactory.getLogger(OvsdbTepAddWorker.class) ;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
-public class OvsdbTepRemoveWorker implements Callable<List<ListenableFuture<Void>>> {
+public class OvsdbTepRemoveWorker implements Callable<List<? extends ListenableFuture<?>>> {
private static final Logger LOG = LoggerFactory.getLogger(OvsdbTepRemoveWorker.class) ;
}
}
- private static class RendererConfigDeleteWorker implements Callable<List<ListenableFuture<Void>>> {
+ private static class RendererConfigDeleteWorker implements Callable<List<? extends ListenableFuture<?>>> {
final InstanceIdentifier<Interface> key;
final Interface interfaceNew;
return "tun" + internalTunnel.getSourceDPN() + internalTunnel.getDestinationDPN();
}
- private static class RendererInternalTunnelDeleteWorker implements Callable<List<ListenableFuture<Void>>> {
+ private static class RendererInternalTunnelDeleteWorker implements Callable<List<? extends ListenableFuture<?>>> {
final InstanceIdentifier<InternalTunnel> key;
final InternalTunnel internalTunnel;
transaction.merge(LogicalDatastoreType.OPERATIONAL, stateTnlII, stateTnlBuilder.build(), false);
}
- private class RendererTunnelStateUpdateWorker implements Callable<List<ListenableFuture<Void>>> {
+ private class RendererTunnelStateUpdateWorker implements Callable<List<? extends ListenableFuture<?>>> {
private final OvsdbTerminationPointAugmentation terminationPointNew;
RendererTunnelStateUpdateWorker(OvsdbTerminationPointAugmentation tpNew) {
}
}
- private class RendererTunnelStateRemoveWorker implements Callable<List<ListenableFuture<Void>>> {
+ private class RendererTunnelStateRemoveWorker implements Callable<List<? extends ListenableFuture<?>>> {
private final OvsdbTerminationPointAugmentation terminationPointOld;
RendererTunnelStateRemoveWorker(OvsdbTerminationPointAugmentation tpNew) {
return futures;
}
- private class TunnelInterfaceStateUpdateWorker implements Callable<List<ListenableFuture<Void>>> {
+ private class TunnelInterfaceStateUpdateWorker implements Callable<List<? extends ListenableFuture<?>>> {
private final InstanceIdentifier<FlowCapableNodeConnector> key;
private final FlowCapableNodeConnector fcNodeConnectorOld;
private final FlowCapableNodeConnector fcNodeConnectorNew;
}
}
- private class TunnelInterfaceStateRemoveWorker implements Callable<List<ListenableFuture<Void>>> {
+ private class TunnelInterfaceStateRemoveWorker implements Callable<List<? extends ListenableFuture<?>>> {
private final NodeConnectorId nodeConnectorId;
private final FlowCapableNodeConnector flowCapableNodeConnector;
private final String interfaceName;
}
}
- private class TunnelRendererStateAddWorker implements Callable<List<ListenableFuture<Void>>> {
+ private class TunnelRendererStateAddWorker implements Callable<List<? extends ListenableFuture<?>>> {
private final InstanceIdentifier<OvsdbBridgeAugmentation> bridgeIid;
private final OvsdbBridgeAugmentation bridgeNew;
}
}
- private class TunnelRendererStateRemoveWorker implements Callable<List<ListenableFuture<Void>>> {
+ private class TunnelRendererStateRemoveWorker implements Callable<List<? extends ListenableFuture<?>>> {
private final InstanceIdentifier<OvsdbBridgeAugmentation> instanceIdentifier;
private final OvsdbBridgeAugmentation bridgeNew;
}
}
- private class TunnelRendererStateUpdateWorker implements Callable<List<ListenableFuture<Void>>> {
+ private class TunnelRendererStateUpdateWorker implements Callable<List<? extends ListenableFuture<?>>> {
private final InstanceIdentifier<OvsdbBridgeAugmentation> instanceIdentifier;
private final OvsdbBridgeAugmentation bridgeNew;
private final OvsdbBridgeAugmentation bridgeOld;
import java.util.concurrent.Callable;
import org.opendaylight.genius.itm.utils.TunnelStateInfo;
-public class TunnelStateAddWorkerForNodeConnector implements Callable<List<ListenableFuture<Void>>> {
+public class TunnelStateAddWorkerForNodeConnector implements Callable<List<? extends ListenableFuture<?>>> {
private final TunnelStateAddWorker tunnelStateAddWorker;
private final TunnelStateInfo tunnelStateInfo;
return alarmText.toString();
}
- private class ItmTunnelAddAlarmWorker implements Callable<List<ListenableFuture<Void>>> {
+ private class ItmTunnelAddAlarmWorker implements Callable<List<? extends ListenableFuture<?>>> {
private final StateTunnelList add;
ItmTunnelAddAlarmWorker(StateTunnelList tnlIface) {
}
}
- private class ItmTunnelRemoveAlarmWorker implements Callable<List<ListenableFuture<Void>>> {
+ private class ItmTunnelRemoveAlarmWorker implements Callable<List<? extends ListenableFuture<?>>> {
private final StateTunnelList del;
ItmTunnelRemoveAlarmWorker(StateTunnelList tnlIface) {
}
}
- private class ItmTunnelUpdateAlarmWorker implements Callable<List<ListenableFuture<Void>>> {
+ private class ItmTunnelUpdateAlarmWorker implements Callable<List<? extends ListenableFuture<?>>> {
private final StateTunnelList update;
private final StateTunnelList original;
}
}
- private static class ItmTunnelStatusOutOfOrderEventWorker implements Callable<List<ListenableFuture<Void>>> {
+ private static class ItmTunnelStatusOutOfOrderEventWorker implements Callable<List<? extends ListenableFuture<?>>> {
private final InstanceIdentifier<StateTunnelList> identifier;
private final StateTunnelList add;
private final TunnelOperStatus operStatus;
* @param job the job task
*/
public void runOnlyInOwnerNode(String entityType, String entityName, JobCoordinator coordinator,
- String jobKey, String jobDesc, Callable<List<ListenableFuture<Void>>> job) {
+ String jobKey, String jobDesc, Callable<List<? extends ListenableFuture<?>>> job) {
final Entity entity = new Entity(entityType, entityName);
coordinator.enqueueJob(getEntityIdentifierString(entityType, entityName), () -> {
if (isEntityOwner(entity)) {
*/
public class TestableJobCoordinatorEventsWaiterTest {
- private static class TestCallable implements Callable<List<ListenableFuture<Void>>> {
+ private static class TestCallable implements Callable<List<? extends ListenableFuture<?>>> {
boolean wasCalled = false;
AtomicInteger invocationCount = new AtomicInteger();
Code Review / genius.git / commitdiff