X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;f=mappingservice%2Fdsbackend%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Flispflowmapping%2Fdsbackend%2FDataStoreBackEnd.java;fp=mappingservice%2Fimplementation%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Flispflowmapping%2Fimplementation%2Fmdsal%2FDataStoreBackEnd.java;h=9d2d2a351f4255eb568d0c64269c15c16c30ff16;hb=ba581e20c92a17643f5fe36f10e1d025917c5860;hp=aee385ac0423981bdaae8adb261256190434a68e;hpb=8ae01fdd4ae23c3b4b0076d488380d0b1ca14ae8;p=lispflowmapping.git diff --git a/mappingservice/implementation/src/main/java/org/opendaylight/lispflowmapping/implementation/mdsal/DataStoreBackEnd.java b/mappingservice/dsbackend/src/main/java/org/opendaylight/lispflowmapping/dsbackend/DataStoreBackEnd.java similarity index 98% rename from mappingservice/implementation/src/main/java/org/opendaylight/lispflowmapping/implementation/mdsal/DataStoreBackEnd.java rename to mappingservice/dsbackend/src/main/java/org/opendaylight/lispflowmapping/dsbackend/DataStoreBackEnd.java index aee385ac0..9d2d2a351 100644 --- a/mappingservice/implementation/src/main/java/org/opendaylight/lispflowmapping/implementation/mdsal/DataStoreBackEnd.java +++ b/mappingservice/dsbackend/src/main/java/org/opendaylight/lispflowmapping/dsbackend/DataStoreBackEnd.java @@ -5,7 +5,7 @@ * 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.lispflowmapping.implementation.mdsal; +package org.opendaylight.lispflowmapping.dsbackend; import java.util.ArrayList; import java.util.List; @@ -19,7 +19,6 @@ import org.opendaylight.controller.md.sal.common.api.data.LogicalDatastoreType; import org.opendaylight.controller.md.sal.common.api.data.ReadFailedException; import org.opendaylight.controller.md.sal.common.api.data.TransactionChain; import org.opendaylight.controller.md.sal.common.api.data.TransactionChainListener; -import org.opendaylight.lispflowmapping.implementation.util.InstanceIdentifierUtil; import org.opendaylight.lispflowmapping.lisp.util.LispAddressStringifier; import org.opendaylight.yang.gen.v1.urn.opendaylight.lfm.lisp.proto.rev151105.XtrId; import org.opendaylight.yang.gen.v1.urn.opendaylight.lfm.mappingservice.rev150906.MappingDatabase; @@ -54,6 +53,7 @@ public class DataStoreBackEnd implements TransactionChainListener { this.txChain = broker.createTransactionChain(this); } + public void addAuthenticationKey(AuthenticationKey authenticationKey) { if (LOG.isDebugEnabled()) { LOG.debug("MD-SAL: Adding authentication key '{}' for {}", @@ -224,10 +224,10 @@ public class DataStoreBackEnd implements TransactionChainListener { WriteTransaction writeTx = txChain.newWriteOnlyTransaction(); writeTx.put(logicalDatastoreType, addIID, data, true); Futures.addCallback(writeTx.submit(), new FutureCallback() { - @Override + public void onSuccess(Void result) { } - @Override + public void onFailure(Throwable t) { LOG.error("Transaction failed:", t); } @@ -258,24 +258,22 @@ public class DataStoreBackEnd implements TransactionChainListener { WriteTransaction writeTx = txChain.newWriteOnlyTransaction(); writeTx.delete(logicalDatastoreType, deleteIID); Futures.addCallback(writeTx.submit(), new FutureCallback() { - @Override + public void onSuccess(Void result) { } - @Override + public void onFailure(Throwable t) { LOG.error("Transaction failed:", t); } }); } - @Override public void onTransactionChainFailed(TransactionChain chain, AsyncTransaction transaction, Throwable cause) { LOG.error("Broken chain {} in DataStoreBackEnd, transaction {}, cause {}", chain, transaction.getIdentifier(), cause); } - @Override public void onTransactionChainSuccessful(TransactionChain chain) { LOG.info("DataStoreBackEnd closed successfully, chain {}", chain); }