assertThat(loadAllCount.get()).isEqualTo(0);

    Object unused1 = baseLoader.load(new Object());
    @SuppressWarnings("unused") // https://errorprone.info/bugpattern/FutureReturnValueIgnored
    Future<?> possiblyIgnoredError = baseLoader.reload(new Object(), new Object());
    Map<Object, Object> unused2 = baseLoader.loadAll(ImmutableList.of(new Object()));
    assertThat(loadCount.get()).isEqualTo(1);

        assertDoesNotThrow(() -> {
            cache.getBuffer();
            cache.releaseBuffer(new byte[1024]);
        }, "All BufferCache interface methods should be callable");
    }

    @Test
    @DisplayName("getBuffer should return non-null byte array")
    void testGetBufferContract() {
        // Given
        byte[] expectedBuffer = new byte[1024];
        when(mockBufferCache.getBuffer()).thenReturn(expectedBuffer);

    }

    @Test
    void testTrans2QueryPathUnsupportedLevel() throws Exception {
        Trans2QueryPathInformationResponse trans = new Trans2QueryPathInformationResponse(9999) {
        };
        assertEquals(0, trans.readDataWireFormat(new byte[10], 0, 10));
        java.lang.reflect.Field infoField = Trans2QueryPathInformationResponse.class.getDeclaredField("info");
        infoField.setAccessible(true);

        ExtensionDescriptor extensionDescriptor = new ExtensionDescriptor();

        XmlNode dom;
        try {
            XMLStreamReader reader = XMLInputFactory.newFactory().createXMLStreamReader(is);
            dom = XmlService.read(reader);
        } catch (XMLStreamException e) {
            throw new IOException(e.getMessage(), e);
        }

        if (!"extension".equals(dom.name())) {

        return new CurlRequest(Method.POST, url);
    }

    /**
     * Creates a new CurlRequest with the HTTP PUT method for the specified URL.
     *
     * @param url the URL to which the PUT request will be sent
     * @return a new CurlRequest object configured with the PUT method and the specified URL
     */
    public static CurlRequest put(final String url) {
        return new CurlRequest(Method.PUT, url);
    }

        final int iterationsPerThread = 100;
        final CountDownLatch startLatch = new CountDownLatch(1);
        final CountDownLatch endLatch = new CountDownLatch(threadCount);
        final AtomicInteger errorCount = new AtomicInteger(0);

        // Set initial values
        testRule.setRuleId("concurrentRule");
        TestResponseProcessor processor = new TestResponseProcessor();
        testRule.setResponseProcessor(processor);

        FailureUrlCQ cq = new FailureUrlCQ();
        if (queryLambda != null) {
            queryLambda.callback(cq);
        }
        FilterAggregationBuilder builder = regFilterA(name, cq.getQuery());
        if (opLambda != null) {
            opLambda.callback(builder);
        }
        if (aggsLambda != null) {
            FailureUrlCA ca = new FailureUrlCA();
            aggsLambda.callback(ca);

    @Override
    public String toString() {
      return "IsOdd";
    }
  }

  /**
   * Generates a new Predicate per call.
   *
   * <p>Creating a new Predicate each time helps catch cases where code is using {@code x == y}
   * instead of {@code x.equals(y)}.
   */
  private static IsOdd isOdd() {
    return new IsOdd();
  }

  /*
   * Tests for Predicates.alwaysTrue().
   */

            this.openFlags = SmbFile.O_CREAT | SmbFile.O_RDWR | SmbFile.O_APPEND;
            write_andx_resp = new SmbComWriteAndXResponse();
            options = WRITE_OPTIONS;
            access = SmbConstants.FILE_READ_DATA | SmbConstants.FILE_WRITE_DATA;
        } else {
            throw new IllegalArgumentException("Invalid mode");
        }
        file.open(openFlags, access, SmbFile.ATTR_NORMAL, options);

    return new TypeResolver().where(TypeMappingIntrospector.getTypeMappings(invariantContext));
  }

  /**
   * Returns a new {@code TypeResolver} with type variables in {@code formal} mapping to types in
   * {@code actual}.
   *
   * <p>For example, if {@code formal} is a {@code TypeVariable T}, and {@code actual} is {@code
   * String.class}, then {@code new TypeResolver().where(formal, actual)} will {@linkplain