import org.junit.runner.RunWith;
import org.mockito.junit.MockitoJUnitRunner;
import org.opendaylight.mdsal.singleton.common.api.ClusterSingletonService;
-import org.opendaylight.mdsal.singleton.common.api.ClusterSingletonServiceRegistration;
/*
* Testing {@link DOMClusterSingletonServiceProviderImpl} implementation
*/
@Test
public void takeDoubleLeadershipClusterSingletonServiceTest() throws Exception {
- final ClusterSingletonServiceRegistration reg = clusterSingletonServiceProvider
- .registerClusterSingletonService(clusterSingletonService);
+ final var reg = clusterSingletonServiceProvider.registerClusterSingletonService(clusterSingletonService);
assertNotNull(reg);
verify(mockEos).registerCandidate(ENTITY);
clusterSingletonServiceProvider.ownershipChanged(ENTITY, LOCAL_OWNERSHIP_GRANTED, false);
*/
@Test
public void unexpectedLostLeadershipDoubleCandidateTest() throws Exception {
- final ClusterSingletonServiceRegistration reg = clusterSingletonServiceProvider
- .registerClusterSingletonService(clusterSingletonService);
+ final var reg = clusterSingletonServiceProvider.registerClusterSingletonService(clusterSingletonService);
assertNotNull(reg);
verify(mockEos).registerCandidate(ENTITY);
clusterSingletonServiceProvider.ownershipChanged(ENTITY, LOCAL_OWNERSHIP_GRANTED, false);
*/
@Test
public void inJeopardyMasterTest() throws Exception {
- final ClusterSingletonServiceRegistration reg = clusterSingletonServiceProvider
- .registerClusterSingletonService(clusterSingletonService);
+ final var reg = clusterSingletonServiceProvider.registerClusterSingletonService(clusterSingletonService);
assertNotNull(reg);
verify(mockEos).registerCandidate(ENTITY);
clusterSingletonServiceProvider.ownershipChanged(ENTITY, LOCAL_OWNERSHIP_GRANTED, false);
}
/**
- * Test checks close processing for {@link ClusterSingletonServiceRegistration}.
+ * Test checks close processing for {@link ServiceRegistration}.
*
* @throws Exception if the condition does not meet
*/
@Test
public void closeClusterSingletonServiceRegistrationMasterTest() throws Exception {
- final ClusterSingletonServiceRegistration reg = clusterSingletonServiceProvider
- .registerClusterSingletonService(clusterSingletonService);
+ final var reg = clusterSingletonServiceProvider.registerClusterSingletonService(clusterSingletonService);
assertNotNull(reg);
assertEquals(TestClusterSingletonServiceState.INITIALIZED, clusterSingletonService.getServiceState());
verify(mockEos).registerCandidate(ENTITY);
}
/**
- * Test checks close processing for {@link ClusterSingletonServiceRegistration}.
+ * Test checks close processing for {@link ServiceRegistration}.
*
* @throws Exception if the condition does not meet
*/
@Test
public void closeClusterSingletonServiceRegistrationMasterCloseWithNotificationTimesTest() throws Exception {
- final ClusterSingletonServiceRegistration reg = clusterSingletonServiceProvider
- .registerClusterSingletonService(clusterSingletonService);
+ final var reg = clusterSingletonServiceProvider.registerClusterSingletonService(clusterSingletonService);
assertNotNull(reg);
assertEquals(TestClusterSingletonServiceState.INITIALIZED, clusterSingletonService.getServiceState());
verify(mockEos).registerCandidate(ENTITY);
}
/**
- * Test checks close processing for {@link ClusterSingletonServiceRegistration}.
+ * Test checks close processing for {@link ServiceRegistration}.
*
* @throws Exception if the condition does not meet
*/
@Test
public void closeClusterSingletonServiceRegistrationMasterCloseCoupleTimesTest() throws Exception {
- final ClusterSingletonServiceRegistration reg = clusterSingletonServiceProvider
- .registerClusterSingletonService(clusterSingletonService);
+ final var reg = clusterSingletonServiceProvider.registerClusterSingletonService(clusterSingletonService);
assertNotNull(reg);
assertEquals(TestClusterSingletonServiceState.INITIALIZED, clusterSingletonService.getServiceState());
verify(mockEos).registerCandidate(ENTITY);