import jcifs.internal.smb1.trans.SmbComTransaction;
import jcifs.internal.smb1.trans.SmbComTransactionResponse;
import jcifs.internal.util.SMBUtil;

/**
 * Trans2 FindFirst2 response message for SMB1 directory enumeration.
 * This class handles the response from a TRANS2_FIND_FIRST2 request, which returns
 * the first set of directory entries matching the specified search criteria.
 */

    )
    serverIpv6.enqueue(
      MockResponse(body = "hello from IPv6"),
    )

    val call = client.newCall(Request(url))
    val response = call.execute()
    assertThat(response.body.string()).isEqualTo("hello from IPv6")

    // In the process we made one successful connection attempt.
    assertThat(listener.recordedEventTypes().filter { it == "ConnectStart" }).hasSize(1)

        setStatus(response, NtStatus.NT_STATUS_NOTIFY_ENUM_DIR);
        assertFalse(response.isErrorResponseStatus());

        // Test with success status
        setStatus(response, NtStatus.NT_STATUS_SUCCESS);
        assertFalse(response.isErrorResponseStatus());

        // Test with error status
        setStatus(response, NtStatus.NT_STATUS_ACCESS_DENIED);

            engineObj.activeShards = response.getActiveShards();
            engineObj.activeShardsPercent = response.getActiveShardsPercent();
            engineObj.relocatingShards = response.getRelocatingShards();
            engineObj.initializingShards = response.getInitializingShards();
            engineObj.unassignedShards = response.getUnassignedShards();
            engineObj.delayedUnassignedShards = response.getDelayedUnassignedShards();

import jcifs.smb.FileEntry;

/**
 * SMB2 Query Directory response message. This response contains directory listing
 * information with file entries and their attributes.
 *
 * @author mbechler
 *
 */
public class Smb2QueryDirectoryResponse extends ServerMessageBlock2Response {

    /**
     * Protocol overhead size for SMB2 query directory response
     */

    public void test_doFilter_withNullWebApiManager() throws IOException, ServletException {
        // Setup mock objects
        HttpServletRequest request = createMockHttpServletRequest();
        HttpServletResponse response = createMockHttpServletResponse();
        AtomicBoolean chainCalled = new AtomicBoolean(false);

        FilterChain chain = new FilterChain() {
            @Override

  )
  fun headers(): Headers = headers

  @JvmName("-deprecated_response")
  @Deprecated(
    message = "moved to val",
    replaceWith = ReplaceWith(expression = "response"),
    level = DeprecationLevel.ERROR,
  )
  fun response(): MockResponse = response

    Request request = new Request.Builder()
        .url("http://httpbin.org/delay/2") // This URL is served with a 2 second delay.
        .build();

    try (Response response = client.newCall(request).execute()) {
      System.out.println("Response completed: " + response);
    }
  }

  public static void main(String... args) throws Exception {
    new ConfigureTimeouts().run();
  }

        return null;
    }

    @Override
    protected void testRead() {
        final Map<String, Object> searchBody = new HashMap<>();
        String response = checkGetMethod(searchBody, "").asString();
        final Map<String, Object> res = JsonPath.from(response).getMap("response");
        assertTrue(res.containsKey("env_props"));
        assertTrue(res.containsKey("system_props"));
        assertTrue(res.containsKey("fess_props"));

    /**
     * Receive a response from the transport
     *
     * @param response the response object to populate
     * @throws IOException if an I/O error occurs
     */
    protected abstract void doRecv(Response response) throws IOException;

    /**
     * Skip a response with the given key
     *
     * @param key the key of the response to skip
     * @throws IOException if an I/O error occurs