2 * Copyright (c) 2016 Ericsson India Global Services Pvt Ltd. and others. All rights reserved.
4 * This program and the accompanying materials are made available under the
5 * terms of the Eclipse Public License v1.0 which accompanies this distribution,
6 * and is available at http://www.eclipse.org/legal/epl-v10.html
8 package org.opendaylight.netvirt.vpnmanager.intervpnlink.tasks;
10 import static org.opendaylight.controller.md.sal.binding.api.WriteTransaction.CREATE_MISSING_PARENTS;
11 import static org.opendaylight.genius.infra.Datastore.CONFIGURATION;
13 import com.google.common.util.concurrent.ListenableFuture;
14 import java.util.Collections;
15 import java.util.List;
16 import java.util.concurrent.Callable;
17 import org.opendaylight.controller.md.sal.binding.api.DataBroker;
18 import org.opendaylight.genius.infra.ManagedNewTransactionRunner;
19 import org.opendaylight.genius.infra.ManagedNewTransactionRunnerImpl;
20 import org.opendaylight.netvirt.vpnmanager.intervpnlink.InterVpnLinkUtil;
21 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.netvirt.inter.vpn.link.rev160311.inter.vpn.links.InterVpnLink;
22 import org.slf4j.Logger;
23 import org.slf4j.LoggerFactory;
25 public class InterVpnLinkCreatorTask implements Callable<List<ListenableFuture<Void>>> {
27 private static final Logger LOG = LoggerFactory.getLogger(InterVpnLinkCreatorTask.class);
29 private final ManagedNewTransactionRunner txRunner;
30 private final InterVpnLink interVpnLinkToPersist;
32 public InterVpnLinkCreatorTask(DataBroker dataBroker, InterVpnLink interVpnLink) {
33 this.txRunner = new ManagedNewTransactionRunnerImpl(dataBroker);
34 this.interVpnLinkToPersist = interVpnLink;
38 public List<ListenableFuture<Void>> call() {
40 "Persisting InterVpnLink {} with 1stEndpoint=[ vpn={}, ipAddr={} ] and 2ndEndpoint=[ vpn={}, ipAddr={} ]",
41 interVpnLinkToPersist.getName(), interVpnLinkToPersist.getFirstEndpoint().getVpnUuid(),
42 interVpnLinkToPersist.getFirstEndpoint().getIpAddress(),
43 interVpnLinkToPersist.getSecondEndpoint().getVpnUuid(),
44 interVpnLinkToPersist.getSecondEndpoint().getIpAddress());
46 return Collections.singletonList(txRunner.callWithNewWriteOnlyTransactionAndSubmit(CONFIGURATION, tx ->
47 tx.merge(InterVpnLinkUtil.getInterVpnLinkPath(interVpnLinkToPersist.getName()),
48 interVpnLinkToPersist, CREATE_MISSING_PARENTS)));