data.write("ca00".decodeHex()) // Empty pong, flag 1 set.
    assertFailsWith<ProtocolException> {
      clientReader.processNextFrame()
    }.also { expected ->
      assertThat(expected.message).isEqualTo("Unexpected rsv1 flag")
    }
  }

  @Test fun reservedFlag1IsUnsupportedForControlFrames() {
    data.write("ca00".decodeHex()) // Empty pong, flag 1 set.

        long delay4 = policy.getDelayMs(4);
        long delay10 = policy.getDelayMs(10);

        // Then
        assertEquals(1000, delay1);
        assertEquals(2000, delay2);
        assertEquals(4000, delay3);
        assertEquals(5000, delay4); // Capped at max
        assertEquals(5000, delay10); // Still capped
    }

    @Test
    @DisplayName("Should handle non-exponential backoff")

        byte[] buffer = new byte[28];
        // Mock data for SmbQueryFSSizeInfo
        writeInt8(2000, buffer, 0); // total allocation units
        writeInt8(1000, buffer, 8); // free allocation units
        writeInt4(8, buffer, 16); // sectors per allocation unit
        writeInt4(4096, buffer, 20); // bytes per sector

  public void testToString() {
    stopwatch.start();
    assertEquals("0.000 ns", stopwatch.toString());
    ticker.advance(1);
    assertEquals("1.000 ns", stopwatch.toString());
    ticker.advance(998);
    assertEquals("999.0 ns", stopwatch.toString());
    ticker.advance(1);
    assertEquals("1.000 \u03bcs", stopwatch.toString());
    ticker.advance(1);

            SMBUtil.writeInt8(testTime, buffer, offset + 8);
            SMBUtil.writeInt8(testTime + 1000, buffer, offset + 16);
            SMBUtil.writeInt8(testTime + 2000, buffer, offset + 24);
            SMBUtil.writeInt8(testTime + 3000, buffer, offset + 32);
            SMBUtil.writeInt8(8192, buffer, offset + 40);
            SMBUtil.writeInt8(2048, buffer, offset + 48);

        buffer[bufferIndex + 1] = 0x00;
        buffer[bufferIndex + 2] = 0x00;

        // totalParameterCount (4 bytes)
        SMBUtil.writeInt4(1000, buffer, bufferIndex + 3);

        // totalDataCount (4 bytes)
        SMBUtil.writeInt4(2000, buffer, bufferIndex + 7);

        // parameterCount (4 bytes)
        SMBUtil.writeInt4(100, buffer, bufferIndex + 11);

        // parameterOffset (4 bytes)

        assertEquals(0, channelInfo.getErrors());

        channelInfo.addBytesSent(1000);
        channelInfo.addBytesReceived(2000);
        channelInfo.incrementRequestsSent();
        channelInfo.incrementErrors();

        assertEquals(1000, channelInfo.getBytesSent());
        assertEquals(2000, channelInfo.getBytesReceived());
        assertEquals(1, channelInfo.getRequestsSent());

     * This affects which documents are included in search results by default.
     */
    @Size(max = 1000)
    public String defaultLabelValue;

    /**
     * Default sort order for search results.
     * Defines how search results are ordered when no specific sort is requested.
     */
    @Size(max = 1000)
    public String defaultSortValue;

    /**
     * Virtual host configuration for multi-tenant setups.

            // Initial setup
            request.setReadLength(1000);
            request.setOffset(500L);
            request.setMinimumCount(100);

            // Update parameters
            request.setReadLength(2000);
            request.setOffset(1000L);
            request.setMinimumCount(200);
            request.setRemainingBytes(3000);
            request.setPadding((byte) 4);

class NameServiceClient implements Runnable {

    static final int DEFAULT_SO_TIMEOUT = 5000;
    static final int DEFAULT_RCV_BUF_SIZE = 576;
    static final int DEFAULT_SND_BUF_SIZE = 576;
    static final int NAME_SERVICE_UDP_PORT = 137;
    static final int DEFAULT_RETRY_COUNT = 2;
    static final int DEFAULT_RETRY_TIMEOUT = 3000;

    static final int RESOLVER_LMHOSTS = 1;
    static final int RESOLVER_BCAST = 2;