private SetImpl impl;

  // the following must be set during setUp
  private CollectionBenchmarkSampleData sampleData;

  @BeforeExperiment
  void setUp() {
    sampleData = new CollectionBenchmarkSampleData(true, random, 0.8, size);
  }

  @Benchmark
  int creation(int reps) {
    int x = 0;
    for (int i = 0; i < reps; i++) {
      x ^= System.identityHashCode(impl.create(sampleData.getValuesInSet()));
    }

        assertNotNull(queryRescorer.evaluate(numberParams));

        // Test with boolean parameter
        Map<String, Object> booleanParams = new HashMap<>();
        booleanParams.put("boolean", true);
        assertNotNull(queryRescorer.evaluate(booleanParams));

        // Test with unknown parameter
        Map<String, Object> unknownParams = new HashMap<>();
        unknownParams.put("unknown", new Object());

    // signature: we make k 0-based rather than 1-based; and we drop from and to, and always work on
    // the whole array.
    int from = 0;
    int to = array.length - 1;

    while (true) {
      if (to <= from + 1) {
        // Two or less elements left.
        if (to == from + 1 && array[to] < array[from]) {
          // Exactly two elements left.
          swap(array, from, to);
        }

        assertEquals(request.size(), encoded);
    }

    @Test
    public void testDurableHandleV2RequestPersistent() {
        DurableHandleV2Request request = new DurableHandleV2Request(0, true);

        assertEquals(0, request.getTimeoutMs());
        assertTrue(request.isPersistent());
        assertEquals(Smb2HandleCapabilities.SMB2_DHANDLE_FLAG_PERSISTENT,

        handle.sendrecv(rpc);
        if (rpc.retval != 0) {
            throw new SmbException(rpc.retval, false);
        }
        this.opened = true;
    }

    @Override
    public synchronized void close() throws IOException {
        if (this.opened) {
            this.opened = false;
            final MsrpcLsarClose rpc = new MsrpcLsarClose(this);

     * One thread sets alive to false, other threads should see the change immediately.
     */
    @Test
    public void test_aliveField_volatileVisibility() throws Exception {
        // Ensure alive starts as true
        assertTrue(dataStore.alive);

        final int readerThreadCount = 5;
        final long testDurationMs = 200; // Run for 200ms
        final Thread[] readerThreads = new Thread[readerThreadCount];

        if (collection.size() == entry.getValue().size()) {
          entryIterator.remove();
        } else {
          collection.clear();
        }
        changed = true;
      }
    }
    return changed;
  }

  @WeakOuter
  private final class AsMap extends ViewCachingAbstractMap<K, Collection<V>> {
    @Override
    public boolean containsKey(@Nullable Object key) {

      for (ValueEntry<K, V> entry = hashTable[smearedHash & mask()];
          entry != null;
          entry = entry.nextInValueBucket) {
        if (entry.matchesValue(o, smearedHash)) {
          return true;
        }
      }
      return false;
    }

    @Override
    public boolean add(@ParametricNullness V value) {
      int smearedHash = smearedHash(value);
      int bucket = smearedHash & mask();

        void shouldDefineIsInherited() {
            ACE inheritedAce = mock(ACE.class);
            ACE directAce = mock(ACE.class);
            when(inheritedAce.isInherited()).thenReturn(true);
            when(directAce.isInherited()).thenReturn(false);

            assertTrue(inheritedAce.isInherited());
            assertFalse(directAce.isInherited());
            verify(inheritedAce).isInherited();

    }

    /**
     * Check if a lease was granted in this response
     * @return true if a lease was granted
     */
    public boolean isLeaseGranted() {
        return getLeaseV1Context() != null || getLeaseV2Context() != null;
    }

    /**
     * Check if a durable handle was granted in this response
     * @return true if a durable handle was granted
     */
    public boolean isDurableHandleGranted() {