*/
package org.opendaylight.protocol.bgp.openconfig.routing.policy.spi;
-import static org.opendaylight.bgpcep.config.loader.routing.policy.OpenconfigRoutingPolicyLoader.ROUTING_POLICY_IID;
+import static org.opendaylight.bgpcep.config.loader.routing.policy.OpenconfigRoutingConfigFileProcessor.ROUTING_POLICY_IID;
import java.util.List;
import java.util.concurrent.ExecutionException;
*/
package org.opendaylight.protocol.bgp.openconfig.routing.policy.statement;
-import static org.opendaylight.bgpcep.config.loader.routing.policy.OpenconfigRoutingPolicyLoader.ROUTING_POLICY_IID;
+import static org.opendaylight.bgpcep.config.loader.routing.policy.OpenconfigRoutingConfigFileProcessor.ROUTING_POLICY_IID;
import java.util.List;
import java.util.concurrent.ExecutionException;
import org.junit.Before;
import org.junit.Test;
-import org.opendaylight.bgpcep.config.loader.impl.AbstractConfigLoader;
+import org.opendaylight.bgpcep.config.loader.impl.AbstractConfigLoaderTest;
import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bmp.monitor.config.rev200120.OdlBmpMonitors;
import org.opendaylight.yangtools.yang.model.api.SchemaPath;
-public class BmpMonitorConfigFileProcessorTest extends AbstractConfigLoader {
+public class BmpMonitorConfigFileProcessorTest extends AbstractConfigLoaderTest {
@Override
@Before
import org.slf4j.LoggerFactory;
import org.xml.sax.SAXException;
-public final class ConfigLoaderImpl implements ConfigLoader, AutoCloseable {
- private static final Logger LOG = LoggerFactory.getLogger(ConfigLoaderImpl.class);
+public final class AbstractConfigLoader implements ConfigLoader, AutoCloseable {
+ private static final Logger LOG = LoggerFactory.getLogger(AbstractConfigLoader.class);
private static final String INTERRUPTED = "InterruptedException";
private static final String EXTENSION = "-.*\\.xml";
private static final String INITIAL = "^";
@GuardedBy("this")
private boolean closed = false;
- public ConfigLoaderImpl(final EffectiveModelContext schemaContext,
+ public AbstractConfigLoader(final EffectiveModelContext schemaContext,
final BindingNormalizedNodeSerializer bindingSerializer, final FileWatcher fileWatcher) {
this.schemaContext = requireNonNull(schemaContext);
this.bindingSerializer = requireNonNull(bindingSerializer);
return new AbstractRegistration() {
@Override
protected void removeRegistration() {
- synchronized (ConfigLoaderImpl.this) {
- ConfigLoaderImpl.this.configServices.remove(pattern);
+ synchronized (AbstractConfigLoader.this) {
+ AbstractConfigLoader.this.configServices.remove(pattern);
}
}
};
try {
key = this.watchService.take();
} catch (final InterruptedException | ClosedWatchServiceException e) {
- if (!ConfigLoaderImpl.this.closed) {
+ if (!AbstractConfigLoader.this.closed) {
LOG.warn(INTERRUPTED, e);
Thread.currentThread().interrupt();
}
}
private synchronized void handleEvent(final String filename) {
- ConfigLoaderImpl.this.configServices.entrySet().stream()
+ AbstractConfigLoader.this.configServices.entrySet().stream()
.filter(entry -> Pattern.matches(entry.getKey(), filename))
.forEach(entry -> handleConfigFile(entry.getValue(), filename));
}
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
-public final class FileWatcherImpl implements FileWatcher, AutoCloseable {
- private static final Logger LOG = LoggerFactory.getLogger(FileWatcherImpl.class);
+public final class DefaultFileWatcher implements FileWatcher, AutoCloseable {
+ private static final Logger LOG = LoggerFactory.getLogger(DefaultFileWatcher.class);
private static final String INTERRUPTED = "InterruptedException";
//BGPCEP config folder OS agnostic path
private static final Path PATH = Paths.get("etc","opendaylight","bgpcep");
private final WatchService watchService;
- public FileWatcherImpl() throws IOException {
+ public DefaultFileWatcher() throws IOException {
this.watchService = FileSystems.getDefault().newWatchService();
final File file = new File(PATH.toString());
if (!file.exists()) {
Runtime.getRuntime().addShutdownHook(new Thread(() -> {
try {
- FileWatcherImpl.this.watchService.close();
+ DefaultFileWatcher.this.watchService.close();
} catch (final IOException e) {
LOG.warn(INTERRUPTED, e);
}
<odl:static-reference id="mappingCodec"
interface="org.opendaylight.mdsal.binding.dom.codec.api.BindingNormalizedNodeSerializer"/>
- <bean id="filewatcher" class="org.opendaylight.bgpcep.config.loader.impl.FileWatcherImpl"
+ <bean id="filewatcher" class="org.opendaylight.bgpcep.config.loader.impl.DefaultFileWatcher"
destroy-method="close"/>
- <bean id="configLoader" class="org.opendaylight.bgpcep.config.loader.impl.ConfigLoaderImpl"
+ <bean id="configLoader" class="org.opendaylight.bgpcep.config.loader.impl.AbstractConfigLoader"
init-method="init"
destroy-method="close">
<argument>
</bean>
<service ref="configLoader" interface="org.opendaylight.bgpcep.config.loader.spi.ConfigLoader"/>
-</blueprint>
\ No newline at end of file
+</blueprint>
import org.opendaylight.mdsal.binding.dom.adapter.test.AbstractDataBrokerTestCustomizer;
import org.opendaylight.mdsal.dom.api.DOMSchemaService;
-public abstract class AbstractConfigLoader extends AbstractConcurrentDataBrokerTest {
+public abstract class AbstractConfigLoaderTest extends AbstractConcurrentDataBrokerTest {
@GuardedBy("this")
private final List<WatchEvent<?>> eventList = new CopyOnWriteArrayList<>();
- protected ConfigLoaderImpl configLoader;
+ protected AbstractConfigLoader configLoader;
@Mock
private WatchService watchService;
@Mock
protected AdapterContext mappingService;
protected DOMSchemaService schemaService;
- public AbstractConfigLoader() {
+ public AbstractConfigLoaderTest() {
super(true);
}
clearEvent();
return null;
}).when(this.processor).loadConfiguration(any());
- this.configLoader = new ConfigLoaderImpl(getSchemaContext(), this.mappingService.currentSerializer(),
+ this.configLoader = new AbstractConfigLoader(getSchemaContext(), this.mappingService.currentSerializer(),
this.fileWatcher);
this.configLoader.init();
}
import org.opendaylight.yangtools.concepts.AbstractRegistration;
import org.opendaylight.yangtools.yang.model.api.SchemaPath;
-public class ConfigLoaderImplTest extends AbstractConfigLoader {
+public class ConfigLoaderImplTest extends AbstractConfigLoaderTest {
@Override
@Before
public void setUp() throws Exception {
triggerEvent("protocols-config.xml");
verify(this.processor, timeout(20000).times(2)).loadConfiguration(any());
}
-}
\ No newline at end of file
+}
import java.io.File;
import org.junit.Test;
-public class FileWatcherTest {
+public class DefaultWatcherTest {
private static final String PATH = String.join(File.separator, "etc", "opendaylight", "bgpcep");
@Test
public void bgpFileWatcherTest() throws Exception {
- final FileWatcherImpl bgpFileWatcher = new FileWatcherImpl();
+ final DefaultFileWatcher bgpFileWatcher = new DefaultFileWatcher();
assertEquals(PATH, bgpFileWatcher.getPathFile());
assertNotNull(bgpFileWatcher.getWatchService());
bgpFileWatcher.close();
import static org.opendaylight.protocol.util.CheckUtil.checkPresentConfiguration;
import org.junit.Test;
-import org.opendaylight.bgpcep.config.loader.impl.AbstractConfigLoader;
+import org.opendaylight.bgpcep.config.loader.impl.AbstractConfigLoaderTest;
import org.opendaylight.yang.gen.v1.http.openconfig.net.yang.network.instance.rev151018.network.instance.top.NetworkInstances;
import org.opendaylight.yang.gen.v1.http.openconfig.net.yang.network.instance.rev151018.network.instance.top.network.instances.NetworkInstance;
import org.opendaylight.yang.gen.v1.http.openconfig.net.yang.network.instance.rev151018.network.instance.top.network.instances.network.instance.Protocols;
import org.opendaylight.yangtools.yang.model.api.SchemaPath;
-public class ProtocolsConfigFileProcessorTest extends AbstractConfigLoader {
+public class ProtocolsConfigFileProcessorTest extends AbstractConfigLoaderTest {
@Test
public void configFileTest() throws Exception {
checkNotPresentConfiguration(getDataBroker(), BGP_PROTOCOLS_IID);
processor.getSchemaPath());
processor.close();
}
-}
\ No newline at end of file
+}
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
-public final class OpenconfigRoutingPolicyLoader implements ConfigFileProcessor, AutoCloseable {
+public final class OpenconfigRoutingConfigFileProcessor implements ConfigFileProcessor, AutoCloseable {
public static final InstanceIdentifier<RoutingPolicy> ROUTING_POLICY_IID
= InstanceIdentifier.create(RoutingPolicy.class);
- private static final Logger LOG = LoggerFactory.getLogger(OpenconfigRoutingPolicyLoader.class);
+ private static final Logger LOG = LoggerFactory.getLogger(OpenconfigRoutingConfigFileProcessor.class);
private static final SchemaPath POLICY_SCHEMA_PATH = SchemaPath.create(true, RoutingPolicy.QNAME);
private final BindingNormalizedNodeSerializer bindingSerializer;
private final ConfigLoader configLoader;
@GuardedBy("this")
private AbstractRegistration registration;
- public OpenconfigRoutingPolicyLoader(final ConfigLoader configLoader, final DataBroker dataBroker) {
+ public OpenconfigRoutingConfigFileProcessor(final ConfigLoader configLoader, final DataBroker dataBroker) {
requireNonNull(configLoader);
this.configLoader = requireNonNull(configLoader);
this.dataBroker = requireNonNull(dataBroker);
<reference id="configLoader" interface="org.opendaylight.bgpcep.config.loader.spi.ConfigLoader"/>
<bean id="rpConfigFileProcessor"
- class="org.opendaylight.bgpcep.config.loader.routing.policy.OpenconfigRoutingPolicyLoader"
+ class="org.opendaylight.bgpcep.config.loader.routing.policy.OpenconfigRoutingConfigFileProcessor"
init-method="init"
destroy-method="close">
<argument ref="configLoader"/>
package org.opendaylight.bgpcep.config.loader.routing.policy;
import static org.junit.Assert.assertNotNull;
-import static org.opendaylight.bgpcep.config.loader.routing.policy.OpenconfigRoutingPolicyLoader.ROUTING_POLICY_IID;
+import static org.opendaylight.bgpcep.config.loader.routing.policy.OpenconfigRoutingConfigFileProcessor.ROUTING_POLICY_IID;
import static org.opendaylight.protocol.util.CheckUtil.checkNotPresentConfiguration;
import static org.opendaylight.protocol.util.CheckUtil.checkPresentConfiguration;
import org.junit.After;
import org.junit.Before;
-import org.opendaylight.bgpcep.config.loader.impl.AbstractConfigLoader;
+import org.opendaylight.bgpcep.config.loader.impl.AbstractConfigLoaderTest;
-public class AbstractOpenconfigRoutingPolicyLoaderTest extends AbstractConfigLoader {
- OpenconfigRoutingPolicyLoader policyLoader;
+public class AbstractOpenconfigRoutingPolicyLoaderTest extends AbstractConfigLoaderTest {
+ OpenconfigRoutingConfigFileProcessor policyLoader;
@Override
@Before
super.setUp();
checkNotPresentConfiguration(getDataBroker(), ROUTING_POLICY_IID);
assertNotNull(ClassLoader.getSystemClassLoader().getResource("initial/routing-policy-config.xml"));
- this.policyLoader = new OpenconfigRoutingPolicyLoader(this.configLoader, getDataBroker());
+ this.policyLoader = new OpenconfigRoutingConfigFileProcessor(this.configLoader, getDataBroker());
this.policyLoader.init();
checkPresentConfiguration(getDataBroker(), ROUTING_POLICY_IID);
this.policyLoader.close();
import java.util.concurrent.ExecutionException;
import org.junit.Test;
-import org.opendaylight.bgpcep.config.loader.impl.AbstractConfigLoader;
+import org.opendaylight.bgpcep.config.loader.impl.AbstractConfigLoaderTest;
import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.NetworkTopology;
import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.TopologyId;
import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.Topology;
import org.opendaylight.yangtools.yang.binding.KeyedInstanceIdentifier;
import org.opendaylight.yangtools.yang.model.api.SchemaPath;
-public class NetworkTopologyConfigFileProcessorTest extends AbstractConfigLoader {
+public class NetworkTopologyConfigFileProcessorTest extends AbstractConfigLoaderTest {
@Test
public void configFileTest() throws InterruptedException, ExecutionException {
final KeyedInstanceIdentifier<Topology, TopologyKey> topologyIIdKeyed =
assertEquals(SchemaPath.create(true, NetworkTopology.QNAME), processor.getSchemaPath());
processor.close();
}
-}
\ No newline at end of file
+}