}

  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

    @BeforeEach
    void setUp() {
        // Setup will be done per test as needed
    }

    @Test
    void testConstructorWithMinimalParameters() throws UnknownHostException {
        // Test the constructor with minimal parameters
        mockName = new Name(mockConfig, "TESTHOST", 0x20, null);
        NbtAddress nbtAddress = new NbtAddress(mockName, testAddressInt, false, NbtAddress.H_NODE);

        assertNotNull(nbtAddress);

    /**
     * Cache for storing resource file modification timestamps to enable cache busting.
     * The cache expires after 10 minutes and has a maximum size of 1000 entries.
     */
    private static LoadingCache<String, Long> resourceHashCache =
            CacheBuilder.newBuilder().maximumSize(1000).expireAfterWrite(10, TimeUnit.MINUTES).build(new CacheLoader<String, Long>() {

* 🚥 👆 💪 🚫 🤔 ❔, 💭 🌖 **ℹ**.

### 🔬 ⚠

🌅 💼 & 🏆 ❔ 📤 🕳 🔗 👨‍💼 **⏮️ 📟**.

📚 💼 👫 🔜 🕴 📁 🧬 📟, ✋️ 👈 🚫 🥃 **🔬 ⚠**.

* 👆 💪 💭 👫 🚚 <a href="https://stackoverflow.com/help/minimal-reproducible-example" class="external-link" target="_blank">⭐, 🔬, 🖼</a>, 👈 👆 💪 **📁-📋** &amp; 🏃 🌐 👀 🎏 ❌ ⚖️ 🎭 👫 👀, ⚖️ 🤔 👫 ⚙️ 💼 👍.

        assertEquals("Expected structureSize = 17", exception.getMessage());
    }

    @Test
    @DisplayName("Should read valid structure with minimal test")
    void testReadBytesWireFormatBasicStructure() throws Exception {
        // Given - Create a complete SMB2 message with header
        byte[] buffer = new byte[512];
        int headerStart = 0;

            assertArrayEquals(Arrays.copyOfRange(fullData, offset, offset + length), Arrays.copyOfRange(buffer, 48, 48 + length));
        }

        @Test
        @DisplayName("Should handle maximum values correctly")
        void testMaximumValues() {
            request.setOffset(Long.MAX_VALUE);
            request.setRemainingBytes(Integer.MAX_VALUE);
            request.setWriteFlags(Integer.MAX_VALUE);

     */
    public Map<Smb2LeaseKey, LeaseEntry> getAllLeases() {
        return new ConcurrentHashMap<>(leases);
    }

    /**
     * Clean up expired leases
     *
     * @param maxAgeMillis maximum age in milliseconds
     * @return number of leases cleaned up
     */
    public int cleanupExpiredLeases(long maxAgeMillis) {
        lock.writeLock().lock();
        try {

            // Then
            assertNotNull(result);
            assertEquals(transport, result);
        }

        @Test
        @DisplayName("Should handle maximum port value")
        void testMaxPortValue() {
            // Given
            int maxPort = 65535;
            when(transportPool.getSmbTransport(context, address, maxPort, false)).thenReturn(transport);

    }

    @Test
    @DisplayName("getInput/getOutput return cached streams when open; throw when closed")
    void getInputOutput_caching_and_closed() throws Exception {
        // Arrange: minimal stubs so stream construction works
        SmbPipeHandleImpl handle = newHandleWithBasicStubs(0, "\\\\pipe\\\\foo");
        when(pipe.ensureTreeConnected()).thenReturn(tree);
        when(tree.acquire()).thenReturn(tree);

    /**
     * Initializes the CrawlingConfigHelper by setting up the crawling configuration cache.
     * This method is called automatically after the bean construction is complete.
     * The cache is configured with a maximum size of 100 entries and expires after 10 minutes.
     */
    @PostConstruct
    public void init() {
        if (logger.isDebugEnabled()) {
            logger.debug("Initialize {}", this.getClass().getSimpleName());