2 * Copyright (c) 2015 Cisco Systems, 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
9 package org.opendaylight.controller.config.yang.netconf.mdsal.monitoring;
11 import com.google.common.base.Preconditions;
12 import com.google.common.util.concurrent.FutureCallback;
13 import com.google.common.util.concurrent.Futures;
14 import com.google.common.util.concurrent.MoreExecutors;
15 import java.util.Collection;
16 import java.util.function.Consumer;
17 import javax.annotation.Nullable;
18 import org.opendaylight.controller.md.sal.binding.api.DataBroker;
19 import org.opendaylight.controller.md.sal.binding.api.WriteTransaction;
20 import org.opendaylight.controller.md.sal.common.api.data.LogicalDatastoreType;
21 import org.opendaylight.netconf.api.monitoring.NetconfMonitoringService;
22 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.netconf.monitoring.rev101004.NetconfState;
23 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.netconf.monitoring.rev101004.netconf.state.Capabilities;
24 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.netconf.monitoring.rev101004.netconf.state.Schemas;
25 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.netconf.monitoring.rev101004.netconf.state.Sessions;
26 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.netconf.monitoring.rev101004.netconf.state.sessions.Session;
27 import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
28 import org.slf4j.Logger;
29 import org.slf4j.LoggerFactory;
32 * Writes netconf server state changes received from NetconfMonitoringService to netconf-state datastore subtree.
34 public final class MonitoringToMdsalWriter implements AutoCloseable, NetconfMonitoringService.CapabilitiesListener,
35 NetconfMonitoringService.SessionsListener {
37 private static final Logger LOG = LoggerFactory.getLogger(MonitoringToMdsalWriter.class);
39 private static final InstanceIdentifier<Capabilities> CAPABILITIES_INSTANCE_IDENTIFIER =
40 InstanceIdentifier.create(NetconfState.class).child(Capabilities.class);
41 private static final InstanceIdentifier<Schemas> SCHEMAS_INSTANCE_IDENTIFIER =
42 InstanceIdentifier.create(NetconfState.class).child(Schemas.class);
43 private static final InstanceIdentifier<Sessions> SESSIONS_INSTANCE_IDENTIFIER =
44 InstanceIdentifier.create(NetconfState.class).child(Sessions.class);
46 private final NetconfMonitoringService serverMonitoringDependency;
47 private final DataBroker dataBroker;
49 public MonitoringToMdsalWriter(final NetconfMonitoringService serverMonitoringDependency,
50 final DataBroker dataBroker) {
51 this.serverMonitoringDependency = serverMonitoringDependency;
52 this.dataBroker = dataBroker;
56 * Invoked using blueprint.
60 runTransaction((tx) -> tx.delete(LogicalDatastoreType.OPERATIONAL,
61 InstanceIdentifier.create(NetconfState.class)));
65 public void onSessionStarted(Session session) {
66 final InstanceIdentifier<Session> sessionPath =
67 SESSIONS_INSTANCE_IDENTIFIER.child(Session.class, session.getKey());
68 runTransaction((tx) -> tx.put(LogicalDatastoreType.OPERATIONAL, sessionPath, session));
72 public void onSessionEnded(Session session) {
73 final InstanceIdentifier<Session> sessionPath =
74 SESSIONS_INSTANCE_IDENTIFIER.child(Session.class, session.getKey());
75 runTransaction((tx) -> tx.delete(LogicalDatastoreType.OPERATIONAL, sessionPath));
79 public void onSessionsUpdated(Collection<Session> sessions) {
80 runTransaction((tx) -> updateSessions(tx, sessions));
84 public void onCapabilitiesChanged(Capabilities capabilities) {
85 runTransaction((tx) -> tx.put(LogicalDatastoreType.OPERATIONAL, CAPABILITIES_INSTANCE_IDENTIFIER,
90 public void onSchemasChanged(Schemas schemas) {
91 runTransaction((tx) -> tx.put(LogicalDatastoreType.OPERATIONAL, SCHEMAS_INSTANCE_IDENTIFIER, schemas));
95 * Invoked using blueprint.
98 serverMonitoringDependency.registerCapabilitiesListener(this);
99 serverMonitoringDependency.registerSessionsListener(this);
102 private void runTransaction(Consumer<WriteTransaction> txUser) {
103 Preconditions.checkState(dataBroker != null);
104 final WriteTransaction tx = dataBroker.newWriteOnlyTransaction();
106 Futures.addCallback(tx.submit(), new FutureCallback<Void>() {
108 public void onSuccess(@Nullable Void result) {
109 LOG.debug("Netconf state updated successfully");
113 public void onFailure(Throwable throwable) {
114 LOG.warn("Unable to update netconf state", throwable);
116 }, MoreExecutors.directExecutor());
119 private static void updateSessions(WriteTransaction tx, Collection<Session> sessions) {
120 for (Session session : sessions) {
121 final InstanceIdentifier<Session> sessionPath =
122 SESSIONS_INSTANCE_IDENTIFIER.child(Session.class, session.getKey());
123 tx.put(LogicalDatastoreType.OPERATIONAL, sessionPath, session);