@Test fun test() {
    val t1 = System.nanoTime() / 1e6

    val delays = mutableListOf(TimeUnit.MILLISECONDS.toNanos(1000), -1L)
    queue.schedule("task", TimeUnit.MILLISECONDS.toNanos(750)) {
      log.put("runOnce delays.size=${delays.size}")
      return@schedule delays.removeAt(0)
    }

    assertThat(log.take()).isEqualTo("runOnce delays.size=2")
    val t2 = System.nanoTime() / 1e6 - t1
    assertThat(t2).isCloseTo(750.0, 250.0)

		} else {
			l.Printf(l.traceWarnStr, utils.FileWithLineNum(), slowLog, float64(elapsed.Nanoseconds())/1e6, rows, sql)
		}
	case l.LogLevel == Info:
		sql, rows := fc()
		if rows == -1 {
			l.Printf(l.traceStr, utils.FileWithLineNum(), float64(elapsed.Nanoseconds())/1e6, "-", sql)
		} else {

    assertThat(converter.convert("0")).isEqualTo((Double) 0.0);
    assertThat(converter.convert("-1")).isEqualTo((Double) (-1.0));
    assertThat(converter.convert("1e6")).isEqualTo((Double) 1e6);
    assertThat(converter.convert("1e-6")).isEqualTo((Double) 1e-6);
  }

  public void testStringConverter_convertError() {
    assertThrows(

	}
}

func Test_localLocker_expireOldLocksExpire(t *testing.T) {
	rng := rand.New(rand.NewSource(0))
	quorum := 0
	// Numbers of unique locks
	for _, locks := range []int{100, 1000, 1e6} {
		if testing.Short() && locks > 100 {
			continue
		}
		t.Run(fmt.Sprintf("%d-locks", locks), func(t *testing.T) {
			// Number of readers per lock...
			for _, readers := range []int{1, 10, 100} {

    assertThat(converter.convert("0")).isEqualTo((Double) 0.0);
    assertThat(converter.convert("-1")).isEqualTo((Double) (-1.0));
    assertThat(converter.convert("1e6")).isEqualTo((Double) 1e6);
    assertThat(converter.convert("1e-6")).isEqualTo((Double) 1e-6);
  }

  public void testStringConverter_convertError() {
    assertThrows(

		return AuthNResponse{}, err
	}
	defer o.args.CloseRespFn(resp.Body)
	reqDurNanos := time.Since(reqStartTime).Nanoseconds()
	o.serviceMetrics.accumRequestRTT(reqStartTime, float64(reqDurNanos)/1e6, true)

	switch resp.StatusCode {
	case 200:
		var result AuthNSuccessResponse
		if err = json.NewDecoder(resp.Body).Decode(&result); err != nil {
			return AuthNResponse{}, err
		}

    }
    val elapsedNanos = System.nanoTime() - startNanos
    org.junit.jupiter.api.Assertions.assertTrue(
      elapsedNanos < TimeUnit.SECONDS.toNanos(5),
      "Timeout should have taken ~100ms but was " + elapsedNanos / 1e6 + " ms",
    )
  }

  @Test
  fun chainWithReadTimeout() {
    val interceptor1 =
      Interceptor { chainA: Interceptor.Chain ->
        assertThat(chainA.readTimeoutMillis()).isEqualTo(5000)

    assertThat(converter.convert("1")).isEqualTo((Float) 1.0f);
    assertThat(converter.convert("0")).isEqualTo((Float) 0.0f);
    assertThat(converter.convert("-1")).isEqualTo((Float) (-1.0f));
    assertThat(converter.convert("1e6")).isEqualTo((Float) 1e6f);
    assertThat(converter.convert("1e-6")).isEqualTo((Float) 1e-6f);
  }

  public void testStringConverter_convertError() {

    assertThat(converter.convert("1")).isEqualTo((Float) 1.0f);
    assertThat(converter.convert("0")).isEqualTo((Float) 0.0f);
    assertThat(converter.convert("-1")).isEqualTo((Float) (-1.0f));
    assertThat(converter.convert("1e6")).isEqualTo((Float) 1e6f);
    assertThat(converter.convert("1e-6")).isEqualTo((Float) 1e-6f);
  }

  public void testStringConverter_convertError() {

	if err != nil {
		t.Fatal(err)
	}
	for i, f := range z.File {
		r, err := f.Open()
		if err != nil {
			continue
		}
		if f.UncompressedSize64 < 1e6 {
			n, err := io.Copy(io.Discard, r)
			if i == 3 && err != io.ErrUnexpectedEOF {
				t.Errorf("File[3] error = %v; want io.ErrUnexpectedEOF", err)
			}
			if err == nil && uint64(n) != f.UncompressedSize64 {