/**
         * Waits for the crawling thread to terminate within a specified time limit.
         * This method blocks until the thread completes or the timeout expires.
         *
         * @param mills maximum time to wait in milliseconds
         */
        public void awaitTermination(final long mills) {
            try {
                join(mills);
            } catch (final InterruptedException e) {

            request.writeBytesWireFormat(smallBuffer, 0);
        });
    }

    @Test
    @DisplayName("Test file ID boundary values")
    void testFileIdBoundaryValues() {
        // Test with file ID having maximum byte values
        byte[] maxFileId = new byte[16];
        Arrays.fill(maxFileId, (byte) 0xFF);
        Smb2CloseRequest maxRequest = new Smb2CloseRequest(mockConfig, maxFileId, testFileName);

        assertNotNull(response.getNotifyInformation());
        assertTrue(response.getNotifyInformation().isEmpty());
    }

    @Test
    @DisplayName("Should handle maximum buffer size")
    void testMaximumBufferSize() throws Exception {
        // Given - large buffer with many notifications
        byte[] buffer = new byte[65536];
        int offset = 0;

  private const val PREFIX_6_BITS = 0x3f
  private const val PREFIX_7_BITS = 0x7f

  private const val SETTINGS_HEADER_TABLE_SIZE = 4_096

  /**
   * The decoder has ultimate control of the maximum size of the dynamic table but we can choose
   * to use less. We'll put a cap at 16K. This is arbitrary but should be enough for most purposes.
   */
  private const val SETTINGS_HEADER_TABLE_SIZE_LIMIT = 16_384

            request.setEncodedSize(16);
            int result3 = request.encode(buffer, 240);
            assertEquals(16, result3);
        }

        @Test
        @DisplayName("Should handle maximum name length")
        void testMaximumNameLength() {
            byte[] maxName = new byte[65536]; // 64KB
            Arrays.fill(maxName, (byte) 'M');

     * Encodes a String as UTF-8 bytes.
     *
     * @param str the String to encode
     * @param dst the destination byte array
     * @param di the starting index in the destination array
     * @param dlim the maximum index in the destination array
     * @return the number of bytes written
     */
    public static int enc_utf8(final String str, final byte[] dst, int di, final int dlim) {
        final int start = di;
        int ch;

        this.includeStackTrace = enable;
    }

    /**
     * Set minimum log level
     *
     * @param level minimum severity level to log
     */
    public void setMinLogLevel(Severity level) {
        this.minLogLevel = level;
        log.info("Minimum log level set to {}", level);
    }

    /**
     * Enable or disable asynchronous logging
     *

        assertTrue(addr.isActive);
        assertTrue(addr.isPermanent);
    }

    @Test
    void readRDataWireFormat_shouldHandleMultipleNames() throws Exception {
        // Test with maximum reasonable number of names
        int numNames = 10;
        int dataLength = 1 + (18 * numNames) + 6 + 6;
        byte[] src = new byte[dataLength];
        int srcIndex = 0;

                if (maxDate && end.isAfter(maxDate))
                    end = maxDate.clone();

                // If the end of the range is before the minimum or the start of the range is
                // after the maximum, don't display this range option at all.
                if ((this.minDate && end.isBefore(this.minDate, this.timepicker ? 'minute' : 'day'))

  }

  private static final Object NOT_FOUND = new Object();

  /**
   * Maximum allowed false positive probability of detecting a hash flooding attack given random
   * input.
   */
  @VisibleForTesting(
      )
  static final double HASH_FLOODING_FPP = 0.001;

  /**
   * Maximum allowed length of a hash table bucket before falling back to a j.u.LinkedHashMap-based