public long getTimestamp() {
            return timestamp;
        }

        /**
         * Sets the notification timestamp.
         *
         * @param timestamp the timestamp value in FILETIME format (100-nanosecond intervals since January 1, 1601 UTC)
         */
        public void setTimestamp(long timestamp) {
            this.timestamp = timestamp;
        }

        /**

    void testWriteParametersWireFormatWithOffset() {
        trans2QueryFSInfo = new Trans2QueryFSInformation(config, FileSystemInformation.SMB_INFO_ALLOCATION);

        byte[] buffer = new byte[512];
        int offset = 100;
        int written = trans2QueryFSInfo.writeParametersWireFormat(buffer, offset);

        // Should write 2 bytes at offset
        assertEquals(2, written);

        // Check information level at offset

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

        byte[] buffer = new byte[512];
        int offset = 100;
        int written = trans2SetFileInfo.writeDataWireFormat(buffer, offset);

        // Should write FileInformation data + 6 bytes padding
        assertEquals(36, written); // 30 + 6

        if (text == null || fromText == null || toText == null) {
            return null;
        }
        final StringBuilder buf = new StringBuilder(100);
        int pos = 0;
        int pos2 = 0;
        while (true) {
            pos = text.indexOf(fromText, pos2);
            if (pos == 0) {
                buf.append(toText);

    /** Maximum number of retry attempts for failed operations */
    protected int maxRetryCount = 5;

    /** Default number of rows to process in a single batch */
    protected int defaultRowSize = 100;

    /**
     * Default constructor for indexing helper.
     * Creates a new instance with default values.
     */
    public IndexingHelper() {
        // Default constructor
    }

     */
    protected void writeJsonResponse(final int status, final Throwable t) {
        final Supplier<String> stacktraceString = () -> {
            final StringBuilder buf = new StringBuilder(100);
            if (StringUtil.isBlank(t.getMessage())) {
                buf.append(t.getClass().getName());
            } else {
                buf.append(t.getMessage());
            }

        final Set<String> highlightQueries = (Set<String>) params.getAttribute(Constants.HIGHLIGHT_QUERIES);
        if (highlightQueries != null) {
            final StringBuilder buf = new StringBuilder(100);
            highlightQueries.stream().forEach(q -> {
                buf.append("&hq=").append(LaFunctions.u(q));
            });
            data.setAppendHighlightParams(buf.toString());
        }

import org.junit.jupiter.params.provider.ValueSource;

/**
 * Comprehensive test class for ACE interface constants and behavior.
 * Tests all constants, bitwise operations, and interface methods.
 * Achieves 100% coverage of the ACE interface contract.
 */
@DisplayName("ACE Interface Comprehensive Tests")
class ACETest {

    @Nested
    @DisplayName("File Access Constants Tests")
    class FileAccessConstantsTests {

        request = new Smb2QueryInfoRequest(mockConfig);

        // Set an input buffer using reflection
        Encodable mockInputBuffer = mock(Encodable.class);
        when(mockInputBuffer.size()).thenReturn(100);

        try {
            Field inputBufferField = Smb2QueryInfoRequest.class.getDeclaredField("inputBuffer");
            inputBufferField.setAccessible(true);

     * If true, read a content as a text when an extraction fails.
     */
    protected boolean readAsTextIfFailed = false;

    /**
     * Max compression ratio.
     */
    protected long maxCompressionRatio = 100;

    /**
     * Max uncompression size.
     */
    protected long maxUncompressionSize = 1000000;

    /**
     * Initial buffer size.
     */
    protected int initialBufferSize = 10000;