return Stream.of(Arguments.of(0x1234, 0L, new byte[] { 0x34, 0x12, (byte) 0xFF, (byte) 0xFF, (byte) 0xFF, (byte) 0xFF }),
                // negative fid wraps around, lastWriteTime = 1000 -> 1 second -> int value 1
                Arguments.of(-1, 1000L, new byte[] { (byte) 0xFF, (byte) 0xFF, 0x01, 0x00, 0x00, 0x00 }));
    }

    /**
     * When lastWriteTime is zero the encoded unsigned time must be all 1s.
     */
    @Test

        when(mockTimeZone.inDaylightTime(any(Date.class))).thenReturn(true);
        SMB1SigningDigest.writeUTime(mockConfig, testTime, dst, 0);

        int expectedSeconds = (int) (testTime / 1000L);
        int actualSeconds = SMBUtil.readInt4(dst, 0);
        assertEquals(expectedSeconds, actualSeconds);

        // Test when current time is in DST but test time is not

                    value = "cash.app",
                  ),
                ),
              ),
            validity =
              Validity(
                notBefore = 0L,
                notAfter = 1000L,
              ),
            subject =
              listOf(
                listOf(
                  AttributeTypeAndValue(
                    type = COMMON_NAME,
                    value = "cash.app",

            @Override
            public String symbol() {
                return "B";
            }
        },
        KILOBYTE {
            @Override
            public long bytes() {
                return 1000L;
            }

            @Override
            public String symbol() {
                return "kB";
            }
        },
        MEGABYTE {
            @Override
            public long bytes() {

    server.webSocket!!.close(1000, "Hello!")
    client.processNextFrame()
    client.listener.assertClosing(1000, "Hello!")
    assertThat(client.webSocket!!.close(1000, "Bye!")).isTrue()
    client.webSocket!!.finishReader()
    taskFaker.runTasks()
    client.listener.assertClosed(1000, "Hello!")
    server.processNextFrame()
    server.listener.assertClosing(1000, "Bye!")
    server.webSocket!!.finishReader()

    assertThat(inputStream.read()).isEqualTo(-1)
    val elapsedNanos = System.nanoTime() - startNanos
    val elapsedMillis = TimeUnit.NANOSECONDS.toMillis(elapsedNanos)
    assertThat(elapsedMillis).isBetween(500L, 1000L)
  }

  /**
   * Throttle the response body by sleeping 500ms after every 3 bytes. With a 6-byte response, this
   * should yield one sleep for a total delay of 500ms.
   */
  @Test

    /**
     * Default constructor.
     */
    public AbstractConfigHelper() {
        // Default constructor
    }

    /**
     * The interval for reloading.
     */
    protected long reloadInterval = 1000L;

    /**
     * Update the configuration.
     */
    public void update() {
        CommonPoolUtil.execute(this::load);
    }

    /**
     * Wait for the next reloading.
     */

    void testSmbComQueryInformationResponseGetters() throws Exception {
        // The constructor is package‑private; use an anonymous subclass
        SmbComQueryInformationResponse resp = new SmbComQueryInformationResponse(1000L) {
        };
        java.lang.reflect.Field fileAttr = SmbComQueryInformationResponse.class.getDeclaredField("fileAttributes");
        fileAttr.setAccessible(true);
        fileAttr.setInt(resp, 0xABCD);

        // Test with a specific TTL
        long ttl = 600; // 10 minutes
        Dfs.CacheEntry cacheEntry = new Dfs.CacheEntry(ttl);
        long expectedExpiration = System.currentTimeMillis() + ttl * 1000L;
        assertTrue(cacheEntry.expiration >= expectedExpiration - 100 && cacheEntry.expiration <= expectedExpiration + 100);
        assertNotNull(cacheEntry.map);

        // Test with TTL = 0, should use default TTL

        lenient().when(mockConfig.getWitnessRegistrationTimeout()).thenReturn(300000L);
        lenient().when(mockConfig.getWitnessReconnectDelay()).thenReturn(1000L);
        lenient().when(mockConfig.isWitnessServiceDiscovery()).thenReturn(true);
    }

    @Test
    void testSuccessfulRegistration() throws Exception {
        // Setup mock RPC response