import static org.mockito.Mockito.doReturn;
import static org.mockito.Mockito.never;
import static org.mockito.Mockito.verify;
+
import com.google.common.util.concurrent.Futures;
import java.util.concurrent.ConcurrentHashMap;
import java.util.concurrent.ConcurrentMap;
import org.opendaylight.mdsal.singleton.common.api.ClusterSingletonService;
import org.opendaylight.mdsal.singleton.common.api.ClusterSingletonServiceRegistration;
import org.opendaylight.mdsal.singleton.common.api.ServiceGroupIdentifier;
-import org.opendaylight.mdsal.singleton.dom.impl.ClusterSingletonServiceGroup;
-import org.opendaylight.mdsal.singleton.dom.impl.ClusterSingletonServiceGroupImpl;
import org.opendaylight.mdsal.singleton.dom.impl.util.TestEntity;
import org.opendaylight.mdsal.singleton.dom.impl.util.TestInstanceIdentifier;
/**
- * Testing {@link ClusterSingletonServiceGroupImpl}
+ * Testing {@link ClusterSingletonServiceGroupImpl}.
*/
public class ClusterSingletonServiceGroupImplTest {
@Mock
private GenericEntityOwnershipCandidateRegistration<?, ?> mockCloseEntityCandReg;
@Mock
- private GenericEntityOwnershipListener<TestInstanceIdentifier,GenericEntityOwnershipChange<TestInstanceIdentifier, TestEntity>> mockEosListener;
+ private GenericEntityOwnershipListener<TestInstanceIdentifier,
+ GenericEntityOwnershipChange<TestInstanceIdentifier, TestEntity>> mockEosListener;
@Mock
- private GenericEntityOwnershipService<TestInstanceIdentifier,TestEntity, GenericEntityOwnershipListener<TestInstanceIdentifier,GenericEntityOwnershipChange<TestInstanceIdentifier, TestEntity>>> mockEosService;
-
- private ClusterSingletonServiceGroupImpl<TestInstanceIdentifier,TestEntity,GenericEntityOwnershipChange<TestInstanceIdentifier,TestEntity>,
- GenericEntityOwnershipListener<TestInstanceIdentifier, GenericEntityOwnershipChange<TestInstanceIdentifier, TestEntity>>,
- GenericEntityOwnershipService<TestInstanceIdentifier, TestEntity, GenericEntityOwnershipListener<TestInstanceIdentifier,
- GenericEntityOwnershipChange<TestInstanceIdentifier, TestEntity>>>> singletonServiceGroup;
+ private GenericEntityOwnershipService<TestInstanceIdentifier,TestEntity,
+ GenericEntityOwnershipListener<TestInstanceIdentifier,
+ GenericEntityOwnershipChange<TestInstanceIdentifier, TestEntity>>> mockEosService;
+
+ private ClusterSingletonServiceGroupImpl<TestInstanceIdentifier,TestEntity,
+ GenericEntityOwnershipChange<TestInstanceIdentifier,TestEntity>,
+ GenericEntityOwnershipListener<TestInstanceIdentifier,
+ GenericEntityOwnershipChange<TestInstanceIdentifier, TestEntity>>,
+ GenericEntityOwnershipService<TestInstanceIdentifier, TestEntity,
+ GenericEntityOwnershipListener<TestInstanceIdentifier,
+ GenericEntityOwnershipChange<TestInstanceIdentifier, TestEntity>>>> singletonServiceGroup;
private final TestEntity mainEntity = new TestEntity(SERVICE_ENTITY_TYPE, SERVICE_IDENTIFIER);
private final TestEntity closeEntity = new TestEntity(CLOSE_SERVICE_ENTITY_TYPE, SERVICE_IDENTIFIER);
private final ConcurrentMap<String, ClusterSingletonServiceGroup<?, ?, ?>> map = new ConcurrentHashMap<>();
/**
- * Initialization functionality for every Tests in this suite
+ * Initialization functionality for every Tests in this suite.
*
* @throws Exception - unexpected exception
*/
- @Before
- public void setup() throws Exception {
- MockitoAnnotations.initMocks(this);
+ @Before
+ public void setup() throws Exception {
+ MockitoAnnotations.initMocks(this);
- doReturn(mockEntityCandReg).when(mockEosService).registerCandidate(mainEntity);
- doReturn(mockCloseEntityCandReg).when(mockEosService).registerCandidate(closeEntity);
- doNothing().when(mockEntityCandReg).close();
- doNothing().when(mockCloseEntityCandReg).close();
- doNothing().when(mockClusterSingletonService).instantiateServiceInstance();
- doReturn(Futures.immediateFuture(null)).when(mockClusterSingletonService).closeServiceInstance();
+ doReturn(mockEntityCandReg).when(mockEosService).registerCandidate(mainEntity);
+ doReturn(mockCloseEntityCandReg).when(mockEosService).registerCandidate(closeEntity);
+ doNothing().when(mockEntityCandReg).close();
+ doNothing().when(mockCloseEntityCandReg).close();
+ doNothing().when(mockClusterSingletonService).instantiateServiceInstance();
+ doReturn(Futures.immediateFuture(null)).when(mockClusterSingletonService).closeServiceInstance();
doReturn(SERVICE_GROUP_IDENT).when(mockClusterSingletonService).getIdentifier();
doReturn(SERVICE_GROUP_IDENT).when(mockClusterSingletonServiceSecond).getIdentifier();
- singletonServiceGroup = new ClusterSingletonServiceGroupImpl(SERVICE_IDENTIFIER, mainEntity, closeEntity, mockEosService, map);
+ singletonServiceGroup = new ClusterSingletonServiceGroupImpl(
+ SERVICE_IDENTIFIER, mainEntity, closeEntity, mockEosService, map);
}
/**
- * Test NULL ServiceIdent input for new ServiceGroup instance
+ * Test NULL ServiceIdent input for new ServiceGroup instance.
*
* @throws Exception - unexpected exception
*/
@Test(expected = IllegalArgumentException.class)
public void instantiationClusterSingletonServiceGroupNullIdentTest() throws Exception {
- singletonServiceGroup = new ClusterSingletonServiceGroupImpl(null, mainEntity, closeEntity, mockEosService, map);
+ singletonServiceGroup = new ClusterSingletonServiceGroupImpl(
+ null, mainEntity, closeEntity, mockEosService, map);
}
/**
- * Test empty ServiceIdent input for new ServiceGroup instance
+ * Test empty ServiceIdent input for new ServiceGroup instance.
*
* @throws Exception - unexpected exception
*/
}
/**
- * Test NULL MainEntity input for new ServiceGroup instance
+ * Test NULL MainEntity input for new ServiceGroup instance.
*
* @throws Exception - unexpected exception
*/
@Test(expected = NullPointerException.class)
public void instantiationClusterSingletonServiceGroupNullMainEntityTest() throws Exception {
- singletonServiceGroup = new ClusterSingletonServiceGroupImpl(SERVICE_IDENTIFIER, null, closeEntity, mockEosService, map);
+ singletonServiceGroup = new ClusterSingletonServiceGroupImpl(
+ SERVICE_IDENTIFIER, null, closeEntity, mockEosService, map);
}
/**
- * Test NULL MainEntity input for new ServiceGroup instance
+ * Test NULL MainEntity input for new ServiceGroup instance.
*
* @throws Exception - unexpected exception
*/
@Test(expected = NullPointerException.class)
public void instantiationClusterSingletonServiceGroupNullCloseEntityTest() throws Exception {
- singletonServiceGroup = new ClusterSingletonServiceGroupImpl(SERVICE_IDENTIFIER, mainEntity, null, mockEosService, map);
+ singletonServiceGroup = new ClusterSingletonServiceGroupImpl(
+ SERVICE_IDENTIFIER, mainEntity, null, mockEosService, map);
}
/**
- * Test NULL MainEntity input for new ServiceGroup instance
+ * Test NULL MainEntity input for new ServiceGroup instance.
*
* @throws Exception - unexpected exception
*/
@Test(expected = NullPointerException.class)
public void instantiationClusterSingletonServiceGroupNullEOS_Test() throws Exception {
- singletonServiceGroup = new ClusterSingletonServiceGroupImpl(SERVICE_IDENTIFIER, mainEntity, closeEntity, null, map);
+ singletonServiceGroup = new ClusterSingletonServiceGroupImpl(
+ SERVICE_IDENTIFIER, mainEntity, closeEntity, null, map);
}
/**
- * Test NULL MainEntity input for new ServiceGroup instance
+ * Test NULL MainEntity input for new ServiceGroup instance.
*
* @throws Exception - unexpected exception
*/
@Test(expected = NullPointerException.class)
public void instantiationClusterSingletonServiceGroupNullMapRefTest() throws Exception {
- singletonServiceGroup = new ClusterSingletonServiceGroupImpl(SERVICE_IDENTIFIER, mainEntity, closeEntity, mockEosService, null);
+ singletonServiceGroup = new ClusterSingletonServiceGroupImpl(
+ SERVICE_IDENTIFIER, mainEntity, closeEntity, mockEosService, null);
}
/**
- * Test GoldPath for initialization ServiceGroup
+ * Test GoldPath for initialization ServiceGroup.
*
* @throws Exception - unexpected exception
*/
}
/**
- * Test GoldPath for NO-TO-SLAVE entity Candidate role change
+ * Test GoldPath for NO-TO-SLAVE entity Candidate role change.
*
* @throws Exception - unexpected exception
*/
}
/**
- * Test GoldPath for NO-TO-SLAVE but without MASTER entity Candidate role change
+ * Test GoldPath for NO-TO-SLAVE but without MASTER entity Candidate role change.
*
* @throws Exception - unexpected exception
*/
}
/**
- * Test GoldPath for InJeopardy entity Candidate role change
+ * Test GoldPath for InJeopardy entity Candidate role change.
*
* @throws Exception - unexpected exception
*/
}
/**
- * Test GoldPath for registration SingletonService
+ * Test GoldPath for registration SingletonService.
*
* @throws Exception - unexpected exception
*/
}
/**
- * Test GoldPath for registration SingletonService
+ * Test GoldPath for registration SingletonService.
*
* @throws Exception - unexpected exception
*/
/**
* Test GoldPath for unregistration SingletonService don't call closeServiceInstance
- * without mastership and don't remove ServiceGroup from map
+ * without mastership and don't remove ServiceGroup from map.
*
* @throws Exception - unexpected exception
*/
/**
* Test GoldPath for unregistration SingletonService don't call closeServiceInstance
- * without mastership and don't remove ServiceGroup from map
+ * without mastership and don't remove ServiceGroup from map.
*
* @throws Exception - unexpected exception
*/
}
/**
- * Test GoldPath get Slave role for registered main entity
+ * Test GoldPath get Slave role for registered main entity.
*
* @throws Exception - unexpected exception
*/
}
/**
- * Test GoldPath get Master role for registered main entity
+ * Test GoldPath get Master role for registered main entity.
*
* @throws Exception - unexpected exception
*/
}
/**
- * Test GoldPath get Master role for registered close entity
+ * Test GoldPath get Master role for registered close entity.
*
* @throws Exception - unexpected exception
*/
/**
* Test GoldPath get Master role for registered entity but initial Slave
- * role for closeEntity
+ * role for closeEntity.
*
* @throws Exception - unexpected exception
*/
}
/**
- * Test inJeopardy validation during wait phase for Master role for closeEntity
+ * Test inJeopardy validation during wait phase for Master role for closeEntity.
*
* @throws Exception - unexpected exception
*/
}
/**
- * Test inJeopardy validation during wait phase for Master role for closeEntity
+ * Test inJeopardy validation during wait phase for Master role for closeEntity.
*
* @throws Exception - unexpected exception
*/
}
/**
- * Test inJeopardy validation for holding leadership
+ * Test inJeopardy validation for holding leadership.
*
* @throws Exception - unexpected exception
*/
}
/**
- * Test GoldPath for SLAVE-TO-MASTER entity Candidate role change
+ * Test GoldPath for SLAVE-TO-MASTER entity Candidate role change.
*
* @throws Exception - unexpected exception
*/
/**
* Test checks validation Error processing for SLAVE-TO-MASTER entity Candidate role change.
- * Not initialized provider has to close and remove all singletonServices from Group and
- * Group itself remove too.
+ * Not initialized provider has to close and remove all singletonServices from Group and
+ * Group itself remove too.
*
* @throws Exception - unexpected exception
*/
}
/**
- * Test checks closing procesing for close {@link ClusterSingletonServiceRegistration}
+ * Test checks closing procesing for close {@link ClusterSingletonServiceRegistration}.
*
* @throws Exception - unexpected exception
*/
}
/**
- * Test checks validation Error processing for MASTER-TO-SLAVE closeEntity Candidate role change
+ * Test checks validation Error processing for MASTER-TO-SLAVE closeEntity Candidate role change.
*
* @throws Exception - unexpected exception
*/
/**
* Test checks validation Error processing for MASTER-TO-SLAVE closeEntity Candidate role change
- * without closeEntity registration
+ * without closeEntity registration.
*
* @throws Exception - unexpected exception
*/
}
private GenericEntityOwnershipChange<TestInstanceIdentifier, TestEntity> getEntityToJeopardy() {
- return new GenericEntityOwnershipChange<>(mainEntity, EntityOwnershipChangeState.from(false, false, false), true);
+ return new GenericEntityOwnershipChange<>(mainEntity,
+ EntityOwnershipChangeState.from(false, false, false), true);
}
}
Code Review / mdsal.git / blobdiff