@BeforeEach
    void setUp() {
        resourceManager = ResourceManager.getInstance();
        // Configure with shorter intervals for testing
        resourceManager.configure(1000, 100, true, true);
    }

    /**
     * Test resource for tracking
     */
    static class TestResource implements AutoCloseable {
        private final AtomicBoolean closed = new AtomicBoolean(false);

          double z = aa.addAndGet(i, y);
          assertBitEquals(x + y, z);
          assertBitEquals(x + y, aa.get(i));
        }
      }
    }
  }

  static final long COUNTDOWN = 100000;

  class Counter extends CheckedRunnable {
    final AtomicDoubleArray aa;
    volatile long counts;

    Counter(AtomicDoubleArray a) {
      aa = a;
    }

            // Given - disk with no free space
            ByteBuffer buffer = ByteBuffer.allocate(24);
            buffer.order(ByteOrder.LITTLE_ENDIAN);
            buffer.putLong(1000000L);
            buffer.putLong(0L);
            buffer.putInt(8);
            buffer.putInt(512);

            // When
            fileFsSizeInfo.decode(buffer.array(), 0, 24);

            // Then

        // Verify O(1) performance - should be reasonably fast (allowing for JVM overhead)
        assertTrue(avgAllocTimeNs < 10000, "Average allocation should be under 10000ns (O(1) performance)");
        assertTrue(avgReleaseTimeNs < 10000, "Average release should be under 10000ns (O(1) performance)");
        assertEquals(threadCount * operationsPerThread, allocations.get());

          double z = aa.updateAndGet(i, value -> value - y);
          assertBitEquals(x - y, z);
          assertBitEquals(x - y, aa.get(i));
        }
      }
    }
  }

  static final long COUNTDOWN = 100000;

  class Counter extends CheckedRunnable {
    final AtomicDoubleArray aa;
    volatile long counts;

    Counter(AtomicDoubleArray a) {
      aa = a;
    }

            // Given - disk with no free space
            ByteBuffer buffer = ByteBuffer.allocate(32);
            buffer.order(ByteOrder.LITTLE_ENDIAN);
            buffer.putLong(1000000L);
            buffer.putLong(0L);
            buffer.putLong(0L);
            buffer.putInt(8);
            buffer.putInt(512);

            // When

 */
public class RdmaErrorHandler {

    private static final Logger log = LoggerFactory.getLogger(RdmaErrorHandler.class);

    // Retry and timing constants (in ms)
    private static final long MAX_RETRY_DELAY = 10000; // 10 seconds maximum delay
    private static final int MAX_BACKOFF_SHIFT = 4; // Maximum 16x multiplier

    private final RdmaStatistics statistics;
    private final int maxRetries;
    private final long retryDelayMs;

        assertThrows(SmbException.class, () -> {
            validator.validateArrayAllocation(-1, 10, 1000);
        });
    }

    @Test
    public void testArrayAllocationInvalidElementSize() throws Exception {
        assertThrows(SmbException.class, () -> {
            validator.validateArrayAllocation(100, 0, 1000);
        });
    }

    @Test

            processor.setSearcher(new TestSearcher(100));
            processor.init();

            final List<Map<String, Object>> results =
                    processor.search("*", new TestSearchRequestParams(0, 10000, 0), OptionalThing.empty());
            assertNotNull(results);
            // Should return only available documents
            assertEquals(100, results.size());
        }
    }

    /**

        // Integer
        assertEquals(42, groovyEngine.evaluate("return 42", params));

        // Long
        assertEquals(1000000L, groovyEngine.evaluate("return 1000000L", params));

        // Double
        final Object doubleResult = groovyEngine.evaluate("return 3.14159", params);
        assertTrue(doubleResult instanceof Number);