opendaylight/config/config-manager/src/test/java/org/opendaylight/controller/config/manager/impl/osgi/BlankTransactionServiceTrackerTest.java

   1 package org.opendaylight.controller.config.manager.impl.osgi;
   2
   3 import static org.junit.Assert.assertNotNull;
   4 import static org.junit.Assert.assertSame;
   5 import static org.junit.Assert.fail;
   6 import static org.mockito.Mockito.doReturn;
   7 import static org.mockito.Mockito.doThrow;
   8 import static org.mockito.Mockito.mock;
   9 import static org.mockito.Mockito.times;
  10 import static org.mockito.Mockito.verify;
  11 import java.util.Collections;
  12 import javax.management.ObjectName;
  13 import org.junit.Before;
  14 import org.junit.Test;
  15 import org.mockito.Mock;
  16 import org.mockito.MockitoAnnotations;
  17 import org.opendaylight.controller.config.api.ConflictingVersionException;
  18 import org.opendaylight.controller.config.api.ModuleIdentifier;
  19 import org.opendaylight.controller.config.api.ValidationException;
  20 import org.opendaylight.controller.config.api.jmx.CommitStatus;
  21 import org.opendaylight.controller.config.spi.ModuleFactory;
  22 import org.osgi.framework.ServiceReference;
  23
  24 public class BlankTransactionServiceTrackerTest {
  25
  26     @Mock
  27     private BlankTransactionServiceTracker.BlankTransaction blankTx;
  28     private BlankTransactionServiceTracker tracker;
  29
  30     @Before
  31     public void setUp() throws Exception {
  32         MockitoAnnotations.initMocks(this);
  33         doReturn(new CommitStatus(Collections.<ObjectName>emptyList(), Collections.<ObjectName>emptyList(), Collections.<ObjectName>emptyList())).when(blankTx).hit();
  34         tracker = new BlankTransactionServiceTracker(blankTx);
  35     }
  36
  37     @Test
  38     public void testBlankTransaction() throws Exception {
  39         tracker.addingService(getMockServiceReference());
  40         tracker.modifiedService(getMockServiceReference(), null);
  41         tracker.removedService(getMockServiceReference(), null);
  42         verify(blankTx, times(3)).hit();
  43     }
  44
  45     @Test
  46     public void testValidationException() throws Exception {
  47         IllegalArgumentException argumentException = new IllegalArgumentException();
  48         ValidationException validationException = ValidationException.createForSingleException(new ModuleIdentifier("m", "i"), argumentException);
  49         doThrow(validationException).when(blankTx).hit();
  50         try {
  51             tracker.addingService(getMockServiceReference());
  52         } catch (Exception e) {
  53             verify(blankTx, times(1)).hit();
  54             assertNotNull(e.getCause());
  55             assertSame(validationException, e.getCause());
  56             return;
  57         }
  58
  59         fail("Exception should have occurred for validation exception");
  60     }
  61
  62     @Test
  63     public void testConflictingException() throws Exception {
  64         int maxAttempts = 2;
  65         tracker = new BlankTransactionServiceTracker(blankTx, maxAttempts);
  66
  67         final ConflictingVersionException ex = new ConflictingVersionException();
  68         doThrow(ex).when(blankTx).hit();
  69         try {
  70             tracker.addingService(getMockServiceReference());
  71         } catch (Exception e) {
  72             verify(blankTx, times(maxAttempts)).hit();
  73             return;
  74         }
  75
  76         fail("Exception should have occurred for conflicting exception");
  77     }
  78
  79     private ServiceReference<ModuleFactory> getMockServiceReference() {
  80         return mock(ServiceReference.class);
  81     }
  82 }