2 * Copyright (c) 2013 Cisco Systems, Inc. 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.controller.config.threadpool.flexible;
10 import static org.hamcrest.CoreMatchers.containsString;
11 import static org.junit.Assert.assertThat;
12 import static org.junit.Assert.fail;
14 import javax.management.InstanceAlreadyExistsException;
15 import javax.management.InstanceNotFoundException;
16 import javax.management.ObjectName;
17 import org.junit.Before;
18 import org.junit.Test;
19 import org.opendaylight.controller.config.api.ConflictingVersionException;
20 import org.opendaylight.controller.config.api.ValidationException;
21 import org.opendaylight.controller.config.api.jmx.CommitStatus;
22 import org.opendaylight.controller.config.manager.impl.AbstractConfigTest;
23 import org.opendaylight.controller.config.manager.impl.factoriesresolver.HardcodedModuleFactoriesResolver;
24 import org.opendaylight.controller.config.util.ConfigTransactionJMXClient;
25 import org.opendaylight.controller.config.yang.threadpool.impl.NamingThreadFactoryModuleFactory;
26 import org.opendaylight.controller.config.yang.threadpool.impl.NamingThreadFactoryModuleMXBean;
27 import org.opendaylight.controller.config.yang.threadpool.impl.flexible.FlexibleThreadPoolModuleFactory;
28 import org.opendaylight.controller.config.yang.threadpool.impl.flexible.FlexibleThreadPoolModuleMXBean;
30 public class FlexibleThreadPoolConfigBeanTest extends AbstractConfigTest {
32 private FlexibleThreadPoolModuleFactory flexibleFactory;
33 private final String instanceName = "flexible1";
34 private final String threadFactoryName = "threadFactoryName";
39 flexibleFactory = new FlexibleThreadPoolModuleFactory();
40 super.initConfigTransactionManagerImpl(new HardcodedModuleFactoriesResolver(mockedContext,flexibleFactory,
41 new NamingThreadFactoryModuleFactory()));
45 public void testCreateBean() throws InstanceAlreadyExistsException, ValidationException,
46 ConflictingVersionException {
47 ConfigTransactionJMXClient transaction = configRegistryClient.createTransaction();
49 createFlexible(transaction, instanceName, threadFactoryName, 1, 20, 20);
50 transaction.validateConfig();
51 CommitStatus status = transaction.commit();
53 assertBeanCount(1, flexibleFactory.getImplementationName());
54 assertStatus(status, 2, 0, 0);
58 public void testReusingOldInstance() throws InstanceAlreadyExistsException, ConflictingVersionException,
61 ConfigTransactionJMXClient transaction = configRegistryClient.createTransaction();
62 createFlexible(transaction, instanceName, threadFactoryName, 1, 20, 10);
66 assertBeanCount(1, flexibleFactory.getImplementationName());
68 transaction = configRegistryClient.createTransaction();
69 CommitStatus status = transaction.commit();
71 assertBeanCount(1, flexibleFactory.getImplementationName());
72 assertStatus(status, 0, 0, 2);
77 public void testInstanceAlreadyExistsException() throws ConflictingVersionException, ValidationException {
78 ConfigTransactionJMXClient transaction = configRegistryClient.createTransaction();
81 createFlexible(transaction, instanceName, threadFactoryName, 1, 1, 2);
83 } catch (InstanceAlreadyExistsException e1) {
87 transaction = configRegistryClient.createTransaction();
89 createFlexible(transaction, instanceName, "threadFactoryName1", 2, 2, 2);
91 } catch (InstanceAlreadyExistsException e) {
94 containsString("There is an instance registered with name ModuleIdentifier{factoryName='threadpool-flexible', instanceName='flexible1'}"));
99 public void testValidationException() throws InstanceAlreadyExistsException {
100 ConfigTransactionJMXClient transaction = configRegistryClient.createTransaction();
102 createFlexible(transaction, instanceName, threadFactoryName, 0, 10, 10);
105 transaction.validateConfig();
107 } catch (ValidationException e) {
108 assertThat(e.getMessage(), containsString("MinThreadCount must be greater than zero"));
113 public void testValidationException2() throws InstanceAlreadyExistsException {
114 ConfigTransactionJMXClient transaction = configRegistryClient.createTransaction();
116 createFlexible(transaction, instanceName, threadFactoryName, 0, 0, 10);
119 transaction.validateConfig();
121 } catch (ValidationException e) {
122 assertThat(e.getMessage(), containsString("KeepAliveMillis must be greater than zero"));
127 public void testValidationException3() throws InstanceAlreadyExistsException {
128 ConfigTransactionJMXClient transaction = configRegistryClient.createTransaction();
130 createFlexible(transaction, instanceName, threadFactoryName, 10, 50, 0);
133 transaction.validateConfig();
135 } catch (ValidationException e) {
136 assertThat(e.getMessage(), containsString("MaxThreadCount must be greater than zero"));
140 private ObjectName createFlexible(ConfigTransactionJMXClient transaction, String instanceName,
141 String threadFactoryName, int minThreadCount, long keepAliveMillis, int maxThreadCount)
142 throws InstanceAlreadyExistsException {
144 ObjectName threadFactoryON = transaction.createModule(NamingThreadFactoryModuleFactory.NAME, threadFactoryName);
145 NamingThreadFactoryModuleMXBean namingThreadFactoryModuleMXBean = transaction.newMXBeanProxy(threadFactoryON,
146 NamingThreadFactoryModuleMXBean.class);
147 namingThreadFactoryModuleMXBean.setNamePrefix("prefix");
149 ObjectName flexibleON = transaction.createModule(flexibleFactory.getImplementationName(), instanceName);
150 FlexibleThreadPoolModuleMXBean mxBean = transaction.newMBeanProxy(flexibleON,
151 FlexibleThreadPoolModuleMXBean.class);
152 mxBean.setKeepAliveMillis(keepAliveMillis);
153 mxBean.setMaxThreadCount(maxThreadCount);
154 mxBean.setMinThreadCount(minThreadCount);
155 mxBean.setThreadFactory(threadFactoryON);
160 public void testReconfigurationInstance() throws InstanceAlreadyExistsException, ValidationException,
161 ConflictingVersionException, InstanceNotFoundException {
162 ConfigTransactionJMXClient transaction = configRegistryClient.createTransaction();
163 createFlexible(transaction, instanceName, threadFactoryName, 2, 2, 2);
165 transaction.commit();
167 transaction = configRegistryClient.createTransaction();
168 ObjectName databaseNew = transaction.lookupConfigBean(flexibleFactory.getImplementationName(), instanceName);
169 FlexibleThreadPoolModuleMXBean proxy = transaction.newMXBeanProxy(databaseNew,
170 FlexibleThreadPoolModuleMXBean.class);
171 proxy.setMaxThreadCount(99);
173 CommitStatus status = transaction.commit();
175 assertBeanCount(1, flexibleFactory.getImplementationName());
176 assertStatus(status, 0, 1, 1);