StringBuilder sb = new StringBuilder("\\\\server");
            for (int i = 0; i < 1000; i++) {
                sb.append("\\segment");
            }
            String path = sb.toString();

            buffer = new DfsReferralRequestBuffer(path, 3);

            byte[] dst = new byte[buffer.size()];
            int bytesEncoded = buffer.encode(dst, 0);

        when(mockFileInfo.encode(any(byte[].class), anyInt())).thenReturn(50);

        trans2SetFileInfo = new Trans2SetFileInformation(config, TEST_FID, mockFileInfo);

        byte[] setupBuffer = new byte[256];
        byte[] paramBuffer = new byte[256];
        byte[] dataBuffer = new byte[256];

        int setupWritten = trans2SetFileInfo.writeSetupWireFormat(setupBuffer, 0);

                fields.add(new DERTaggedObject(true, 3, new DEROctetString(mechanismListMIC)));
            }
            der.writeObject(new DERTaggedObject(true, 1, new DERSequence(fields)));
            return collector.toByteArray();
        } catch (final IOException ex) {
            throw new IllegalStateException(ex.getMessage());
        }
    }

    @Override

        NetworkInterfaceInfo localInterface = new NetworkInterfaceInfo(addr, 1000);
        NetworkInterfaceInfo remoteInterface = new NetworkInterfaceInfo(addr, 1000);
        ChannelInfo channel = new ChannelInfo("test-channel", mockTransport, localInterface, remoteInterface);

        IOException error = new IOException("Test error");

        // Should not throw exception

        // Arrange
        transPeekNamedPipe = new TransPeekNamedPipe(mockConfig, TEST_PIPE_NAME, TEST_FID);
        String[] results = new String[10];
        Thread[] threads = new Thread[10];

        // Act
        for (int i = 0; i < threads.length; i++) {
            final int index = i;
            threads[i] = new Thread(() -> {
                results[index] = transPeekNamedPipe.toString();

            byte[] originalSalt = new byte[32];
            new Random(42).nextBytes(originalSalt);
            PreauthIntegrityNegotiateContext originalContext =
                    new PreauthIntegrityNegotiateContext(mockConfig, originalHashAlgos, originalSalt);

            int encoded = originalContext.encode(buffer, 0);

            PreauthIntegrityNegotiateContext decodedContext = new PreauthIntegrityNegotiateContext();

        // Test constructor with message and cause
        String message = "Theme configuration error";
        RuntimeException cause = new RuntimeException("Config file not found");
        ThemeException exception = new ThemeException(message, cause);

        assertNotNull(exception);
        assertEquals(message, exception.getMessage());
        assertEquals(cause, exception.getCause());

    assertEquals(expected, new String(buf));
    assertFullyRead(reader);

    // read in chunks to fixed array
    reader = new CharSequenceReader(charSequence);
    buf = new char[5];
    StringBuilder builder = new StringBuilder();
    int read;
    while ((read = reader.read(buf, 0, buf.length)) != -1) {
      builder.append(buf, 0, read);
    }
    assertEquals(expected, builder.toString());

                } catch (IOException e) {
                    throw new RuntimeException(e);
                }
            }
        };
        ComponentUtil.register(dictionaryManager, "dictionaryManager");

        // Create StopwordsFile instance
        stopwordsFile = new StopwordsFile("test_id", testFile.getAbsolutePath(), new Date());
        stopwordsFile.manager(dictionaryManager);
    }

    private static final int MAX_PATH_SIZE = 32767;

    // Statistics
    private final AtomicLong totalValidations = new AtomicLong(0);
    private final AtomicLong failedValidations = new AtomicLong(0);
    private final AtomicLong bufferOverflowsPrevented = new AtomicLong(0);
    private final AtomicLong integerOverflowsPrevented = new AtomicLong(0);

    /**
     * Validate SMB response buffer bounds
     *