2 * Copyright (c) 2019 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.elan.l2gw.recovery.impl;
10 import java.util.Optional;
11 import java.util.concurrent.ExecutionException;
12 import javax.inject.Inject;
13 import javax.inject.Singleton;
14 import org.opendaylight.genius.datastoreutils.SingleTransactionDataBroker;
15 import org.opendaylight.genius.infra.ManagedNewTransactionRunner;
16 import org.opendaylight.genius.infra.ManagedNewTransactionRunnerImpl;
17 import org.opendaylight.genius.utils.clustering.EntityOwnershipUtils;
18 import org.opendaylight.infrautils.jobcoordinator.JobCoordinator;
19 import org.opendaylight.mdsal.binding.api.DataBroker;
20 import org.opendaylight.mdsal.common.api.LogicalDatastoreType;
21 import org.opendaylight.netvirt.elan.l2gw.utils.L2GatewayConnectionUtils;
22 import org.opendaylight.serviceutils.srm.ServiceRecoveryInterface;
23 import org.opendaylight.serviceutils.srm.ServiceRecoveryRegistry;
24 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.yang.types.rev130715.Uuid;
25 import org.opendaylight.yang.gen.v1.urn.opendaylight.neutron.l2gateways.rev150712.l2gateway.connections.attributes.L2gatewayConnections;
26 import org.opendaylight.yang.gen.v1.urn.opendaylight.neutron.l2gateways.rev150712.l2gateway.connections.attributes.l2gatewayconnections.L2gatewayConnection;
27 import org.opendaylight.yang.gen.v1.urn.opendaylight.neutron.l2gateways.rev150712.l2gateway.connections.attributes.l2gatewayconnections.L2gatewayConnectionKey;
28 import org.opendaylight.yang.gen.v1.urn.opendaylight.neutron.rev150712.Neutron;
29 import org.opendaylight.yang.gen.v1.urn.opendaylight.serviceutils.srm.types.rev180626.NetvirtL2gwConnection;
30 import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
31 import org.slf4j.Logger;
32 import org.slf4j.LoggerFactory;
36 public class L2GatewayConnectionInstanceRecoveryHandler implements ServiceRecoveryInterface {
38 private static final Logger LOG = LoggerFactory.getLogger(L2GatewayConnectionInstanceRecoveryHandler.class);
40 private final ManagedNewTransactionRunner txRunner;
41 private final DataBroker dataBroker;
42 private ServiceRecoveryRegistry serviceRecoveryRegistry;
43 private JobCoordinator jobCoordinator;
44 private L2GatewayConnectionUtils l2GatewayConnectionUtils;
45 private EntityOwnershipUtils entityOwnershipUtils;
48 public L2GatewayConnectionInstanceRecoveryHandler(DataBroker dataBroker,
49 ServiceRecoveryRegistry serviceRecoveryRegistry,
50 JobCoordinator jobCoordinator,
51 L2GatewayConnectionUtils l2GatewayConnectionUtils,
52 EntityOwnershipUtils entityOwnershipUtils) {
53 this.txRunner = new ManagedNewTransactionRunnerImpl(dataBroker);
54 this.dataBroker = dataBroker;
55 this.serviceRecoveryRegistry = serviceRecoveryRegistry;
56 this.jobCoordinator = jobCoordinator;
57 this.l2GatewayConnectionUtils = l2GatewayConnectionUtils;
58 this.entityOwnershipUtils = entityOwnershipUtils;
59 serviceRecoveryRegistry.registerServiceRecoveryRegistry(buildServiceRegistryKey(),this);
63 @SuppressWarnings("ForbidCertainMethod")
64 public void recoverService(String entityId) {
65 LOG.info("recover l2gateway connection {}", entityId);
66 // Fetch the l2 gateway connection from l2 gateway connection config DS first.
67 Uuid uuid = Uuid.getDefaultInstance(entityId);
69 InstanceIdentifier<L2gatewayConnection> connectionInstanceIdentifier = InstanceIdentifier.create(Neutron.class)
70 .child(L2gatewayConnections.class)
71 .child(L2gatewayConnection.class, new L2gatewayConnectionKey(uuid));
73 Optional<L2gatewayConnection> l2gatewayConnectionOptional = Optional.empty();
75 l2gatewayConnectionOptional = SingleTransactionDataBroker.syncReadOptional(
76 dataBroker, LogicalDatastoreType.CONFIGURATION, connectionInstanceIdentifier);
77 } catch (ExecutionException | InterruptedException e) {
78 LOG.error("recoverService: Exception while reading L2gatewayConnection DS", e);
80 //l2GatewayConnectionUtils.addL2GatewayConnection(l2gatewayConnectionOptional.get());
82 if (l2gatewayConnectionOptional.isPresent()) {
83 L2gatewayConnection l2gatewayConnection = l2gatewayConnectionOptional.get();
86 LOG.info("deleting l2 gateway connection {}",l2gatewayConnection.key());
87 txRunner.callWithNewWriteOnlyTransactionAndSubmit(
88 tx -> tx.delete(LogicalDatastoreType.CONFIGURATION, connectionInstanceIdentifier)).get();
89 LOG.info("recreating l2 gateway connection {}, {}",entityId, l2gatewayConnection.key());
90 txRunner.callWithNewWriteOnlyTransactionAndSubmit(
91 tx -> tx.put(LogicalDatastoreType.CONFIGURATION, connectionInstanceIdentifier,
92 l2gatewayConnection)).get();
93 } catch (InterruptedException | ExecutionException e) {
94 LOG.error("Service recovery failed for l2gw connection {}", entityId);
99 public String buildServiceRegistryKey() {
100 return NetvirtL2gwConnection.class.toString();