sourceCount++
    }

    return RelaySource()
  }

  internal inner class RelaySource : Source {
    private val timeout = Timeout()

    /** The operator to read and write the shared file. Null if this source is closed. */
    private var fileOperator: FileOperator? = FileOperator(file!!.channel)

    /** The next byte to read. This is always less than or equal to [upstreamPos]. */

 * service type, and DFS information for the connected share.
 *
 * @author mbechler
 */
public interface TreeConnectResponse extends CommonServerMessageBlockResponse {

    /**
     * Returns the tree identifier (TID) assigned to this tree connection.
     *
     * @return tree id
     */
    int getTid();

    /**
     * Returns the service type of the connected share (e.g., A: for disk, LPT1: for printer, IPC for named pipe).

        assertEquals(2, response.results.length, "Should have 2 share entries.");

        SmbShareInfo share1 = (SmbShareInfo) response.results[0];
        assertEquals("SHARE1", share1.getName().trim(), "Share 1 name should be correct.");
        assertEquals(0, share1.type, "Share 1 raw type should be 0.");
        assertEquals("Remark 1", share1.remark.trim(), "Share 1 remark should be correct.");

import okhttp3.internal.isHealthy
import okhttp3.internal.tls.OkHostnameVerifier
import okio.Buffer

/**
 * A connection to a remote web server capable of carrying 1 or more concurrent streams.
 *
 * Connections are shared in a connection pool. Accesses to the connection's state must be guarded
 * by holding a lock on the connection.
 */
class RealConnection internal constructor(
  val taskRunner: TaskRunner,

                this.canon = "/" + this.share + "/" + StringUtil.join("/", remainParts) + (trailingSlash ? "/" : "");
            } else {
                this.unc = "\\";
                if (this.share != null) {
                    this.canon = "/" + this.share + (trailingSlash ? "/" : "");
                } else {
                    this.canon = "/";
                }

     */
    SmbTransport getTransport();

    /**
     * Connect to the logon share
     *
     * @throws SmbException if the connection fails
     */
    void treeConnectLogon() throws SmbException;

    /**
     * Gets or creates an SMB tree connection for the specified share and service.
     *
     * @param share the share name to connect to
     * @param service the service type for the connection

        assertEquals(path, entryByPath.getPath());
    }

    @Test
    @DisplayName("Should release all leases")
    void testReleaseAll() {
        String path1 = "/share/file1.txt";
        String path2 = "/share/file2.txt";

        Smb2LeaseKey key1 = leaseManager.requestLease(path1, Smb2LeaseState.SMB2_LEASE_READ_CACHING);

        assertTrue(tree.matches("testshare", "TESTSERVICE"));

        // Test matching share with null service
        assertTrue(tree.matches("testShare", null));

        // Test matching share with service starting with "??"
        assertTrue(tree.matches("testShare", "??otherService"));

        // Test non-matching share
        assertFalse(tree.matches("otherShare", "testService"));

        // Test non-matching service

        testImplementation.setFullUNCPath(expectedDomain, "server", "\\\\server\\share\\path");
        assertEquals(expectedDomain, testImplementation.getDomain());
    }

    @Test
    @DisplayName("Test getFullUNCPath returns complete UNC path")
    void testGetFullUNCPath() {
        // Test with mock
        String expectedUNCPath = "\\\\server\\share\\folder\\file.txt";

import jcifs.internal.dtyp.SecurityDescriptor;

/**
 * MSRPC implementation for retrieving share information.
 * This class provides functionality to get detailed information about
 * a specific share using the Server Service RPC interface.
 */
public class MsrpcShareGetInfo extends srvsvc.ShareGetInfo {

    /**
     * Creates a new request to get share information.
     *
     * @param server the server name