assertEquals(1, notifications.get(0).getAction());
        assertEquals("file1", notifications.get(0).getFileName());

        assertEquals(2, notifications.get(1).getAction());
        assertEquals("file2", notifications.get(1).getFileName());

        assertEquals(3, notifications.get(2).getAction());
        assertEquals("file3", notifications.get(2).getFileName());
    }

        double avgAllocTimeNs = totalAllocTime.get() / (double) allocations.get();
        double avgReleaseTimeNs = totalReleaseTime.get() / (double) releases.get();

        System.out.printf("Buffer Cache Performance: %d allocs, %d releases in %.2f ms%n", allocations.get(), releases.get(),
                overallTimeMs);

    public LeaseEntry getLease(Smb2LeaseKey key) {
        return leases.get(key);
    }

    /**
     * Get lease entry by path
     *
     * @param path file path
     * @return lease entry or null if not found
     */
    public LeaseEntry getLeaseByPath(String path) {
        Smb2LeaseKey key = pathToLease.get(path);
        return key != null ? leases.get(key) : null;
    }

    /**

                return channels.get(index);

            case LEAST_CONNECTIONS:
                return channels.stream()
                        .min((c1, c2) -> Integer.compare(c1.getActiveConnections(), c2.getActiveConnections()))
                        .orElse(channels.get(0));

            case RANDOM:
                return channels.get((int) (Math.random() * channels.size()));

            return !exists;
        });
    }

    /**
     * Get detailed health statistics
     */
    public PoolHealthMetrics getHealthMetrics() {
        return new PoolHealthMetrics(connections.size(), nonPooledConnections.size(), activeConnections.get(), maxPoolSize,
                totalHealthChecks.get(), failedHealthChecks.get(), connectionsRemoved.get(), connectionMetrics.size(),

      @Override
      public int size() {
        return axes.size();
      }

      @Override
      public E get(int axis) {
        checkElementIndex(axis, size());
        int axisIndex = getAxisIndexForProductIndex(index, axis);
        return axes.get(axis).get(axisIndex);
      }

      @Override
      boolean isPartialView() {
        return true;
      }

        // Only cache if we haven't reached the limit - O(1) check
        if (queueSize.get() < MAX_BUFFERS) {
            if (bufferQueue.offer(buf)) { // O(1) operation
                queueSize.incrementAndGet();
            }
        }
        // If queue is full, let the buffer be garbage collected
    }

    /**
     * Get current cache statistics for monitoring
     * @return formatted statistics string
     */

        List<Exception> exceptions = new ArrayList<>();

        // When - Multiple threads get and release buffers
        for (int t = 0; t < threadCount; t++) {
            executor.submit(() -> {
                try {
                    startLatch.await();

                    for (int i = 0; i < opsPerThread; i++) {
                        // Get buffer
                        byte[] buffer = BufferCache.getBuffer();

        Map<String, Integer> failCounts = (Map<String, Integer>) failCountsField.get(pool);

        // When: Add fail counts
        failCounts.put("192.168.1.1", 3);
        failCounts.put("192.168.1.2", 1);

        // Then: Should be accessible
        assertEquals(3, failCounts.get("192.168.1.1"));
        assertEquals(1, failCounts.get("192.168.1.2"));
    }

        // Then - Verify no exceptions occurred
        if (!exceptions.isEmpty()) {
            fail("Concurrent operations caused exceptions: " + exceptions.get(0));
        }

        assertEquals(threadCount * opsPerThread, successCount.get(), "All operations should succeed");
    }

    /**
     * Test that session release with double-check pattern prevents race conditions.
     */
    @Test