X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?p=controller.git;a=blobdiff_plain;f=opendaylight%2Fmd-sal%2Fforwardingrules-manager%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Ffrm%2Fflow%2FFlowChangeListener.java;h=b60424513f2fb9f6c930e1648f937008bf9d203e;hp=df086c7acc9ac92f13bad11cec3f5957d75beebe;hb=1ee71ae58a03de1c1f8fd8c789e7921508ba9f59;hpb=4cb9924282774a2979030076e09f69826fa93585 diff --git a/opendaylight/md-sal/forwardingrules-manager/src/main/java/org/opendaylight/controller/frm/flow/FlowChangeListener.java b/opendaylight/md-sal/forwardingrules-manager/src/main/java/org/opendaylight/controller/frm/flow/FlowChangeListener.java index df086c7acc..b60424513f 100644 --- a/opendaylight/md-sal/forwardingrules-manager/src/main/java/org/opendaylight/controller/frm/flow/FlowChangeListener.java +++ b/opendaylight/md-sal/forwardingrules-manager/src/main/java/org/opendaylight/controller/frm/flow/FlowChangeListener.java @@ -1,6 +1,6 @@ /** * Copyright (c) 2014 Cisco Systems, Inc. and others. All rights reserved. - * + * * This program and the accompanying materials are made available under the * terms of the Eclipse Public License v1.0 which accompanies this distribution, * and is available at http://www.eclipse.org/legal/epl-v10.html @@ -32,7 +32,7 @@ import org.slf4j.Logger; import org.slf4j.LoggerFactory; /** - * + * * @author Vaclav Demcak * */ @@ -45,7 +45,7 @@ public class FlowChangeListener extends AbstractChangeListener { public SalFlowService getSalFlowService() { return this.salFlowService; } - + public FlowChangeListener(final SalFlowService manager) { this.salFlowService = manager; } @@ -58,16 +58,16 @@ public class FlowChangeListener extends AbstractChangeListener { @Override protected void remove(InstanceIdentifier identifier, DataObject removeDataObj) { if ((removeDataObj instanceof Flow)) { - + final Flow flow = ((Flow) removeDataObj); final InstanceIdentifier tableInstanceId = identifier.
firstIdentifierOf(Table.class); final InstanceIdentifier nodeInstanceId = identifier. firstIdentifierOf(Node.class); final RemoveFlowInputBuilder builder = new RemoveFlowInputBuilder(flow); - + builder.setFlowRef(new FlowRef(identifier)); builder.setNode(new NodeRef(nodeInstanceId)); builder.setFlowTable(new FlowTableRef(tableInstanceId)); - + Uri uri = new Uri(this.getTransactionId()); builder.setTransactionUri(uri); this.salFlowService.removeFlow((RemoveFlowInput) builder.build()); @@ -78,21 +78,21 @@ public class FlowChangeListener extends AbstractChangeListener { @Override protected void update(InstanceIdentifier identifier, DataObject original, DataObject update) { if (original instanceof Flow && update instanceof Flow) { - + final Flow originalFlow = ((Flow) original); final Flow updatedFlow = ((Flow) update); final InstanceIdentifier nodeInstanceId = identifier.firstIdentifierOf(Node.class); final UpdateFlowInputBuilder builder = new UpdateFlowInputBuilder(); - + builder.setNode(new NodeRef(nodeInstanceId)); builder.setFlowRef(new FlowRef(identifier)); - + Uri uri = new Uri(this.getTransactionId()); builder.setTransactionUri(uri); - + builder.setUpdatedFlow((UpdatedFlow) (new UpdatedFlowBuilder(updatedFlow)).build()); builder.setOriginalFlow((OriginalFlow) (new OriginalFlowBuilder(originalFlow)).build()); - + this.salFlowService.updateFlow((UpdateFlowInput) builder.build()); LOG.debug("Transaction {} - Update Flow has updated flow {} with {}", new Object[]{uri, original, update}); } @@ -101,16 +101,16 @@ public class FlowChangeListener extends AbstractChangeListener { @Override protected void add(InstanceIdentifier identifier, DataObject addDataObj) { if ((addDataObj instanceof Flow)) { - + final Flow flow = ((Flow) addDataObj); final InstanceIdentifier
tableInstanceId = identifier.
firstIdentifierOf(Table.class); final InstanceIdentifier nodeInstanceId = identifier. firstIdentifierOf(Node.class); final AddFlowInputBuilder builder = new AddFlowInputBuilder(flow); - + builder.setNode(new NodeRef(nodeInstanceId)); builder.setFlowRef(new FlowRef(identifier)); builder.setFlowTable(new FlowTableRef(tableInstanceId)); - + Uri uri = new Uri(this.getTransactionId()); builder.setTransactionUri(uri); this.salFlowService.addFlow((AddFlowInput) builder.build());