* 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;
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;
this.txChain = broker.createTransactionChain(this);
}
+
public void addAuthenticationKey(AuthenticationKey authenticationKey) {
if (LOG.isDebugEnabled()) {
LOG.debug("MD-SAL: Adding authentication key '{}' for {}",
WriteTransaction writeTx = txChain.newWriteOnlyTransaction();
writeTx.put(logicalDatastoreType, addIID, data, true);
Futures.addCallback(writeTx.submit(), new FutureCallback<Void>() {
- @Override
+
public void onSuccess(Void result) {
}
- @Override
+
public void onFailure(Throwable t) {
LOG.error("Transaction failed:", t);
}
WriteTransaction writeTx = txChain.newWriteOnlyTransaction();
writeTx.delete(logicalDatastoreType, deleteIID);
Futures.addCallback(writeTx.submit(), new FutureCallback<Void>() {
- @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);
}