Details
Description
The cache#putAllAsync method does not collect statistics.
The reproducer for GridCacheAbstractMetricsSelfTest:
@Test public void testPutAllAsyncAvgTime() throws Exception { IgniteCache<Integer, Integer> cache = grid(0).cache(DEFAULT_CACHE_NAME); assertEquals(0.0, cache.localMetrics().getAveragePutTime(), 0.0); assertEquals(0, cache.localMetrics().getCachePuts()); Map<Integer, Integer> values = new HashMap<>(); values.put(1, 1); values.put(2, 2); values.put(3, 3); IgniteFuture<Void> fut = cache.putAllAsync(values); fut.get(); assertTrue(waitForCondition(() -> cache.localMetrics().getAveragePutTime() > 0, 30_000)); assertEquals(values.size(), cache.localMetrics().getCachePuts()); }
Attachments
Issue Links
- links to