}

// Test canceling context while quorum servers report lock not found
func TestFailedRefreshLock(t *testing.T) {
	if testing.Short() {
		t.Skip("skipping test in short mode.")
	}

	// Simulate Refresh response to return no locking found
	for i := range lockServers[:3] {
		lockServers[i].setRefreshReply(false)
		defer lockServers[i].setRefreshReply(true)
	}

	dm := NewDRWMutex(ds, "aap")

        CIFSContext ctx = mock(CIFSContext.class);
        SmbTreeConnectionTrace trace = Mockito.spy(new SmbTreeConnectionTrace(ctx));

        // Act: directly invoke finalize to simulate GC finalization path
        trace.finalize();

        // Assert: verify that finalize delegated to checkRelease()
        verify(trace, times(1)).checkRelease();
    }

    @Test

            // Host is empty -> triggers master browser path
            URL anyUrlWithEmptyHost = new URL("file:/");
            when(locator.getURL()).thenReturn(anyUrlWithEmptyHost);
            // Simulate failure to find master browser (UnknownHost wrapped in CIFSException)
            when(locator.getAddress()).thenThrow(new CIFSException("no master", new UnknownHostException("MB")));

        }

        @Override
        protected FileEntry open() throws CIFSException {
            if (staticThrowOnOpen)
                throw new CIFSException("open fail");
            // Simulate fetching first page during open
            if (staticPages != null && !staticPages.isEmpty()) {
                pageIdx = 0;
            }
            // Return the initial element if provided

            byte[] buffer1 = new byte[10];
            byte[] buffer2 = new byte[10];
            SMBUtil.writeInt2(4, buffer1, 0);
            SMBUtil.writeInt2(4, buffer2, 0);

            // When - simulate concurrent access
            Thread thread1 = new Thread(() -> {
                try {
                    response.readBytesWireFormat(buffer1, 0);
                } catch (SMBProtocolDecodingException e) {

        FileSystemClient client = new FileSystemClient() {
            @Override
            protected ResponseData getResponseData(final String uri, final boolean includeContent) {
                // Simulate quick completion before timeout
                ResponseData responseData = new ResponseData();
                responseData.setHttpStatusCode(200);
                return responseData;
            }
        };

 * that is already in the desired state.
 *
 * <p>When testing code that uses this class, use {@link #createUnstarted(Ticker)} or {@link
 * #createStarted(Ticker)} to supply a fake or mock ticker. This allows you to simulate any valid
 * behavior of the stopwatch.
 *
 * <p><b>Note:</b> This class is not thread-safe.
 *
 * <p><b>Warning for Android users:</b> a stopwatch with default behavior may not continue to keep

        assertEquals(0, transport.getNumSessions());
    }

    @Test
    @DisplayName("isDisconnected / isFailed reflect socket and state")
    void connectionStateChecks() throws Exception {
        // Arrange: simulate connected state and open socket
        setField(transport, "state", 3); // connected
        Socket s = mock(Socket.class);
        when(s.isClosed()).thenReturn(false);
        setField(transport, "socket", s);

        void urlParameterParsing() {
            String expectedUrl = "smb://server/share/test.txt";
            TestLocking t = new TestLocking();

            // Simulate argument parsing
            String[] args = { "-t", "2", "-i", "5", "-d", "100", expectedUrl };
            for (int ai = 0; ai < args.length; ai++) {
                if (args[ai].equals("-t")) {
                    ai++;

import jcifs.Configuration;
import jcifs.NameServiceClient;
import jcifs.NetbiosAddress;
import jcifs.smb.NtlmPasswordAuthentication;

/**
 * JUnit 5 tests for the NtlmSsp class.
 * This class uses Mockito to simulate HttpServletRequest and HttpServletResponse objects.
 */
@ExtendWith(MockitoExtension.class)
public class NtlmSspTest {

    @Mock
    private CIFSContext mockCifsContext;

    @Mock