2 * Copyright © 2023 Fujitsu Network Communications, Inc. 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.transportpce.servicehandler.catalog;
10 import java.util.concurrent.ExecutionException;
11 import java.util.concurrent.TimeUnit;
12 import java.util.concurrent.TimeoutException;
13 import org.opendaylight.mdsal.binding.api.DataBroker;
14 import org.opendaylight.mdsal.binding.api.WriteTransaction;
15 import org.opendaylight.mdsal.common.api.LogicalDatastoreType;
16 import org.opendaylight.transportpce.common.Timeouts;
17 import org.opendaylight.yang.gen.v1.http.org.openroadm.operational.mode.catalog.rev211210.operational.mode.catalog.OpenroadmOperationalModes;
18 import org.opendaylight.yang.gen.v1.http.org.openroadm.operational.mode.catalog.rev211210.operational.mode.catalog.SpecificOperationalModes;
19 import org.opendaylight.yang.gen.v1.http.org.openroadm.service.rev211210.OperationalModeCatalog;
20 import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
21 import org.slf4j.Logger;
22 import org.slf4j.LoggerFactory;
24 public class CatalogDataStoreOperationsImpl implements CatalogDataStoreOperations {
25 private static final Logger LOG = LoggerFactory.getLogger(CatalogDataStoreOperationsImpl.class);
27 private DataBroker dataBroker;
29 public CatalogDataStoreOperationsImpl(DataBroker dataBroker) {
30 this.dataBroker = dataBroker;
34 * Store OpenroadmOperationalModes object in the config data store.
37 public void addOpenroadmOperationalModesToCatalog(OpenroadmOperationalModes objToSave) {
38 LOG.info("Inside addOpenroadmOperationalModesToCatalog method of CatalogDataStoreOperationsImpl");
40 InstanceIdentifier<OpenroadmOperationalModes> instanceIdentifier =
41 InstanceIdentifier.create(OperationalModeCatalog.class).child(OpenroadmOperationalModes.class);
42 WriteTransaction writeTransaction = this.dataBroker.newWriteOnlyTransaction();
43 writeTransaction.merge(LogicalDatastoreType.CONFIGURATION, instanceIdentifier , objToSave);
44 writeTransaction.commit().get(Timeouts.DATASTORE_WRITE, TimeUnit.MILLISECONDS);
45 } catch (TimeoutException | InterruptedException | ExecutionException e) {
46 LOG.warn("Warning addOpenroadmOperationalModesToCatalog CatalogDataStoreOperationsImpl");
51 * Store SpecificOperationalModes object in the config data store.
54 public void addSpecificOperationalModesToCatalog(SpecificOperationalModes objToSave) {
55 LOG.info("Inside addSpecificOperationalModesToCatalog method of CatalogDataStoreOperationsImpl");
57 InstanceIdentifier<SpecificOperationalModes> instanceIdentifier = InstanceIdentifier
58 .create(OperationalModeCatalog.class).child(SpecificOperationalModes.class);
59 WriteTransaction writeTransaction = this.dataBroker.newWriteOnlyTransaction();
60 writeTransaction.merge(LogicalDatastoreType.CONFIGURATION, instanceIdentifier , objToSave);
61 writeTransaction.commit().get(Timeouts.DATASTORE_WRITE, TimeUnit.MILLISECONDS);
62 } catch (TimeoutException | InterruptedException | ExecutionException e) {
63 LOG.warn("Warning addSpecificOperationalModesToCatalog CatalogDataStoreOperationsImpl");