SMBUtil.writeInt4(1500, buffer, bufferIndex + 3);

        // Fill rest of required fields
        for (int i = 7; i < 37; i++) {
            buffer[bufferIndex + i] = 0x00;
        }

        response.readParameterWordsWireFormat(buffer, bufferIndex);

        // Verify bufDataStart was set to totalParameterCount
        assertEquals(1500, bufDataStartField.get(response));
    }

  /**
   * We delay sending the last byte of the request body 1500 ms. The 1000 ms read timeout should
   * only elapse 1000 ms after the request body is sent.
   */
  @Test
  fun headersReadTimeoutDoesNotStartUntilLastRequestBodyByteFire() {
    enableProtocol(Protocol.HTTP_2)
    server.enqueue(
      MockResponse
        .Builder()
        .headersDelay(1500, TimeUnit.MILLISECONDS)
        .build(),
    )

        // Arrange
        byte[] buffer = new byte[10];
        SMBUtil.writeInt2(1500, buffer, 0);
        SMBUtil.writeInt2(0xFFFF, buffer, 2);
        SMBUtil.writeInt2(TransPeekNamedPipeResponse.STATUS_DISCONNECTED, buffer, 4);

        // Act
        response.readParametersWireFormat(buffer, 0, 6);

        // Assert
        assertEquals(1500, response.getAvailable());

	}, {
		header:  &Header{ModTime: time.Unix(1, 500), Format: FormatUSTAR},
		paxHdrs: map[string]string{paxMtime: "1.0000005"},
		formats: FormatUSTAR,
	}, {
		header:  &Header{ModTime: time.Unix(1, 500), Format: FormatPAX},
		paxHdrs: map[string]string{paxMtime: "1.0000005"},
		formats: FormatPAX,
	}, {
		header:  &Header{ModTime: time.Unix(1, 500), Format: FormatGNU},

    assertAtLeastTimePassed(stopwatch, 1000);
    assertInterrupted();
  }

  public void testConditionAwaitInterruptedTimeoutNotExceeded() {
    Stopwatch stopwatch = Stopwatch.createStarted();
    Condition condition = TestCondition.createAndSignalAfter(1000, MILLISECONDS);
    requestInterruptIn(500);

    boolean signaledBeforeTimeout = awaitUninterruptibly(condition, 1500, MILLISECONDS);

        assertEquals(2, result.size());
        assertEquals("1500", result.get("total_docs"));
        assertEquals("3", result.get("error_count"));
    }

    public void test_setMaxSessionIdsInList() {
        crawlingInfoHelper.setMaxSessionIdsInList(500);
        assertEquals(500, crawlingInfoHelper.maxSessionIdsInList);

        crawlingInfoHelper.setMaxSessionIdsInList(0);

            SMBUtil.writeInt8(1000, buffer1, 40);
            SMBUtil.writeInt8(500, buffer1, 48);
            SMBUtil.writeInt4(0x01, buffer1, 56);

            response.readBytesWireFormat(buffer1, 0);

            assertEquals(1, response.getCloseFlags());
            assertEquals(1000, response.getAllocationSize());
            assertEquals(500, response.getEndOfFile());

            1000,  // 1 second timeout
            null
        );
        
        assertFalse(info.isExpired());
        
        // Wait for expiration
        Thread.sleep(1500);
        assertTrue(info.isExpired());
        
        // Persistent handles don't expire
        HandleInfo persistent = new HandleInfo(
            "/test/file2.txt",
            new HandleGuid(),

     * the server doesn't respond the web socket will be canceled.
     */
    const val CANCEL_AFTER_CLOSE_MILLIS = 60L * 1000

    /**
     * The smallest message that will be compressed. We use 1024 because smaller messages already
     * fit comfortably within a single ethernet packet (1500 bytes) even with framing overhead.
     *
     * For tests this must be big enough to realize real compression on test messages like

    thread.start();
    thread.awaitWaiting();
    Thread.class.getMethod("suspend").invoke(thread);
    // Sleep for enough time to add 1500 milliseconds of overwait to the get() call.
    long toWaitMillis = 3500 - NANOSECONDS.toMillis(System.nanoTime() - thread.startTime);
    Thread.sleep(toWaitMillis);
    thread.setPriority(Thread.MAX_PRIORITY);
    Thread.class.getMethod("resume").invoke(thread);