+++ /dev/null
-/*
- * Copyright (c) 2013, 2017 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.config.manager.testingservices.parallelapsp;
-
-import static com.google.common.base.Preconditions.checkNotNull;
-import static com.google.common.base.Preconditions.checkState;
-
-import com.google.common.base.Strings;
-import java.io.Closeable;
-import javax.annotation.Nullable;
-import javax.annotation.concurrent.NotThreadSafe;
-import javax.management.AttributeNotFoundException;
-import javax.management.InstanceNotFoundException;
-import javax.management.MBeanException;
-import javax.management.ObjectName;
-import javax.management.ReflectionException;
-import org.opendaylight.controller.config.api.DependencyResolver;
-import org.opendaylight.controller.config.api.JmxAttribute;
-import org.opendaylight.controller.config.api.ModuleIdentifier;
-import org.opendaylight.controller.config.api.annotations.RequireInterface;
-import org.opendaylight.controller.config.manager.testingservices.seviceinterface.TestingThreadPoolServiceInterface;
-import org.opendaylight.controller.config.manager.testingservices.threadpool.TestingThreadPoolConfigMXBean;
-import org.opendaylight.controller.config.manager.testingservices.threadpool.TestingThreadPoolIfc;
-import org.opendaylight.controller.config.spi.Module;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-
-/**
- * Represents service that has dependency to thread pool.
- */
-@NotThreadSafe
-public class TestingParallelAPSPModule implements Module, TestingParallelAPSPConfigMXBean {
- private static final Logger LOG = LoggerFactory.getLogger(TestingParallelAPSPModule.class);
-
- private final DependencyResolver dependencyResolver;
- private final AutoCloseable oldCloseable;
- private final TestingParallelAPSPImpl oldInstance;
- private final ModuleIdentifier identifier;
- private ObjectName threadPoolON;
- private TestingParallelAPSPImpl instance;
- private String someParam;
-
- public TestingParallelAPSPModule(final ModuleIdentifier identifier, final DependencyResolver dependencyResolver,
- @Nullable final AutoCloseable oldCloseable, @Nullable final TestingParallelAPSPImpl oldInstance) {
- this.identifier = identifier;
- this.dependencyResolver = dependencyResolver;
- this.oldCloseable = oldCloseable;
- this.oldInstance = oldInstance;
- }
-
- @Override
- public ObjectName getThreadPool() {
- return threadPoolON;
- }
-
- @RequireInterface(TestingThreadPoolServiceInterface.class)
- @Override
- public void setThreadPool(final ObjectName threadPoolName) {
- this.threadPoolON = threadPoolName;
- }
-
- @Override
- public String getSomeParam() {
- return someParam;
- }
-
- @Override
- public void setSomeParam(final String someParam) {
- this.someParam = someParam;
- }
-
- @Override
- public Integer getMaxNumberOfThreads() {
- if (instance == null) {
- return null;
- }
- return instance.getMaxNumberOfThreads();
- }
-
- // this would be generated:
- private final JmxAttribute threadPoolOnJMXAttribute = new JmxAttribute("threadPoolON");
-
- @Override
- public void validate() {
- checkNotNull(threadPoolON, "Parameter 'threadPool' must be set");
- dependencyResolver.validateDependency(TestingThreadPoolServiceInterface.class, threadPoolON,
- threadPoolOnJMXAttribute);
-
- checkState(Strings.isNullOrEmpty(someParam) == false, "Parameter 'SomeParam' is blank");
- // check that calling resolveInstance fails
- try {
- dependencyResolver.resolveInstance(TestingThreadPoolIfc.class, threadPoolON, threadPoolOnJMXAttribute);
- throw new RuntimeException("fail");
- } catch (final IllegalStateException e) {
- checkState("Commit was not triggered".equals(e.getMessage()), e.getMessage());
- }
-
- // test retrieving dependent module's attribute
- int threadCount;
- try {
- threadCount = (Integer) dependencyResolver.getAttribute(threadPoolON, "ThreadCount");
- } catch (final ReflectionException | InstanceNotFoundException | AttributeNotFoundException
- | MBeanException e) {
- throw new IllegalStateException(e);
- }
- checkState(threadCount > 0);
- TestingThreadPoolConfigMXBean proxy = dependencyResolver.newMXBeanProxy(threadPoolON,
- TestingThreadPoolConfigMXBean.class);
- checkState(threadCount == proxy.getThreadCount());
- }
-
- @Override
- @SuppressWarnings("IllegalCatch")
- public Closeable getInstance() {
- if (instance == null) {
- TestingThreadPoolIfc threadPoolInstance = dependencyResolver.resolveInstance(TestingThreadPoolIfc.class,
- threadPoolON, threadPoolOnJMXAttribute);
-
- if (oldInstance != null) {
- // changing thread pool is not supported
- boolean reuse = threadPoolInstance == oldInstance.getThreadPool();
- if (reuse) {
- LOG.debug("Reusing old instance");
- instance = oldInstance;
- instance.setSomeParam(someParam);
- }
- }
- if (instance == null) {
- LOG.debug("Creating new instance");
- if (oldCloseable != null) {
- try {
- oldCloseable.close();
- } catch (final Exception e) {
- throw new RuntimeException(e);
- }
- }
- instance = new TestingParallelAPSPImpl(threadPoolInstance, someParam);
- }
- }
- return instance;
- }
-
- @Override
- public boolean canReuse(final Module oldModule) {
- return false;
- }
-
- @Override
- public ModuleIdentifier getIdentifier() {
- return identifier;
- }
-}
Code Review / controller.git / blobdiff