- public void gatherDynamicDataTest() {
-
-
- final StatisticsContextImpl statisticsContext = new StatisticsContextImpl(mockedDeviceInfo, false, mockConductor);
-
- final ListenableFuture<RpcResult<List<MultipartReply>>> rpcResult = immediateFuture(RpcResultBuilder.success(Collections.<MultipartReply>emptyList()).build());
+ public void gatherDynamicDataTest() throws InterruptedException {
+
+ when(mockedDeviceState.isTableStatisticsAvailable()).thenReturn(Boolean.TRUE);
+ when(mockedDeviceState.isFlowStatisticsAvailable()).thenReturn(Boolean.TRUE);
+ when(mockedDeviceState.isGroupAvailable()).thenReturn(Boolean.TRUE);
+ when(mockedDeviceState.isMetersAvailable()).thenReturn(Boolean.TRUE);
+ when(mockedDeviceState.isPortStatisticsAvailable()).thenReturn(Boolean.TRUE);
+ when(mockedDeviceState.isQueueStatisticsAvailable()).thenReturn(Boolean.TRUE);
+ when(mockedDeviceContext.getDeviceState()).thenReturn(mockedDeviceState);
+
+ final ConvertorManager convertorManager = ConvertorManagerFactory.createDefaultManager();
+ final StatisticsContextImpl<MultipartReply> statisticsContext = new StatisticsContextImpl<>(
+ mockedDeviceContext, convertorManager,
+ MultipartWriterProviderFactory.createDefaultProvider(mockedDeviceContext),
+ MoreExecutors.newDirectExecutorService(),
+ config,
+ true,
+ false);
+
+ final ListenableFuture<RpcResult<List<MultipartReply>>> rpcResult = immediateFuture(RpcResultBuilder
+ .success(Collections.<MultipartReply>emptyList()).build());