// Validate buffer before returning to cache
        if (buf == null || buf.length != SmbComTransaction.TRANSACTION_BUF_SIZE) {
            return; // Silently ignore invalid buffers
        }

        // Only cache if we haven't reached the limit - O(1) check
        if (queueSize.get() < MAX_BUFFERS) {
            if (bufferQueue.offer(buf)) { // O(1) operation
                queueSize.incrementAndGet();
            }
        }

    /** requestedAt */
    protected LocalDateTime requestedAt;

    /** url */
    protected String url;

    /** userSessionId */
    protected String userSessionId;

    // [Referrers] *comment only

    // ===================================================================================
    //                                                                             DB Meta

            assertEquals(0, SMBUtil.readInt2(buffer, 2)); // Lock count
            assertArrayEquals(testFileId, Arrays.copyOfRange(buffer, 8, 24));
            assertEquals(24, bytesWritten); // Only structure, no locks
        }

        @Test
        @DisplayName("Should write at different buffer positions")
        void testWriteAtDifferentPositions() {
            byte[] buffer = new byte[512];

    /** targetRole */
    protected String targetRole;

    /** updatedBy */
    protected String updatedBy;

    /** updatedTime */
    protected Long updatedTime;

    // [Referrers] *comment only

    // ===================================================================================
    //                                                                             DB Meta

        this.cfg = new BaseConfiguration(true);
    }

    /**
     * Sub-class of {@link BaseConfiguration} that forces {@code useUnicode()}
     * to return {@code false}. This mimics an ASCII only client
     */
    private static class OffUnicodeConfig extends BaseConfiguration {
        public OffUnicodeConfig() throws Exception {
            super(true);
        }

        @Override

                    throw new SmbException(ie.getMessage(), ie);
                }
            }
            connectionState = 1; // trying ...

            try {
                /* The hostname to use in the path is only known for
                 * sure if the NetBIOS session has been successfully
                 * established.
                 */

                session.transport.connect();

        assertEquals("true", returned.get("storeKey"));
        assertEquals("******@****.***", returned.get("principal"));
        // Ensure no unexpected extra options
        assertEquals(3, returned.size(), "Only provided options are expected");
    }

    @Test
    @DisplayName("Null options cause IllegalArgumentException when retrieving entries (JAAS requires non-null options)")
    void nullOptions_throwOnAccess() {

                try (ObjectInputStream ois = new ObjectInputStream(Files.newInputStream(handleFile))) {
                    HandleInfo info = (HandleInfo) ois.readObject();

                    // Only load if not expired
                    if (!info.isExpired()) {
                        handles.put(info.getPath(), info);
                        guidToHandle.put(info.getCreateGuid(), info);

    /**
     * Creates a new EditForm instance.
     */
    public EditForm() {
        // Default constructor
    }

    /**
     * Enable or disable incremental crawling.
     * When enabled, only new or modified documents are crawled.
     */
    @Size(max = 10)
    public String incrementalCrawling;

    /**
     * Number of days to keep crawled documents before cleanup.

                rows.add(fields);
                dataRowCount++;
            }

            if (dataRowCount >= maxRows && logger.isDebugEnabled()) {
                logger.debug("CSV file exceeded max rows ({}), only first {} data rows extracted", maxRows, dataRowCount);
            }

            return buildExtractData(headers, rows);
        } catch (final IOException e) {