*
     * @param expectTag the expected tag number
     * @param limit the maximum length limit
     * @param in the ASN.1 input stream
     * @return coded bytes of the tagged object
     * @throws IOException if reading fails or tag mismatch
     */
    public static byte[] readUnparsedTagged(final int expectTag, final int limit, final ASN1InputStream in) throws IOException {
        final int ftag = in.read();

        }

        // Check global rate limit
        if (!checkGlobalRateLimit()) {
            totalAttemptsBlocked.incrementAndGet();
            log.warn("Global rate limit exceeded, blocking attempt from {}", sourceIp);
            return false;
        }

        // Check per-account limit
        if (username != null) {

        }

        // Reasonable upper limit (1TB)
        long maxSize = 1099511627776L;
        if (size > maxSize) {
            failedValidations.incrementAndGet();
            log.warn("File size exceeds reasonable limit: {} > {}", size, maxSize);
            throw new SmbException("File size exceeds limit: " + size);
        }
    }

    /**

            assertTrue("Error message should mention file size", e.getMessage().contains("File too large"));
        }
    }

    /**
     * Test readBytes with file within size limit
     *
     * @throws Exception
     */
    @Test
    public void testReadBytes_NormalFile() throws Exception {
        final File normalFile = tempFolder.newFile("normal.txt");

public class LhaExtractor extends AbstractExtractor {
    /** Logger for this class. */
    private static final Logger logger = LogManager.getLogger(LhaExtractor.class);

    /** Maximum content size for extraction. -1 means no limit. */
    protected long maxContentSize = -1;

    /**
     * Creates a new LhaExtractor instance.
     */
    public LhaExtractor() {
        super();
    }

    /**

    @DisplayName("Should not reuse connection when session limit reached")
    void testSessionLimitPreventsReuse() throws Exception {
        // Given: Config with session limit of 1
        when(config.getSessionLimit()).thenReturn(1);

        // Create first connection
        SmbTransportImpl first = pool.getSmbTransport(ctx, address, 445, false);

        // Mock that session limit is reached

    @DisplayName("writeAndXWireFormat with andx but batching prevented by limit")
    void testWriteAndXWireFormatBatchingPrevented() {
        DummyPlainSMB next = new DummyPlainSMB();
        DummyAndXBlock block = new DummyAndXBlock(next);
        block.customBatchLimit = 1; // allow 1, but we'll set batchLevel to meet limit
        block.batchLevel = 1; // batchLevel >= limit prevents chaining

        byte[] buf = new byte[128];

    }

    /**
     * Set the key rotation bytes limit
     *
     * @param limit number of bytes to encrypt before rotating keys
     */
    public void setKeyRotationBytesLimit(long limit) {
        this.keyRotationBytesLimit = limit;
    }

    /**
     * Set the key rotation time limit
     *
     * @param limit time in milliseconds before rotating keys
     */

        req.txn_buf = getBuffer();
        rsp.txn_buf = getBuffer();
    }

    /**
     * Returns a buffer to the cache for reuse.
     *
     * Performance: O(1) operation with size limit check
     *
     * @param buf the buffer to return to the cache
     */
    static public void releaseBuffer(final byte[] buf) {
        // Validate buffer before returning to cache

                return Collections.emptyList();
            }

            List<String> readings = new ArrayList<>();
            int limit = Math.min(langs.length, getMaxReadingNum());

            for (int i = 0; i < limit; i++) {
                readings.add(text.toUpperCase() + "_" + langs[i]);
            }

            return readings;
        }
    }