assertEquals(testDialect, response.getDialect(), "Dialect should match");
    }

    @Test
    @DisplayName("Test decode returns correct bytes consumed")
    void testDecodeBytesConsumed() throws SMBProtocolDecodingException {
        // Prepare minimal buffer
        byte[] buffer = new byte[24];

        // Test with offset 0

 * </pre>
 * the access check would fail because the direct ACE has an access mask
 * of <code>0x001200A9</code> which doesn't have the
 * <code>FILE_WRITE_DATA</code> bit on (bit <code>0x00000002</code>). Actually, this isn't quite correct. If
 * <code>WNET\alice</code> is in the local <code>Administrators</code> group the access check
 * will succeed because the inherited ACE allows local <code>Administrators</code>

            assertTrue(e.getCause() instanceof InterruptedException);
        }
    }

    public void test_directory_child_urls() throws Exception {
        // Test that childUri (not typo chileUri) is correctly used in directory listing
        FtpServer server = null;
        try {
            String username = "testuser";
            String password = "testpass";

        String id = "test-id";
        SuggestSettings settings = builder.build(client, id);

        assertNotNull(settings);
        // Verify that the settings object was created with the correct parameters
        // Note: We can't directly verify internal state of SuggestSettings without getters,
        // but we can verify it was created successfully
    }

    @Test

        assertEquals(
                Path.of("src/main/resources3").toString(), resourcesAfter.get(2).getDirectory());

        // Verify the modification was applied to the correct resource
        assertTrue(
                resourcesAfter.get(1).getIncludes().contains("*.properties"),
                "Middle resource should have the include");

```

#### 3.2.3 Generate a self-signed certificate

Create a file named `openssl.conf` with the content below. Set `IP.1` and/or `DNS.1` to point to the correct IP/DNS addresses:

```sh
[req]
distinguished_name = req_distinguished_name
x509_extensions = v3_req
prompt = no

[req_distinguished_name]
C = US
ST = VA
L = Somewhere
O = MyOrg

        }
    }

    @Nested
    @DisplayName("Resource Unwrapping Tests")
    class ResourceUnwrappingTest {

        @Test
        @DisplayName("Should provide unwrap method with correct signature")
        void shouldProvideUnwrapMethod() {
            assertDoesNotThrow(() -> {
                java.lang.reflect.Method unwrapMethod = SmbSession.class.getMethod("unwrap", Class.class);

        // Execute
        service.generateUrlQueues(previousSessionId, sessionId);

        // Verify
        assertEquals(2, newQueue.size());

        // Verify the generated queues have correct properties
        List<UrlQueueImpl<Long>> queueList = new ArrayList<>(newQueue);
        boolean foundPage1 = false;
        boolean foundPage2 = false;

        for (UrlQueueImpl<Long> queue : queueList) {

                msg.decode_header(fbuf);
                stub_frag_len = msg.length - 24;

                if (off + stub_frag_len > stub.length) {
                    // shouldn't happen if alloc_hint is correct or greater
                    final byte[] tmp = new byte[off + stub_frag_len];
                    System.arraycopy(stub, 0, tmp, 0, off);
                    stub = tmp;
                }

storage class by setting `x-amz-storage-class=STANDARD/REDUCED_REDUNDANCY` for each object uploads so effectively utilizing the capacity of the cluster. Additionally these can also be enforced using IAM policies to make sure the client uploads with correct HTTP headers.

- MinIO also supports expansion of existing clusters in server pools. Each pool is a self contained entity with same SLA's (read/write quorum) for each object as original cluster. By using the existing namespace for lookup...