*/
    @Test
    @DisplayName("Handle large data size")
    void testLargeDataSize() throws CIFSException {
        // Create a large data array
        byte[] largeData = new byte[1024];
        Arrays.fill(largeData, (byte) 0xFF);

        byte[] avPairData = createAvPairData(0x99, largeData);
        byte[] eolData = createEolData();

    connection.setFixedLengthStreamingMode(1024 * 1024 * 1024) // 1 GB
    connection.connect()
    val out = connection.outputStream
    val data = ByteArray(1024 * 1024)
    var i = 0
    while (i < 1024) {
      try {
        out.write(data)
        out.flush()
        if (i == 513) {
          // pause slightly after halfway to make result more predictable
          Thread.sleep(100)
        }

    /** Account control bit flag: Password does not expire */
    public static final int ACB_PWNOEXP = 512;
    /** Account control bit flag: Account is auto-locked */
    public static final int ACB_AUTOLOCK = 1024;
    /** Account control bit flag: Encrypted text password is allowed */
    public static final int ACB_ENC_TXT_PWD_ALLOWED = 2048;
    /** Account control bit flag: Smart card is required for login */

        this.authMethod = null;
        try (InputStream errorStream = this.connection.getErrorStream()) {
            if (errorStream != null && errorStream.available() != 0) {
                final byte[] buf = new byte[1024];
                while (errorStream.read(buf, 0, 1024) != -1) {
                    ;
                }
            }
            String authHeader;
            if (response == HTTP_UNAUTHORIZED) {

     * the server doesn't respond the web socket will be canceled.
     */
    const val CANCEL_AFTER_CLOSE_MILLIS = 60L * 1000

    /**
     * The smallest message that will be compressed. We use 1024 because smaller messages already
     * fit comfortably within a single ethernet packet (1500 bytes) even with framing overhead.
     *
     * For tests this must be big enough to realize real compression on test messages like

	}
	// Does the bucket name look like an IP address?
	return len(pieces) != 4 || !allNumbers
}

// IsValidObjectName verifies an object name in accordance with Amazon's
// requirements. It cannot exceed 1024 characters and must be a valid UTF8
// string.
//
// See:
// http://docs.aws.amazon.com/AmazonS3/latest/dev/UsingMetadata.html
//
// You should avoid the following characters in a key name because of

   * smaller than a large array. (This assumes that in the lazy case, most stripes are unused. As
   * always, if many stripes are in use, a non-lazy striped makes more sense.)
   */
  private static final int LARGE_LAZY_CUTOFF = 1024;

  private Striped() {}

  /**
   * Returns the stripe that corresponds to the passed key. It is always guaranteed that if {@code
   * key1.equals(key2)}, then {@code get(key1) == get(key2)}.
   *

pkg os (netbsd-arm64-cgo), const O_APPEND = 8
pkg os (netbsd-arm64-cgo), const O_CREATE = 512
pkg os (netbsd-arm64-cgo), const O_EXCL = 2048
pkg os (netbsd-arm64-cgo), const O_SYNC = 128
pkg os (netbsd-arm64-cgo), const O_TRUNC = 1024
pkg os (netbsd-arm64-cgo), const PathListSeparator = 58
pkg os (netbsd-arm64-cgo), const PathSeparator = 47
pkg os (netbsd-arm64), const DevNull = "/dev/null"
pkg os (netbsd-arm64), const O_APPEND = 8

     * @return the batch limit for the given command
     */
    int getBatchLimit(String cmd);

    /**
     *
     * Property {@code jcifs.smb.client.notify_buf_size} (int, default 1024)
     *
     * @return the size of the requested server notify buffer
     */
    int getNotifyBufferSize();

    /**
     *
     *

            assertEquals(64, samr.ACB_DOMTRUST);
            assertEquals(128, samr.ACB_WSTRUST);
            assertEquals(256, samr.ACB_SVRTRUST);
            assertEquals(512, samr.ACB_PWNOEXP);
            assertEquals(1024, samr.ACB_AUTOLOCK);
            assertEquals(2048, samr.ACB_ENC_TXT_PWD_ALLOWED);
            assertEquals(4096, samr.ACB_SMARTCARD_REQUIRED);
            assertEquals(8192, samr.ACB_TRUSTED_FOR_DELEGATION);