2 * Copyright (c) 2017 Pantheon Technologies s.r.o. 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.mdsal.dom.broker.schema;
10 import com.google.common.annotations.VisibleForTesting;
11 import com.google.common.util.concurrent.ListenableFuture;
12 import java.io.IOException;
14 import java.util.ArrayList;
15 import java.util.List;
16 import java.util.Optional;
17 import org.checkerframework.checker.lock.qual.GuardedBy;
18 import org.opendaylight.mdsal.dom.spi.AbstractDOMSchemaService;
19 import org.opendaylight.yangtools.concepts.ListenerRegistration;
20 import org.opendaylight.yangtools.concepts.Registration;
21 import org.opendaylight.yangtools.util.ListenerRegistry;
22 import org.opendaylight.yangtools.yang.model.api.EffectiveModelContext;
23 import org.opendaylight.yangtools.yang.model.api.EffectiveModelContextListener;
24 import org.opendaylight.yangtools.yang.model.repo.api.SchemaSourceException;
25 import org.opendaylight.yangtools.yang.model.repo.api.SourceIdentifier;
26 import org.opendaylight.yangtools.yang.model.repo.api.YangTextSchemaSource;
27 import org.opendaylight.yangtools.yang.parser.api.YangSyntaxErrorException;
28 import org.opendaylight.yangtools.yang.parser.repo.YangTextSchemaContextResolver;
29 import org.slf4j.Logger;
30 import org.slf4j.LoggerFactory;
33 public class ScanningSchemaServiceProvider extends AbstractDOMSchemaService.WithYangTextSources
34 implements AutoCloseable {
35 private static final Logger LOG = LoggerFactory.getLogger(ScanningSchemaServiceProvider.class);
37 private final YangTextSchemaContextResolver contextResolver = YangTextSchemaContextResolver.create("global-bundle");
39 private final ListenerRegistry<EffectiveModelContextListener> listeners = ListenerRegistry.create();
40 private final Object lock = new Object();
42 public void tryToUpdateSchemaContext() {
44 final Optional<? extends EffectiveModelContext> optSchema = contextResolver.getEffectiveModelContext();
45 optSchema.ifPresent(schema -> {
46 if (LOG.isDebugEnabled()) {
47 LOG.debug("Got new SchemaContext: # of modules {}", schema.getModules().size());
49 notifyListeners(schema);
55 @SuppressWarnings("checkstyle:IllegalCatch")
56 public void notifyListeners(final EffectiveModelContext schemaContext) {
58 listeners.streamListeners().forEach(listener -> {
60 listener.onModelContextUpdated(schemaContext);
61 } catch (final Exception e) {
62 LOG.error("Exception occured during invoking listener {}", listener, e);
68 public List<Registration> registerAvailableYangs(final List<URL> yangs) {
69 final List<Registration> sourceRegistrator = new ArrayList<>();
70 for (final URL url : yangs) {
72 sourceRegistrator.add(contextResolver.registerSource(url));
73 } catch (SchemaSourceException | IOException | YangSyntaxErrorException e) {
74 LOG.warn("Failed to register {}, ignoring it", url, e);
77 return sourceRegistrator;
80 public boolean hasListeners() {
82 return !listeners.isEmpty();
87 public EffectiveModelContext getGlobalContext() {
88 return contextResolver.getEffectiveModelContext().orElse(null);
92 public ListenerRegistration<EffectiveModelContextListener> registerSchemaContextListener(
93 final EffectiveModelContextListener listener) {
95 contextResolver.getEffectiveModelContext().ifPresent(listener::onModelContextUpdated);
96 return listeners.register(listener);
101 public ListenableFuture<? extends YangTextSchemaSource> getSource(final SourceIdentifier sourceIdentifier) {
102 return contextResolver.getSource(sourceIdentifier);
106 public void close() {
107 synchronized (lock) {