}

        /*
         * Subtract the server and share from the pathConsumed so that
         * it reflects the part of the relative path consumed and not
         * the entire path.
         */

        DfsReferralDataInternal next = dri;
        do {
            next.stripPathConsumed(1 + server.length() + 1 + share.length());
            next = next.next();
        } while (next != dri);

    val request2 = Request.Builder().url(server.url("/")).build()
    val response2 = client.newCall(request2).execute()
    assertThat(response2.body.string()).isEqualTo("def")

    // The HTTP calls should share a single connection.
    assertThat(socksProxy.connectionCount()).isEqualTo(1)
  }

  @Test
  fun proxySelector() {
    server.enqueue(MockResponse.Builder().body("abc").build())
    val proxySelector: ProxySelector =

        // Validates simple property delegation to the connection
        when(treeConnection.getTreeType()).thenReturn(7);
        when(treeConnection.getConnectedShare()).thenReturn("SHARE");
        assertEquals(7, handle.getTreeType());
        assertEquals("SHARE", handle.getConnectedShare());
        verify(treeConnection).getTreeType();
        verify(treeConnection).getConnectedShare();
    }

    @Test

    CIFSContext context = getTestContext();
    context.getConfig().setProperty("jcifs.smb.client.directoryNotificationsEnabled", "true");
    
    SmbFile dir = new SmbFile("smb://server/share/testdir/", context);
    SmbFile testFile = new SmbFile("smb://server/share/testdir/newfile.txt", context);
    
    // Get initial listing (establishes cache)
    SmbFile[] initialFiles = dir.listFiles();
    
    // Create new file

/** An HTTP request that came into the mock web server. */
public class RecordedRequest(
  /**
   * The index of the socket connection that carried this request. If two recorded requests share a
   * connection index, they also shared a socket connection.
   */
  public val connectionIndex: Int,
  /**
   * The index of this exchange on its HTTP connection. A request is uniquely identified by the

        SMBUtil.writeInt2(mapInformationLevel(this.informationLevel), dst, dstIndex);
        dstIndex += 2;

        /*
         * windows98 has what appears to be another 4 0's followed by the share
         * name as a zero terminated ascii string "\TMP" + '\0'
         *
         * As is this works, but it deviates from the spec section 4.1.6.6 but
         * maybe I should put it in. Wonder what NT does?
         */

        GsaConfigParser parser = new GsaConfigParser();
        String xmlWithFileUrls = "<?xml version=\"1.0\"?>" + "<eef><config><globalparams>"
                + "<start_urls>file:///test\nsmb://server/share</start_urls>" + "</globalparams></config></eef>";

        parser.parse(new InputSource(new StringReader(xmlWithFileUrls)));

        assertFalse(parser.getWebConfig().isPresent());

        scheduler.scheduleAtFixedRate(this::monitorRegistrations, 10, 10, TimeUnit.SECONDS);
    }

    /**
     * Registers for witness notifications.
     *
     * @param shareName the share name to monitor
     * @param serverAddress the server address
     * @param listener the notification listener
     * @return a future that completes with the registration
     */

    /**
     * Constructs an SmbRandomAccessFile with the specified URL, mode, and share access flags.
     *
     * @param url the SMB URL of the file to access
     * @param mode the access mode ("r" for read-only, "rw" for read-write)
     * @param shareAccess the share access flags for file sharing
     * @throws SmbException if an SMB error occurs

        // Create a buffer representing a valid DFS referral response
        // Need to include space for actual string data
        int stringDataStart = 28; // After the referral structure
        String testPath = "\\server\\share";
        byte[] pathBytes = testPath.getBytes(java.nio.charset.StandardCharsets.UTF_16LE);
        int bufferSize = stringDataStart + pathBytes.length + 2; // +2 for null terminator
        byte[] buffer = new byte[bufferSize];