package org.opendaylight.openflowplugin.impl.statistics.services.direct;
+import static org.junit.Assert.assertFalse;
+import static org.junit.Assert.assertTrue;
+import static org.mockito.Mockito.times;
+import static org.mockito.Mockito.verify;
+
import org.junit.Before;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.opendaylight.yangtools.yang.common.RpcError;
import org.opendaylight.yangtools.yang.common.RpcResult;
-import static org.junit.Assert.assertFalse;
-import static org.junit.Assert.assertTrue;
-import static org.mockito.Mockito.times;
-import static org.mockito.Mockito.verify;
-
@RunWith(MockitoJUnitRunner.class)
public class OpendaylightDirectStatisticsServiceImplTest {
@Mock
- FlowDirectStatisticsService flowDirectStatisticsService;
+ AbstractFlowDirectStatisticsService flowDirectStatisticsService;
@Mock
- GroupDirectStatisticsService groupDirectStatisticsService;
+ AbstractGroupDirectStatisticsService groupDirectStatisticsService;
@Mock
- MeterDirectStatisticsService meterDirectStatisticsService;
+ AbstractMeterDirectStatisticsService meterDirectStatisticsService;
@Mock
- NodeConnectorDirectStatisticsService nodeConnectorDirectStatisticsService;
+ AbstractPortDirectStatisticsService nodeConnectorDirectStatisticsService;
@Mock
- QueueDirectStatisticsService queueDirectStatisticsService;
+ AbstractQueueDirectStatisticsService queueDirectStatisticsService;
@Mock
GetGroupStatisticsInput getGroupStatisticsInput;
GetMeterStatisticsInput getMeterStatisticsInput;
@Mock
GetNodeConnectorStatisticsInput getNodeConnectorStatisticsInput;
-
+
private OpendaylightDirectStatisticsService service;
private OpendaylightDirectStatisticsService emptyService;
@Before
public void setUp() throws Exception {
final OpendaylightDirectStatisticsServiceProvider provider = new OpendaylightDirectStatisticsServiceProvider();
- provider.register(FlowDirectStatisticsService.class, flowDirectStatisticsService);
- provider.register(GroupDirectStatisticsService.class, groupDirectStatisticsService);
- provider.register(MeterDirectStatisticsService.class, meterDirectStatisticsService);
- provider.register(NodeConnectorDirectStatisticsService.class, nodeConnectorDirectStatisticsService);
- provider.register(QueueDirectStatisticsService.class, queueDirectStatisticsService);
+ provider.register(AbstractFlowDirectStatisticsService.class, flowDirectStatisticsService);
+ provider.register(AbstractGroupDirectStatisticsService.class, groupDirectStatisticsService);
+ provider.register(AbstractMeterDirectStatisticsService.class, meterDirectStatisticsService);
+ provider.register(AbstractPortDirectStatisticsService.class, nodeConnectorDirectStatisticsService);
+ provider.register(AbstractQueueDirectStatisticsService.class, queueDirectStatisticsService);
service = new OpendaylightDirectStatisticsServiceImpl(provider);
emptyService = new OpendaylightDirectStatisticsServiceImpl(new OpendaylightDirectStatisticsServiceProvider());
assertFalse(result.isSuccessful());
for (RpcError error : result.getErrors()) {
- assertTrue(error.getMessage().contains(GroupDirectStatisticsService.class.getSimpleName()));
+ assertTrue(error.getMessage().contains(AbstractGroupDirectStatisticsService.class.getSimpleName()));
}
verify(groupDirectStatisticsService, times(0)).handleAndReply(getGroupStatisticsInput);
assertFalse(result.isSuccessful());
for (RpcError error : result.getErrors()) {
- assertTrue(error.getMessage().contains(QueueDirectStatisticsService.class.getSimpleName()));
+ assertTrue(error.getMessage().contains(AbstractQueueDirectStatisticsService.class.getSimpleName()));
}
verify(queueDirectStatisticsService, times(0)).handleAndReply(getQueueStatisticsInput);
assertFalse(result.isSuccessful());
for (RpcError error : result.getErrors()) {
- assertTrue(error.getMessage().contains(FlowDirectStatisticsService.class.getSimpleName()));
+ assertTrue(error.getMessage().contains(AbstractFlowDirectStatisticsService.class.getSimpleName()));
}
verify(flowDirectStatisticsService, times(0)).handleAndReply(getFlowStatisticsInput);
assertFalse(result.isSuccessful());
for (RpcError error : result.getErrors()) {
- assertTrue(error.getMessage().contains(MeterDirectStatisticsService.class.getSimpleName()));
+ assertTrue(error.getMessage().contains(AbstractMeterDirectStatisticsService.class.getSimpleName()));
}
verify(meterDirectStatisticsService, times(0)).handleAndReply(getMeterStatisticsInput);
assertFalse(result.isSuccessful());
for (RpcError error : result.getErrors()) {
- assertTrue(error.getMessage().contains(NodeConnectorDirectStatisticsService.class.getSimpleName()));
+ assertTrue(error.getMessage().contains(AbstractPortDirectStatisticsService.class.getSimpleName()));
}
verify(nodeConnectorDirectStatisticsService, times(0)).handleAndReply(getNodeConnectorStatisticsInput);
}
-}
\ No newline at end of file
+}