1 package org.opendaylight.controller.config.threadpool.flexible;
\r
3 import org.junit.Before;
\r
4 import org.junit.Test;
\r
5 import org.opendaylight.controller.config.api.ConflictingVersionException;
\r
6 import org.opendaylight.controller.config.api.ValidationException;
\r
7 import org.opendaylight.controller.config.api.jmx.CommitStatus;
\r
8 import org.opendaylight.controller.config.manager.impl.AbstractConfigTest;
\r
9 import org.opendaylight.controller.config.manager.impl.factoriesresolver.HardcodedModuleFactoriesResolver;
\r
10 import org.opendaylight.controller.config.util.ConfigTransactionJMXClient;
\r
11 import org.opendaylight.controller.config.yang.threadpool.impl.NamingThreadFactoryModuleFactory;
\r
12 import org.opendaylight.controller.config.yang.threadpool.impl.NamingThreadFactoryModuleMXBean;
\r
13 import org.opendaylight.controller.config.yang.threadpool.impl.flexible.FlexibleThreadPoolModuleFactory;
\r
14 import org.opendaylight.controller.config.yang.threadpool.impl.flexible.FlexibleThreadPoolModuleMXBean;
\r
16 import javax.management.InstanceAlreadyExistsException;
\r
17 import javax.management.InstanceNotFoundException;
\r
18 import javax.management.ObjectName;
\r
20 import static org.junit.Assert.assertThat;
\r
21 import static org.junit.Assert.fail;
\r
22 import static org.junit.matchers.JUnitMatchers.containsString;
\r
24 public class FlexibleThreadPoolConfigBeanTest extends AbstractConfigTest {
\r
26 private FlexibleThreadPoolModuleFactory flexibleFactory;
\r
27 private final String instanceName = "flexible1";
\r
28 private final String threadFactoryName = "threadFactoryName";
\r
31 public void setUp() {
\r
33 flexibleFactory = new FlexibleThreadPoolModuleFactory();
\r
34 super.initConfigTransactionManagerImpl(new HardcodedModuleFactoriesResolver(flexibleFactory,
\r
35 new NamingThreadFactoryModuleFactory()));
\r
39 public void testCreateBean() throws InstanceAlreadyExistsException, ValidationException,
\r
40 ConflictingVersionException {
\r
41 ConfigTransactionJMXClient transaction = configRegistryClient.createTransaction();
\r
43 createFlexible(transaction, instanceName, threadFactoryName, 1, 20, 20);
\r
44 transaction.validateConfig();
\r
45 CommitStatus status = transaction.commit();
\r
47 assertBeanCount(1, flexibleFactory.getImplementationName());
\r
48 assertStatus(status, 2, 0, 0);
\r
52 public void testReusingOldInstance() throws InstanceAlreadyExistsException, ConflictingVersionException,
\r
53 ValidationException {
\r
55 ConfigTransactionJMXClient transaction = configRegistryClient.createTransaction();
\r
56 createFlexible(transaction, instanceName, threadFactoryName, 1, 20, 10);
\r
58 transaction.commit();
\r
60 assertBeanCount(1, flexibleFactory.getImplementationName());
\r
62 transaction = configRegistryClient.createTransaction();
\r
63 CommitStatus status = transaction.commit();
\r
65 assertBeanCount(1, flexibleFactory.getImplementationName());
\r
66 assertStatus(status, 0, 0, 2);
\r
71 public void testInstanceAlreadyExistsException() throws ConflictingVersionException, ValidationException {
\r
72 ConfigTransactionJMXClient transaction = configRegistryClient.createTransaction();
\r
75 createFlexible(transaction, instanceName, threadFactoryName, 1, 1, 2);
\r
76 transaction.commit();
\r
77 } catch (InstanceAlreadyExistsException e1) {
\r
81 transaction = configRegistryClient.createTransaction();
\r
83 createFlexible(transaction, instanceName, "threadFactoryName1", 2, 2, 2);
\r
85 } catch (InstanceAlreadyExistsException e) {
\r
88 containsString("There is an instance registered with name ModuleIdentifier{factoryName='threadpool-flexible', instanceName='flexible1'}"));
\r
93 public void testValidationException() throws InstanceAlreadyExistsException {
\r
94 ConfigTransactionJMXClient transaction = configRegistryClient.createTransaction();
\r
96 createFlexible(transaction, instanceName, threadFactoryName, 0, 10, 10);
\r
99 transaction.validateConfig();
\r
101 } catch (ValidationException e) {
\r
102 assertThat(e.getMessage(), containsString("MinThreadCount must be greater than zero"));
\r
107 public void testValidationException2() throws InstanceAlreadyExistsException {
\r
108 ConfigTransactionJMXClient transaction = configRegistryClient.createTransaction();
\r
110 createFlexible(transaction, instanceName, threadFactoryName, 0, 0, 10);
\r
113 transaction.validateConfig();
\r
115 } catch (ValidationException e) {
\r
116 assertThat(e.getMessage(), containsString("KeepAliveMillis must be greater than zero"));
\r
121 public void testValidationException3() throws InstanceAlreadyExistsException {
\r
122 ConfigTransactionJMXClient transaction = configRegistryClient.createTransaction();
\r
124 createFlexible(transaction, instanceName, threadFactoryName, 10, 50, 0);
\r
127 transaction.validateConfig();
\r
129 } catch (ValidationException e) {
\r
130 assertThat(e.getMessage(), containsString("MaxThreadCount must be greater than zero"));
\r
134 private ObjectName createFlexible(ConfigTransactionJMXClient transaction, String instanceName,
\r
135 String threadFactoryName, int minThreadCount, long keepAliveMillis, int maxThreadCount)
\r
136 throws InstanceAlreadyExistsException {
\r
138 ObjectName threadFactoryON = transaction.createModule(NamingThreadFactoryModuleFactory.NAME, threadFactoryName);
\r
139 NamingThreadFactoryModuleMXBean namingThreadFactoryModuleMXBean = transaction.newMXBeanProxy(threadFactoryON,
\r
140 NamingThreadFactoryModuleMXBean.class);
\r
141 namingThreadFactoryModuleMXBean.setNamePrefix("prefix");
\r
143 ObjectName flexibleON = transaction.createModule(flexibleFactory.getImplementationName(), instanceName);
\r
144 FlexibleThreadPoolModuleMXBean mxBean = transaction.newMBeanProxy(flexibleON,
\r
145 FlexibleThreadPoolModuleMXBean.class);
\r
146 mxBean.setKeepAliveMillis(keepAliveMillis);
\r
147 mxBean.setMaxThreadCount(maxThreadCount);
\r
148 mxBean.setMinThreadCount(minThreadCount);
\r
149 mxBean.setThreadFactory(threadFactoryON);
\r
154 public void testReconfigurationInstance() throws InstanceAlreadyExistsException, ValidationException,
\r
155 ConflictingVersionException, InstanceNotFoundException {
\r
156 ConfigTransactionJMXClient transaction = configRegistryClient.createTransaction();
\r
157 createFlexible(transaction, instanceName, threadFactoryName, 2, 2, 2);
\r
159 transaction.commit();
\r
161 transaction = configRegistryClient.createTransaction();
\r
162 ObjectName databaseNew = transaction.lookupConfigBean(flexibleFactory.getImplementationName(), instanceName);
\r
163 FlexibleThreadPoolModuleMXBean proxy = transaction.newMXBeanProxy(databaseNew,
\r
164 FlexibleThreadPoolModuleMXBean.class);
\r
165 proxy.setMaxThreadCount(99);
\r
167 CommitStatus status = transaction.commit();
\r
169 assertBeanCount(1, flexibleFactory.getImplementationName());
\r
170 assertStatus(status, 0, 1, 1);
\r