Split up BindingRuntimeContext
[mdsal.git] / binding / mdsal-binding-dom-codec-osgi / src / main / java / org / opendaylight / mdsal / binding / dom / codec / osgi / impl / SimpleBindingRuntimeContextService.java
1 /*
2  * Copyright (c) 2017 Pantheon Technologies, s.r.o. and others.  All rights reserved.
3  *
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
7  */
8 package org.opendaylight.mdsal.binding.dom.codec.osgi.impl;
9
10 import static com.google.common.base.Preconditions.checkState;
11 import static java.util.Objects.requireNonNull;
12
13 import com.google.common.util.concurrent.ListenableFuture;
14 import org.checkerframework.checker.lock.qual.GuardedBy;
15 import org.opendaylight.binding.runtime.api.BindingRuntimeContext;
16 import org.opendaylight.binding.runtime.api.ClassLoadingStrategy;
17 import org.opendaylight.binding.runtime.api.DefaultBindingRuntimeContext;
18 import org.opendaylight.mdsal.binding.dom.codec.osgi.BindingRuntimeContextListener;
19 import org.opendaylight.mdsal.binding.dom.codec.osgi.BindingRuntimeContextService;
20 import org.opendaylight.mdsal.binding.generator.impl.DefaultBindingRuntimeGenerator;
21 import org.opendaylight.yangtools.yang.model.api.SchemaContext;
22 import org.opendaylight.yangtools.yang.model.repo.api.SourceIdentifier;
23 import org.opendaylight.yangtools.yang.model.repo.api.YangTextSchemaSource;
24 import org.opendaylight.yangtools.yang.model.repo.spi.SchemaSourceProvider;
25 import org.osgi.framework.BundleContext;
26 import org.osgi.framework.ServiceReference;
27 import org.osgi.util.tracker.ServiceTracker;
28
29 @Deprecated
30 final class SimpleBindingRuntimeContextService extends
31         ServiceTracker<BindingRuntimeContextListener, BindingRuntimeContextListener>
32         implements BindingRuntimeContextService {
33     private final SchemaSourceProvider<YangTextSchemaSource> sourceProvider;
34     private final ClassLoadingStrategy strategy;
35     private final Object lock = new Object();
36
37     @GuardedBy("lock")
38     private BindingRuntimeContext current;
39
40     SimpleBindingRuntimeContextService(final BundleContext context, final ClassLoadingStrategy strategy,
41         final SchemaSourceProvider<YangTextSchemaSource> sourceProvider) {
42         super(context, BindingRuntimeContextListener.class, null);
43         this.sourceProvider = requireNonNull(sourceProvider);
44         this.strategy = requireNonNull(strategy);
45     }
46
47     @Override
48     public ListenableFuture<? extends YangTextSchemaSource> getSource(final SourceIdentifier sourceIdentifier) {
49         return sourceProvider.getSource(sourceIdentifier);
50     }
51
52     @Override
53     public BindingRuntimeContext getBindingRuntimeContext() {
54         synchronized (lock) {
55             checkState(current != null, "Runtime context is not initialized yet");
56             return current;
57         }
58     }
59
60     void updateBindingRuntimeContext(final SchemaContext schemaContext) {
61         final BindingRuntimeContext next = DefaultBindingRuntimeContext.create(
62             new DefaultBindingRuntimeGenerator().generateTypeMapping(schemaContext), strategy);
63
64         final BindingRuntimeContextListener[] listeners;
65         synchronized (lock) {
66             current = next;
67             listeners = this.getServices(new BindingRuntimeContextListener[0]);
68         }
69
70         for (BindingRuntimeContextListener l : listeners) {
71             l.onBindingRuntimeContextUpdated(next);
72         }
73     }
74
75     @Override
76     public BindingRuntimeContextListener addingService(
77             final ServiceReference<BindingRuntimeContextListener> reference) {
78         final BindingRuntimeContextListener listener = super.addingService(reference);
79
80         synchronized (lock) {
81             listener.onBindingRuntimeContextUpdated(current);
82         }
83
84         return listener;
85     }
86 }