+ ListenableFuture<List<RpcResult<List<MultipartReply>>>> deviceFeaturesFuture = null;
+
+ if (connectionContext.getFeatures().getVersion() == OFConstants.OFP_VERSION_1_0) {
+ final CapabilitiesV10 capabilitiesV10 = connectionContext.getFeatures().getCapabilitiesV10();
+
+ DeviceStateUtil.setDeviceStateBasedOnV10Capabilities(deviceState, capabilitiesV10);
+ //FIXME: next two lines are hack to make OF10 + cbench working (they don't send reply for description request)
+ createEmptyFlowCapableNodeInDs(deviceContext);
+ makeEmptyTables(deviceContext, deviceContext.getDeviceState().getNodeInstanceIdentifier(), connectionContext.getFeatures().getTables());
+
+ deviceFeaturesFuture = Futures.immediateFuture(null);//createDeviceFeaturesForOF10(messageListener, deviceContext, deviceState);
+
+ for (final PortGrouping port : connectionContext.getFeatures().getPhyPort()) {
+ final short ofVersion = deviceContext.getDeviceState().getVersion();
+ final TranslatorKey translatorKey = new TranslatorKey(ofVersion, PortGrouping.class.getName());
+ final MessageTranslator<PortGrouping, FlowCapableNodeConnector> translator = deviceContext.oook().lookupTranslator(translatorKey);
+ final FlowCapableNodeConnector fcNodeConnector = translator.translate(port, deviceContext, null);
+
+ final BigInteger dataPathId = deviceContext.getPrimaryConnectionContext().getFeatures().getDatapathId();
+ final NodeConnectorId nodeConnectorId = NodeStaticReplyTranslatorUtil.nodeConnectorId(dataPathId.toString(), port.getPortNo(), ofVersion);
+ final NodeConnectorBuilder ncBuilder = new NodeConnectorBuilder().setId(nodeConnectorId);
+ ncBuilder.addAugmentation(FlowCapableNodeConnector.class, fcNodeConnector);
+ ncBuilder.addAugmentation(FlowCapableNodeConnectorStatisticsData.class, new FlowCapableNodeConnectorStatisticsDataBuilder().build());
+ final NodeConnector connector = ncBuilder.build();
+ final InstanceIdentifier<NodeConnector> connectorII = deviceState.getNodeInstanceIdentifier().child(NodeConnector.class, connector.getKey());
+ deviceContext.writeToTransaction(LogicalDatastoreType.OPERATIONAL, connectorII, connector);
+ //FlowCapableNodeConnectorBuilder
+ }
+ } else if (connectionContext.getFeatures().getVersion() == OFConstants.OFP_VERSION_1_3) {
+ final Capabilities capabilities = connectionContext.getFeatures().getCapabilities();
+ DeviceStateUtil.setDeviceStateBasedOnV13Capabilities(deviceState, capabilities);
+ deviceFeaturesFuture = createDeviceFeaturesForOF13(messageListener, deviceContext, deviceState);
+ }
+
+ Futures.addCallback(deviceFeaturesFuture, new FutureCallback<List<RpcResult<List<MultipartReply>>>>() {
+ @Override
+ public void onSuccess(final List<RpcResult<List<MultipartReply>>> result) {
+ deviceInitPhaseHandler.onDeviceContextLevelUp(deviceContext);
+ }
+
+ @Override
+ public void onFailure(final Throwable t) {
+ // FIXME : remove session
+ LOG.trace("Device capabilities gathering future failed.");
+ }
+ });
+ }
+
+
+ private ListenableFuture<RpcResult<List<MultipartReply>>> processReplyDesc(OpenflowProtocolListenerFullImpl messageListener,
+ DeviceContext deviceContext,
+ DeviceState deviceState) {