X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?p=controller.git;a=blobdiff_plain;f=opendaylight%2Fmd-sal%2Fsal-common-impl%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fmd%2Fsal%2Fcommon%2Fimpl%2Frouting%2FAbstractDataReadRouter.java;fp=opendaylight%2Fmd-sal%2Fsal-common-impl%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fmd%2Fsal%2Fcommon%2Fimpl%2Frouting%2FAbstractDataReadRouter.java;h=0000000000000000000000000000000000000000;hp=fea06bb2a12fd32a5bd5fe579971392a6c6947bd;hb=72ec925228c924330ecbc568c652b9e56630b37f;hpb=6df346bc479589f850a371f9c5932e53dbfff48a

diff --git a/opendaylight/md-sal/sal-common-impl/src/main/java/org/opendaylight/controller/md/sal/common/impl/routing/AbstractDataReadRouter.java b/opendaylight/md-sal/sal-common-impl/src/main/java/org/opendaylight/controller/md/sal/common/impl/routing/AbstractDataReadRouter.java
deleted file mode 100644
index fea06bb2a1..0000000000
--- a/opendaylight/md-sal/sal-common-impl/src/main/java/org/opendaylight/controller/md/sal/common/impl/routing/AbstractDataReadRouter.java
+++ /dev/null
@@ -1,198 +0,0 @@
-/*
- * Copyright (c) 2014 Cisco Systems, Inc. and others.  All rights reserved.
- *
- * This program and the accompanying materials are made available under the
- * terms of the Eclipse Public License v1.0 which accompanies this distribution,
- * and is available at http://www.eclipse.org/legal/epl-v10.html
- */
-package org.opendaylight.controller.md.sal.common.impl.routing;
-
-import java.util.Map.Entry;
-
-import org.opendaylight.controller.md.sal.common.api.data.DataReader;
-import org.opendaylight.yangtools.concepts.AbstractObjectRegistration;
-import org.opendaylight.yangtools.concepts.Path;
-import org.opendaylight.yangtools.concepts.Registration;
-
-import com.google.common.base.Function;
-import com.google.common.base.Predicate;
-import com.google.common.collect.FluentIterable;
-import com.google.common.collect.HashMultimap;
-import com.google.common.collect.Multimap;
-import com.google.common.collect.Multimaps;
-
-/**
- * Base abstract implementation of DataReadRouter, which performs
- * a read operation on multiple data readers and then merges result.
- *
- * @param <P>
- * @param <D>
- */
-@Deprecated
-public abstract class AbstractDataReadRouter<P extends Path<P>, D> implements DataReader<P, D> {
-
-    Multimap<P, DataReaderRegistration<P, D>> configReaders = Multimaps.synchronizedSetMultimap(HashMultimap.<P, DataReaderRegistration<P, D>>create());
-    Multimap<P, DataReaderRegistration<P, D>> operationalReaders = Multimaps.synchronizedSetMultimap(HashMultimap.<P, DataReaderRegistration<P, D>>create());
-
-    @Override
-    public D readConfigurationData(P path) {
-        FluentIterable<D> dataBits = FluentIterable //
-                .from(getReaders(configReaders, path)).transform(configurationRead(path));
-        return merge(path,dataBits);
-    }
-
-    @Override
-    public D readOperationalData(P path) {
-        FluentIterable<D> dataBits = FluentIterable //
-                .from(getReaders(operationalReaders, path)).transform(operationalRead(path));
-        return merge(path,dataBits);
-
-    }
-
-    /**
-     * Merges data readed by reader instances from specified path
-     *
-     * @param path Path on which read was performed
-     * @param data Data which was returned by read operation.
-     * @return Merged result.
-     */
-    protected abstract D merge(P path,Iterable<D> data);
-
-    /**
-     * Returns a function which performs configuration read for supplied path
-     *
-     * @param path
-     * @return function which performs configuration read for supplied path
-     */
-
-    private Function<DataReader<P, D>, D> configurationRead(final P path) {
-        return new Function<DataReader<P, D>, D>() {
-            @Override
-            public D apply(DataReader<P, D> input) {
-                return input.readConfigurationData(path);
-            }
-        };
-    }
-
-    /**
-     * Returns a function which performs operational read for supplied path
-     *
-     * @param path
-     * @return function which performs operational read for supplied path
-     */
-    private Function<DataReader<P, D>, D> operationalRead(final P path) {
-        return new Function<DataReader<P, D>, D>() {
-            @Override
-            public D apply(DataReader<P, D> input) {
-                return input.readOperationalData(path);
-            }
-        };
-    }
-
-    // Registrations
-
-    /**
-     * Register's a reader for operational data.
-     *
-     * @param path Path which is served by this reader
-     * @param reader Reader instance which is responsible for reading particular subpath.
-     * @return
-     */
-    public Registration registerOperationalReader(P path, DataReader<P, D> reader) {
-        OperationalDataReaderRegistration<P, D> ret = new OperationalDataReaderRegistration<>(path, reader);
-        operationalReaders.put(path, ret);
-        return ret;
-    }
-
-    public Registration registerConfigurationReader(P path, DataReader<P, D> reader) {
-        ConfigurationDataReaderRegistration<P, D> ret = new ConfigurationDataReaderRegistration<>(path, reader);
-        configReaders.put(path, ret);
-        return ret;
-    }
-
-    Iterable<DataReader<P, D>> getOperationalReaders(P path) {
-        return getReaders(operationalReaders, path);
-    }
-
-    Iterable<DataReader<P, D>> getConfigurationReaders(P path) {
-        return getReaders(configReaders, path);
-    }
-
-    private Iterable<DataReader<P, D>> getReaders(Multimap<P, DataReaderRegistration<P, D>> readerMap, P path) {
-        return FluentIterable
-            .from(readerMap.entries()) //
-            .filter(affects(path)) //
-            .transform(retrieveInstance());
-    }
-
-    private void removeRegistration(OperationalDataReaderRegistration<?, ?> registration) {
-        operationalReaders.remove(registration.getKey(), registration);
-    }
-
-    private void removeRegistration(ConfigurationDataReaderRegistration<?, ?> registration) {
-        configReaders.remove(registration.getKey(), registration);
-    }
-
-    private Function<? super Entry<P, DataReaderRegistration<P, D>>, DataReader<P, D>> retrieveInstance() {
-        return new Function<Entry<P, DataReaderRegistration<P, D>>, DataReader<P,D>>() {
-            @Override
-            public DataReader<P, D> apply(Entry<P, DataReaderRegistration<P, D>> input) {
-                return input.getValue().getInstance();
-            }
-        };
-    }
-
-    private Predicate<? super Entry<P, DataReaderRegistration<P, D>>> affects(final P path) {
-
-        return new Predicate<Entry<P, DataReaderRegistration<P, D>>>() {
-
-            @Override
-            public boolean apply(Entry<P, DataReaderRegistration<P, D>> input) {
-                final P key = input.getKey();
-                return key.contains(path) || ((P) path).contains(key);
-            }
-
-        };
-    }
-
-    @SuppressWarnings("hiding")
-    private class ConfigurationDataReaderRegistration<P extends Path<P>, D> extends DataReaderRegistration<P, D> {
-
-        public ConfigurationDataReaderRegistration(P key, DataReader<P, D> instance) {
-            super(key, instance);
-        }
-
-        @Override
-        protected void removeRegistration() {
-            AbstractDataReadRouter.this.removeRegistration(this);
-        }
-    }
-
-    @SuppressWarnings("hiding")
-    private class OperationalDataReaderRegistration<P extends Path<P>, D> extends DataReaderRegistration<P, D> {
-
-        public OperationalDataReaderRegistration(P key, DataReader<P, D> instance) {
-            super(key, instance);
-        }
-
-        @Override
-        protected void removeRegistration() {
-            AbstractDataReadRouter.this.removeRegistration(this);
-        }
-    }
-
-    private abstract static class DataReaderRegistration<P extends Path<P>, D> extends
-            AbstractObjectRegistration<DataReader<P, D>> {
-
-        private final P key;
-
-        public P getKey() {
-            return this.key;
-        }
-
-        public DataReaderRegistration(P key, DataReader<P, D> instance) {
-            super(instance);
-            this.key = key;
-        }
-    }
-}