assertDoesNotThrow(() -> new Smb2WriteRequest(mockConfig, emptyFileId));
        }
    }

    @Nested
    @DisplayName("FileId Tests")
    class FileIdTests {

        @Test
        @DisplayName("Should set file ID correctly")
        void testSetFileId() {
            byte[] newFileId = new byte[16];
            new SecureRandom().nextBytes(newFileId);

            assertDoesNotThrow(() -> request.setFileId(newFileId));

            assertDoesNotThrow(() -> new Smb2LockRequest(mockConfig, testFileId, null));
        }
    }

    @Nested
    @DisplayName("FileId Tests")
    class FileIdTests {

        @Test
        @DisplayName("Should set file ID correctly")
        void testSetFileId() {
            byte[] newFileId = new byte[16];
            new SecureRandom().nextBytes(newFileId);

        // 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");
        lenient().when(fe1.getFileIndex()).thenReturn(1);

        FileEntry fe2 = mock(FileEntry.class);
        lenient().when(fe2.getName()).thenReturn("file2");
        when(fe2.getFileIndex()).thenReturn(2);

            assertEquals(0x2, Smb2ReadRequest.SMB2_CHANNEL_RDMA_V1_INVALIDATE);
        }
    }

    @Nested
    @DisplayName("FileId Tests")
    class FileIdTests {

        @Test
        @DisplayName("Should set file ID correctly")
        void testSetFileId() {
            byte[] newFileId = new byte[16];
            new SecureRandom().nextBytes(newFileId);

        }
    }
    
    public void handleFailure(ChannelInfo failedChannel, Exception error) {
        log.warn("Channel {} failed: {}", failedChannel.getChannelId(), error.getMessage());
        
        // Mark channel as failed
        failedChannel.setState(ChannelState.FAILED);
        
        // Get or create failover state
        FailoverState state = failoverStates.computeIfAbsent(

                throw (IOException) e.getCause();
            }
            throw new IOException("Connection failed", e);
        } catch (Exception e) {
            // Handle any other exceptions from circuit breaker
            throw new IOException("Connection failed", e);
        }
    }

    private void doConnectInternal() throws IOException {
        /*

        Files.createDirectory(dir1);
        Files.writeString(dir1.resolve("file2.txt"), "file2");
        Path dir2 = dir1.resolve("dir2");
        Files.createDirectory(dir2);
        Files.writeString(dir2.resolve("file3.txt"), "file3");
        Path dir3 = usersDir.resolve("dir3");
        Files.createDirectory(dir3);
        Files.writeString(dir3.resolve("file4.txt"), "file4");

        // Setup public directory files

                .build(), "file2".getBytes());

        storage.create(BlobInfo.newBuilder(BlobId.of(bucketName, "dir1/dir2/file3.txt"))//
                .setContentType("application/octet-stream")//
                .setMetadata(Map.of("label", "label3"))//
                .build(), "file3".getBytes());

        storage.create(BlobInfo.newBuilder(BlobId.of(bucketName, "dir3/file4.txt"))//

                .object("file1.txt")
                .stream(new ByteArrayInputStream("file1".getBytes()), 5, -1)
                .contentType("application/octet-stream")
                .build());
        minioClient.putObject(PutObjectArgs.builder()
                .bucket(bucketName)
                .object("dir1/file2.txt")
                .stream(new ByteArrayInputStream("file2".getBytes()), 5, -1)

import static org.junit.jupiter.api.Assertions.assertThrows;
import static org.junit.jupiter.api.Assertions.fail;

import java.io.IOException;
import java.lang.reflect.Field;
import java.nio.file.Files;
import java.nio.file.Path;
import java.util.Properties;

import org.junit.jupiter.api.AfterEach;
import org.junit.jupiter.api.BeforeEach;
import org.junit.jupiter.api.Test;
import org.junit.jupiter.api.io.TempDir;