import com.google.common.util.concurrent.Futures;
import com.google.common.util.concurrent.ListenableFuture;
import com.google.common.util.concurrent.MoreExecutors;
-import edu.umd.cs.findbugs.annotations.SuppressFBWarnings;
-import javax.annotation.Nonnull;
-import javax.annotation.Nullable;
+import org.eclipse.jdt.annotation.NonNull;
+import org.eclipse.jdt.annotation.Nullable;
import org.opendaylight.mdsal.common.api.LogicalDatastoreType;
import org.opendaylight.openflowplugin.api.openflow.connection.ConnectionContext;
import org.opendaylight.openflowplugin.api.openflow.device.DeviceContext;
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.types.rev130731.CapabilitiesV10;
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.types.rev130731.MultipartType;
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.PortGrouping;
-import org.opendaylight.yang.gen.v1.urn.opendaylight.port.statistics.rev131214.FlowCapableNodeConnectorStatisticsData;
import org.opendaylight.yang.gen.v1.urn.opendaylight.port.statistics.rev131214.FlowCapableNodeConnectorStatisticsDataBuilder;
import org.opendaylight.yangtools.yang.common.RpcResult;
import org.slf4j.Logger;
private static final Logger LOG = LoggerFactory.getLogger(OF10DeviceInitializer.class);
@Override
- protected ListenableFuture<Void> initializeNodeInformation(@Nonnull final DeviceContext deviceContext,
+ protected ListenableFuture<Void> initializeNodeInformation(@NonNull final DeviceContext deviceContext,
final boolean switchFeaturesMandatory,
final boolean skipTableFeatures,
@Nullable final MultipartWriterProvider multipartWriterProvider,
port.getPortNo(),
OpenflowVersion.get(deviceInfo.getVersion()));
+ final NodeConnectorBuilder connectorBuilder = new NodeConnectorBuilder()
+ .setId(nodeConnectorId)
+ .addAugmentation(new FlowCapableNodeConnectorStatisticsDataBuilder().build());
+ final FlowCapableNodeConnector augment = translator.translate(port, deviceInfo, null);
+ if (augment != null) {
+ connectorBuilder.addAugmentation(augment);
+ }
+
try {
deviceContext.writeToTransaction(LogicalDatastoreType.OPERATIONAL,
deviceInfo
.getNodeInstanceIdentifier()
.child(NodeConnector.class, new NodeConnectorKey(nodeConnectorId)),
- new NodeConnectorBuilder()
- .setId(nodeConnectorId)
- .addAugmentation(
- FlowCapableNodeConnector.class,
- translator.translate(port, deviceInfo, null))
- .addAugmentation(
- FlowCapableNodeConnectorStatisticsData.class,
- new FlowCapableNodeConnectorStatisticsDataBuilder().build())
- .build());
+ connectorBuilder.build());
} catch (final Exception e) {
LOG.debug("Failed to write node {} to DS ", deviceInfo, e);
}
}
@SuppressWarnings("checkstyle:IllegalCatch")
- @SuppressFBWarnings(value = "UPM_UNCALLED_PRIVATE_METHOD",
- justification = "https://github.com/spotbugs/spotbugs/issues/811")
private static void makeEmptyFlowCapableNode(final TxFacade txFacade, final DeviceInfo deviceInfo) {
try {
txFacade.writeToTransaction(LogicalDatastoreType.OPERATIONAL,