while (!data.exhausted()) {
      assertFailsWith<ProtocolException> {
        clientReader.processNextFrame()
      }.also { expected ->
        assertThat(expected.message!!)
          .matches(Regex("Code \\d+ is reserved and may not be used."))
      }
      count++
    }
    assertThat(count).isEqualTo(1988)
  }

  @Test fun clientWithCompressionCannotBeUsedAfterClose() {

        buffer[index++] = (byte) ((messageSize >> 8) & 0xFF);
        buffer[index++] = (byte) ((messageSize >> 16) & 0xFF);
        buffer[index++] = (byte) ((messageSize >> 24) & 0xFF);

        // Reserved (2 bytes)
        buffer[index++] = 0;
        buffer[index++] = 0;

        // Flags (2 bytes) - little-endian
        int flags = 0x0001;
        buffer[index++] = (byte) (flags & 0xFF);

/* Copyright 2020 The TensorFlow Authors. All Rights Reserved.

Licensed under the Apache License, Version 2.0 (the "License");
you may not use this file except in compliance with the License.
You may obtain a copy of the License at

    http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software
distributed under the License is distributed on an "AS IS" BASIS,

        #
        # NB: a `for` loop captures its iteration list before it begins, so
        # changing the positional parameters here affects neither the number of
        # iterations, nor the values presented in `arg`.
        shift                   # remove old arg
        set -- "$@" "$arg"      # push replacement arg
    done
fi

    private var lastModifiedString: String? = null

    /**
     * The expiration date of the cached response, if known. If both this field and the max age are
     * set, the max age is preferred.
     */
    private var expires: Date? = null

    /**
     * Extension header set by OkHttp specifying the timestamp when the cached HTTP request was
     * first initiated.
     */

}

// sortIPs - sort ips based on higher octets.
// The logic to sort by last octet is implemented to
// prefer CIDRs with higher octets, this in-turn skips the
// localhost/loopback address to be not preferred as the
// first ip on the list. Subsequently this list helps us print
// a user friendly message with appropriate values.
func sortIPs(ipList []string) []string {
	if len(ipList) == 1 {
		return ipList
	}

        request.setDesiredAccess(access);

        byte[] buffer = new byte[1024];
        request.writeBytesWireFormat(buffer, 0);

        // Read desired access from buffer (offset 24-27 after 8 bytes reserved)
        int readAccess = (buffer[24] & 0xFF) | ((buffer[25] & 0xFF) << 8) | ((buffer[26] & 0xFF) << 16) | ((buffer[27] & 0xFF) << 24);
        assertEquals(access, readAccess);
    }

    @Test

/* Copyright 2020 The TensorFlow Authors. All Rights Reserved.

Licensed under the Apache License, Version 2.0 (the "License");
you may not use this file except in compliance with the License.
You may obtain a copy of the License at

    http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software
distributed under the License is distributed on an "AS IS" BASIS,

 */

public final class NbtAddress implements NetbiosAddress {

    /**
     * This is a special name that means all hosts. If you wish to find all hosts
     * on a network querying a workgroup group name is the preferred method.
     */
    public static final String ANY_HOSTS_NAME =
            "*\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000";

    /**

            // Should handle encoding at the end of buffer correctly
            assertDoesNotThrow(() -> context.encode(smallBuffer, 4));
        }

        @Test
        @DisplayName("Should preserve data integrity through encode/decode cycle")
        void testDataIntegrity() throws SMBProtocolDecodingException {
            // Create complex test data
            int[] hashAlgos = new int[20];