}

        // Decode
        int bytesDecoded = smbInfoAllocation.decode(buffer, 0, buffer.length);

        // Verify we read exactly 20 bytes (4 + 4 + 4 + 4 + 4)
        // Note: bytesPerSect is read as Int2 but 4 bytes are consumed (padding)
        assertEquals(20, bytesDecoded);
    }

    @Test
    @DisplayName("Test capacity calculation overflow handling")

                            || initialState == RdmaConnection.RdmaConnectionState.CONNECTING,
                    "Initial state should be DISCONNECTED or CONNECTING");

            // Test connection properties
            // Note: Local address may be null for TCP fallback provider
            InetSocketAddress localAddr = connection.getLocalAddress();
            if (localAddr != null) {
                System.out.println("Local address: " + localAddr);

     */
    @Test
    public void testEncryptionContextPerformance() throws Exception {
        // Create mock encryption context for testing (simplified)
        // Note: This tests the atomic operations without actual encryption

        int threadCount = 8;
        int operationsPerThread = 500;
        ExecutorService executor = Executors.newFixedThreadPool(threadCount);

     * the key would be inserted into the list: the index of the next higher element in the list, or
     * {@code list.size()} if there is no such element.
     *
     * <p>Note that the return value will be {@code >= 0} if and only if there is an element of the
     * list that compares as equal to the key.
     *

   * to dump the queue into a newly allocated array of {@code String}:
   *
   * <pre>
   *     String[] y = x.toArray(new String[0]);</pre>
   *
   * <p>Note that {@code toArray(new Object[0])} is identical in function to {@code toArray()}.
   *
   * @param a the array into which the elements of the queue are to be stored, if it is big enough;

        @Test
        @DisplayName("Should handle read request with RDMA channel")
        void testReadRequestWithRdmaChannel() {
            request.setReadLength(65536);
            request.setOffset(0L);
            // Note: channel is private and not settable via public API
            // This test documents that channel defaults to SMB2_CHANNEL_NONE

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

            assertTrue(ACE.GENERIC_EXECUTE < ACE.GENERIC_WRITE, "GENERIC_EXECUTE should be less than GENERIC_WRITE");
            // Note: GENERIC_READ (0x80000000) is negative, so it's less than positive values in signed comparison
            assertTrue(ACE.GENERIC_WRITE > 0 && ACE.GENERIC_READ < 0, "GENERIC_WRITE is positive, GENERIC_READ is negative");
        }

   * {@code iterator().remove()} of an unmodifiable list could throw either {@link
   * IllegalStateException} or {@link UnsupportedOperationException}. Note that iterator
   * implementations should always throw one of the exceptions in a {@code PermittedExceptions}
   * instance, since {@code PermittedExceptions} is thrown only when a method call is invalid.
   *

          ToIntFunction<? super T> countFunction) {
    return CollectCollectors.toImmutableMultiset(elementFunction, countFunction);
  }

  /**
   * Returns the empty immutable multiset.
   *
   * <p><b>Performance note:</b> the instance returned is a singleton.
   */
  @SuppressWarnings("unchecked") // all supported methods are covariant
  public static <E> ImmutableMultiset<E> of() {

        }

        /*
         * if there is an andx and it itself is an andx then just recur by
         * calling this method for it. otherwise just read it's parameter words
         * and bytes as usual. Note how we can't just call andx.readWireFormat
         * because there's no header.
         */

        if (this.errorCode != 0 || this.andxCommand == (byte) 0xFF) {
            this.andxCommand = (byte) 0xFF;