Change-Id: Idef70e2e2f28e231dacbe2ccda8a8a9d484570e1
Signed-off-by: Martin Bobak <mbobak@cisco.com>
flowId = FlowUtil.createAlienFlowId(input.getTableId());
}
flowId = FlowUtil.createAlienFlowId(input.getTableId());
}
+ final DeviceContext deviceContext = getDeviceContext();
+ final FlowHash flowHash = FlowHashFactory.create(input, deviceContext.getPrimaryConnectionContext().getFeatures().getVersion());
+ final FlowDescriptor flowDescriptor = FlowDescriptorFactory.create(input.getTableId(), flowId);
+ deviceContext.getDeviceFlowRegistry().store(flowHash, flowDescriptor);
Futures.addCallback(future, new FutureCallback<RpcResult<AddFlowOutput>>() {
Futures.addCallback(future, new FutureCallback<RpcResult<AddFlowOutput>>() {
- final DeviceContext deviceContext = getDeviceContext();
- final FlowHash flowHash = FlowHashFactory.create(input, deviceContext.getPrimaryConnectionContext().getFeatures().getVersion());
@Override
public void onSuccess(final RpcResult<AddFlowOutput> rpcResult) {
@Override
public void onSuccess(final RpcResult<AddFlowOutput> rpcResult) {