private HandleInfo testHandle;

    @BeforeEach
    public void setUp() {
        MockitoAnnotations.openMocks(this);
        reconnector = new HandleReconnector(mockManager, 2, 50); // 2 retries, 50ms delay

        HandleGuid guid = new HandleGuid();
        byte[] fileId = new byte[16];
        for (int i = 0; i < 16; i++) {
            fileId[i] = (byte) (i + 1);
        }

 * connects successfully. This kicks off new attempts every 250 ms until a connect succeeds.
 */
internal class FastFallbackExchangeFinder(
  override val routePlanner: RoutePlanner,
  private val taskRunner: TaskRunner,
) : ExchangeFinder {
  private val connectDelayNanos = TimeUnit.MILLISECONDS.toNanos(250L)
  private var nextTcpConnectAtNanos = Long.MIN_VALUE

  /**

        params.put("delayMillisBeforeProcessing", 250L);
        // Not setting delayMillisAtNoUrlInQueue and delayMillisForWaitingNewUrl

        final DefaultIntervalController controller = new DefaultIntervalController(params);

        assertEquals(150L, controller.getDelayMillisAfterProcessing());
        assertEquals(500L, controller.getDelayMillisAtNoUrlInQueue()); // default
        assertEquals(250L, controller.getDelayMillisBeforeProcessing());

        assertEquals(0, response.getErrors().size());
    }

    @Test
    public void test_getTook() throws Exception {
        SuggestDeleteResponse response = new SuggestDeleteResponse(null, 250);

        assertEquals(250, response.getTook());
    }

    @Test
    public void test_hasError() throws Exception {
        SuggestDeleteResponse response1 = new SuggestDeleteResponse(null, 100);

[versions]
agp = "8.13.1"
biz-aQute-bnd = "7.1.0"
checkStyle = "12.3.0"
com-squareup-moshi = "1.15.2"
com-squareup-okio = "3.16.4"
de-mannodermaus-junit5 = "1.9.0"
graalvm = "25.0.1"
#noinspection UnusedVersionCatalogEntry
junit-platform = "1.13.4"
kotlinx-serialization = "1.9.0"
ksp = "2.3.2"
lintGradle = "1.0.0-alpha05"
mockserverClient = "5.15.0"
org-bouncycastle = "1.82"
org-conscrypt = "2.5.2"
org-jetbrains-coroutines = "1.10.2"

import org.junit.jupiter.api.Test

/**
 * Integration test to confirm that [TaskRunner] works with a real backend. Business logic is all
 * exercised by [TaskRunnerTest].
 *
 * This test is doing real sleeping with tolerances of 250 ms. Hopefully that's enough for even the
 * busiest of CI servers.
 */
@Tag("Slowish")
class TaskRunnerRealBackendTest {
  private val log = LinkedBlockingDeque<String>()

  private val loggingUncaughtExceptionHandler =

    return [{"name": "Foo"}]


def custom_openapi():
    if app.openapi_schema:
        return app.openapi_schema
    openapi_schema = get_openapi(
        title="Custom title",
        version="2.5.0",
        summary="This is a very custom OpenAPI schema",
        description="Here's a longer description of the custom **OpenAPI** schema",
        routes=app.routes,
    )
    openapi_schema["info"]["x-logo"] = {

          @Override
          public void tearDown() throws Exception {
            interruptingTask.stopInterrupting();
            interruptingThread.interrupt();
            joinUninterruptibly(interruptingThread, 2500, MILLISECONDS);
            Thread.interrupted();
            if (interruptingThread.isAlive()) {
              // This will be hidden by test-output redirection:

    assertEquals("1.500 min", stopwatch.toString());
    stopwatch.reset();
    stopwatch.start();
    ticker.advance((long) (2.5 * 60 * 60 * 1000000000L));
    assertEquals("2.500 h", stopwatch.toString());
    stopwatch.reset();
    stopwatch.start();
    ticker.advance((long) (7.25 * 24 * 60 * 60 * 1000000000L));
    assertEquals("7.250 d", stopwatch.toString());
  }

  @GwtIncompatible

          @Override
          public void tearDown() throws Exception {
            interruptingTask.stopInterrupting();
            interruptingThread.interrupt();
            joinUninterruptibly(interruptingThread, 2500, MILLISECONDS);
            Thread.interrupted();
            if (interruptingThread.isAlive()) {
              // This will be hidden by test-output redirection: