} catch (NoSuchMethodException e) {
            throw new RuntimeException(e);
        }
    }

    private static Method makeAccessible(Method method) {
        method.setAccessible(true);
        return method;
    }

    private static <T> T invoke(Method method, Object instance, Object... args) {
        try {
            Object result = method.invoke(instance, args);

            proxy_set_header X-Real-IP $remote_addr;
            proxy_set_header X-Forwarded-For $proxy_add_x_forwarded_for;
            proxy_set_header X-Forwarded-Proto $scheme;
            proxy_set_header X-NginX-Proxy true;

            # This is necessary to pass the correct IP to be hashed
            real_ip_header X-Real-IP;

            proxy_connect_timeout 300;
            
            # To support websocket

        // Initially not received
        Method isReceivedMethod = ServerMessageBlock2Response.class.getDeclaredMethod("isReceived");
        isReceivedMethod.setAccessible(true);
        assertFalse((boolean) isReceivedMethod.invoke(response));

        // Test reset method
        response.reset();
        assertFalse((boolean) isReceivedMethod.invoke(response));
    }

    @Test

     * 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) {

        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);

      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();

import okhttp3.sse.EventSourceListener

class EventSourceRecorder : EventSourceListener() {
  private val events = LinkedBlockingDeque<Any>()
  private var cancel = false

  fun enqueueCancel() {
    cancel = true
  }

  override fun onOpen(
    eventSource: EventSource,
    response: Response,
  ) {
    get().log("[ES] onOpen", Platform.INFO, null)
    events.add(Open(eventSource, response))