opendaylight/config/netty-timer-config/src/test/org/opendaylight/controller/config/yang/netty/timer/HashedWheelTimerModuleTest.java

   1 package org.opendaylight.controller.config.yang.netty.timer;
   2
   3 import javax.management.InstanceAlreadyExistsException;
   4 import javax.management.InstanceNotFoundException;
   5 import javax.management.ObjectName;
   6
   7 import junit.framework.Assert;
   8
   9 import org.junit.Before;
  10 import org.junit.Test;
  11 import org.opendaylight.controller.config.api.ConflictingVersionException;
  12 import org.opendaylight.controller.config.api.ValidationException;
  13 import org.opendaylight.controller.config.api.jmx.CommitStatus;
  14 import org.opendaylight.controller.config.manager.impl.AbstractConfigTest;
  15 import org.opendaylight.controller.config.manager.impl.factoriesresolver.HardcodedModuleFactoriesResolver;
  16 import org.opendaylight.controller.config.util.ConfigTransactionJMXClient;
  17 import org.opendaylight.controller.config.yang.threadpool.impl.NamingThreadFactoryModuleFactory;
  18 import org.opendaylight.controller.config.yang.threadpool.impl.NamingThreadFactoryModuleMXBean;
  19
  20 public class HashedWheelTimerModuleTest extends AbstractConfigTest {
  21
  22     private HashedWheelTimerModuleFactory factory;
  23     private NamingThreadFactoryModuleFactory threadFactory;
  24     private final String instanceName = "hashed-wheel-timer1";
  25
  26     @Before
  27     public void setUp() {
  28         factory = new HashedWheelTimerModuleFactory();
  29         threadFactory = new NamingThreadFactoryModuleFactory();
  30         super.initConfigTransactionManagerImpl(new HardcodedModuleFactoriesResolver(factory, threadFactory));
  31     }
  32
  33     public void testValidationExceptionTickDuration() throws InstanceAlreadyExistsException {
  34         ConfigTransactionJMXClient transaction = configRegistryClient.createTransaction();
  35         try {
  36             createInstance(transaction, instanceName, 0L, 10, true);
  37             transaction.validateConfig();
  38             Assert.fail();
  39         } catch (ValidationException e) {
  40             Assert.assertTrue(e.getMessage().contains("TickDuration value must be greater than 0"));
  41         }
  42     }
  43
  44     public void testValidationExceptionTicksPerWheel() throws InstanceAlreadyExistsException {
  45         ConfigTransactionJMXClient transaction = configRegistryClient.createTransaction();
  46         try {
  47             createInstance(transaction, instanceName, 500L, 0, true);
  48             transaction.validateConfig();
  49             Assert.fail();
  50         } catch (ValidationException e) {
  51             Assert.assertTrue(e.getMessage().contains("TicksPerWheel value must be greater than 0"));
  52         }
  53     }
  54
  55     @Test
  56     public void testCreateBean() throws InstanceAlreadyExistsException, ValidationException,
  57             ConflictingVersionException {
  58         ConfigTransactionJMXClient transaction = configRegistryClient.createTransaction();
  59
  60         createInstance(transaction, instanceName, 500L, 10, true);
  61         createInstance(transaction, instanceName + 1, null, null, false);
  62         createInstance(transaction, instanceName + 2, 500L, 10, false);
  63         createInstance(transaction, instanceName + 3, 500L, null, false);
  64         transaction.validateConfig();
  65         CommitStatus status = transaction.commit();
  66
  67         assertBeanCount(4, factory.getImplementationName());
  68         assertStatus(status, 5, 0, 0);
  69     }
  70
  71     @Test
  72     public void testReusingOldInstance() throws InstanceAlreadyExistsException, ConflictingVersionException,
  73             ValidationException {
  74
  75         ConfigTransactionJMXClient transaction = configRegistryClient.createTransaction();
  76         createInstance(transaction, instanceName, 500L, 10, true);
  77
  78         transaction.commit();
  79
  80         transaction = configRegistryClient.createTransaction();
  81         assertBeanCount(1, factory.getImplementationName());
  82         CommitStatus status = transaction.commit();
  83
  84         assertBeanCount(1, factory.getImplementationName());
  85         assertStatus(status, 0, 0, 2);
  86     }
  87
  88     @Test
  89     public void testReconfigure() throws InstanceAlreadyExistsException, ConflictingVersionException,
  90             ValidationException, InstanceNotFoundException {
  91
  92         ConfigTransactionJMXClient transaction = configRegistryClient.createTransaction();
  93         createInstance(transaction, instanceName, 500L, 10, true);
  94         transaction.commit();
  95
  96         transaction = configRegistryClient.createTransaction();
  97         assertBeanCount(1, factory.getImplementationName());
  98         HashedWheelTimerModuleMXBean mxBean = transaction.newMBeanProxy(
  99                 transaction.lookupConfigBean(factory.getImplementationName(), instanceName),
 100                 HashedWheelTimerModuleMXBean.class);
 101         mxBean.setTicksPerWheel(20);
 102         CommitStatus status = transaction.commit();
 103
 104         assertBeanCount(1, factory.getImplementationName());
 105         assertStatus(status, 0, 1, 1);
 106     }
 107
 108     private ObjectName createInstance(ConfigTransactionJMXClient transaction, String instanceName,
 109             final Long tickDuration, final Integer ticksPerWheel, final boolean hasThreadfactory)
 110             throws InstanceAlreadyExistsException {
 111         ObjectName nameCreated = transaction.createModule(factory.getImplementationName(), instanceName);
 112         HashedWheelTimerModuleMXBean mxBean = transaction
 113                 .newMBeanProxy(nameCreated, HashedWheelTimerModuleMXBean.class);
 114         mxBean.setTickDuration(tickDuration);
 115         mxBean.setTicksPerWheel(ticksPerWheel);
 116         if (hasThreadfactory) {
 117             mxBean.setThreadFactory(createThreadfactoryInstance(transaction, "thread-factory1", "th"));
 118         }
 119         return nameCreated;
 120     }
 121
 122     private ObjectName createThreadfactoryInstance(ConfigTransactionJMXClient transaction, String instanceName,
 123             final String namePrefix) throws InstanceAlreadyExistsException {
 124         ObjectName nameCreated = transaction.createModule(threadFactory.getImplementationName(), instanceName);
 125         NamingThreadFactoryModuleMXBean mxBean = transaction.newMBeanProxy(nameCreated,
 126                 NamingThreadFactoryModuleMXBean.class);
 127         mxBean.setNamePrefix(namePrefix);
 128         return nameCreated;
 129     }
 130
 131 }