X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;f=samples%2Flearning-switch%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fopenflowplugin%2Flearningswitch%2FFlowCommitWrapperImpl.java;h=a6dd4ded3bb3fa78efe0d9199599a829e56a1583;hb=05f8db12159673d0e0a95642fe86e62c14b7dc7b;hp=b6458aac28e4b18e772eb800ce601ccaf46a4456;hpb=b33b612f863b9d305c29454cc93757cfc6fc3323;p=openflowplugin.git diff --git a/samples/learning-switch/src/main/java/org/opendaylight/openflowplugin/learningswitch/FlowCommitWrapperImpl.java b/samples/learning-switch/src/main/java/org/opendaylight/openflowplugin/learningswitch/FlowCommitWrapperImpl.java index b6458aac28..a6dd4ded3b 100644 --- a/samples/learning-switch/src/main/java/org/opendaylight/openflowplugin/learningswitch/FlowCommitWrapperImpl.java +++ b/samples/learning-switch/src/main/java/org/opendaylight/openflowplugin/learningswitch/FlowCommitWrapperImpl.java @@ -1,17 +1,16 @@ -/** +/* * 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 */ - package org.opendaylight.openflowplugin.learningswitch; import com.google.common.util.concurrent.ListenableFuture; -import org.opendaylight.controller.md.sal.binding.api.DataBroker; -import org.opendaylight.controller.md.sal.binding.api.ReadWriteTransaction; -import org.opendaylight.controller.md.sal.common.api.data.LogicalDatastoreType; +import org.opendaylight.mdsal.binding.api.DataBroker; +import org.opendaylight.mdsal.binding.api.ReadWriteTransaction; +import org.opendaylight.mdsal.common.api.LogicalDatastoreType; import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.inventory.rev130819.tables.table.Flow; import org.opendaylight.yangtools.yang.binding.InstanceIdentifier; @@ -24,10 +23,10 @@ public class FlowCommitWrapperImpl implements FlowCommitWrapper { } @Override - public ListenableFuture writeFlowToConfig(InstanceIdentifier flowPath, Flow flowBody) { + public ListenableFuture writeFlowToConfig(InstanceIdentifier flowPath, Flow flowBody) { ReadWriteTransaction addFlowTransaction = dataBrokerService.newReadWriteTransaction(); - addFlowTransaction.put(LogicalDatastoreType.CONFIGURATION, flowPath, flowBody, true); - return addFlowTransaction.submit(); + addFlowTransaction.mergeParentStructurePut(LogicalDatastoreType.CONFIGURATION, flowPath, flowBody); + return addFlowTransaction.commit(); } }