assertEquals(65535, decodedSize);
        assertEquals(65535, referral.getSize());
        assertEquals(65535, referral.getServerType());
        assertEquals(65535, referral.getRFlags());
        assertEquals(65535, referral.getProximity());
        assertEquals(65535, referral.getTtl());
    }

    @Test
    public void testEmptyStrings() {

        when(locator.getUNCPath()).thenReturn("\\\\server\\share\\dir\\");
        when(tree.getConfig()).thenReturn(config);
        when(config.getMaximumBufferSize()).thenReturn(65535);
        when(config.getListSize()).thenReturn(65535);

        // Arrange: initial page with two entries, then one more entry, then no more files
        FileEntry fe1 = mock(FileEntry.class);
        lenient().when(fe1.getName()).thenReturn("file1");

    checkFromStringCase("192.0.2.2:83", -1, "192.0.2.2", 83, true);
    checkFromStringCase("[2001::2]:85", -1, "2001::2", 85, true);
    checkFromStringCase("goo.gl:65535", 65536, "goo.gl", 65535, true);
    // No port, bad default.
    checkFromStringCase("google.com", -1, "google.com", -1, false);
    checkFromStringCase("192.0.2.1", 65536, "192.0.2.1", -1, false);

    private Trans2FindFirst2 trans2FindFirst2;

    @BeforeEach
    void setUp() {
        MockitoAnnotations.openMocks(this);
        when(mockConfig.getMaximumBufferSize()).thenReturn(65535);
        when(mockConfig.getTransactionBufferSize()).thenReturn(65535);
        when(mockConfig.isUseUnicode()).thenReturn(true);
        when(mockConfig.isForceUnicode()).thenReturn(false);
        when(mockConfig.getOemEncoding()).thenReturn("ASCII");
    }

    @Test
    void testLargeBatchParameters() {
        // Test with maximum allowed values
        int maxSid = 0xFFFF;
        int maxResumeKey = 0x7FFFFFFF;
        int maxBatchCount = 65535;
        int maxBatchSize = 65535;

        trans2FindNext2 = new Trans2FindNext2(config, maxSid, maxResumeKey, TEST_FILENAME, maxBatchCount, maxBatchSize);

        byte[] buffer = new byte[512];

        // init(th) behavior inside SmbFileInputStream constructor
        when(tree.isSMB2()).thenReturn(smb2);
        when(tree.getReceiveBufferSize()).thenReturn(4096);
        when(tree.getMaximumBufferSize()).thenReturn(65535);
        when(tree.hasCapability(anyInt())).thenReturn(false);
        return new SmbPipeInputStream(handle, tree);
    }

    private SmbPipeInputStream newStreamWithMinimalStubs(boolean smb2) throws CIFSException {

        // Test with small data count
        response.setDataCount(10);
        assertEquals(10, response.getDataCount());

        // Test with large data count
        response.setDataCount(65535);
        assertEquals(65535, response.getDataCount());

        // Test with zero data count
        response.setDataCount(0);
        assertEquals(0, response.getDataCount());
    }

    @Test

        assertEquals("Structure size != 4", ex1.getMessage());

        // Test maximum 2-byte value (65535)
        SMBUtil.writeInt2(65535, buffer, 0);

        SMBProtocolDecodingException ex2 = assertThrows(SMBProtocolDecodingException.class, () -> response.readBytesWireFormat(buffer, 0));

      builder.append(':').append(port);
    }
    return builder.toString();
  }

  /** Return true for valid port numbers. */
  private static boolean isValidPort(int port) {
    return port >= 0 && port <= 65535;
  }

  @GwtIncompatible @J2ktIncompatible private static final long serialVersionUID = 0;

        // Set excessive negotiate context count (writeInt2(-1) becomes 65535)
        SMBUtil.writeInt2(-1, buffer, 6);

        SMBProtocolDecodingException exception = assertThrows(SMBProtocolDecodingException.class, () -> {
            response.readBytesWireFormat(buffer, 0);
        });

        assertTrue(exception.getMessage().contains("Invalid negotiate context count: 65535"));
    }

    /**