}

    @Test
    @DisplayName("Test log authentication failure")
    void testLogAuthenticationFailure() {
        logger.logAuthentication(false, "testuser", "DOMAIN", "192.168.1.1");

        Map<EventType, Long> stats = logger.getStatistics();
        assertEquals(Long.valueOf(1), stats.get(EventType.AUTHENTICATION_FAILURE), "Should have 1 authentication failure event");
    }

    @Test
    @DisplayName("Test log file access")

  }

  public void testTrustedGetFailure_failed() {
    SettableFuture<String> future = SettableFuture.create();
    Throwable failure = new Throwable();
    future.setException(failure);
    assertThat(future.tryInternalFastPathGetFailure()).isEqualTo(failure);
  }

  public void testTrustedGetFailure_notCompleted() {
    SettableFuture<String> future = SettableFuture.create();

    try {
      testHttpUrl(testData)
      if (KNOWN_FAILURES.contains(testData.toString())) {
        System.err.println("Expected failure but was success: $testData")
      }
    } catch (e: Throwable) {
      if (KNOWN_FAILURES.contains(testData.toString())) {
        System.err.println("Ignoring known failure: $testData")
        e.printStackTrace()
      } else {
        throw e
      }
    }
  }

            testReconnector.testCreateReconnectionRequest(testHandle);
        });
    }

    /**
     * Test implementation of HandleReconnector that allows controlling success/failure
     */
    private static class TestHandleReconnector extends HandleReconnector {
        private final boolean shouldSucceed;

    @Nullable private String value = null;
    @Nullable private Throwable failure = null;
    private boolean wasCalled = false;
    private final Object monitor = new Object();

    MockCallback(String expectedValue) {
      this.value = expectedValue;
    }

    MockCallback(Throwable expectedFailure) {
      this.failure = expectedFailure;
    }

    @Override

        throw new UnsupportedOperationException();
    }

    /**
     * Starts a scheduled job by ID.
     *
     * @param id the ID of the scheduled job to start
     * @return JSON response indicating success or failure
     */
    // PUT /api/admin/scheduler/{id}/start
    @Execute(urlPattern = "{}/@word")
    public JsonResponse<ApiResult> put$start(final String id) {
        scheduledJobService.getScheduledJob(id).ifPresent(entity -> {

     * <p>If the combiningCallable throws an {@code ExecutionException}, the cause of the thrown
     * {@code ExecutionException} will be extracted and used as the failure of the derived step.
     *
     * <p>If the combiningCallable throws any other exception, it will be used as the failure of the
     * derived step.
     *
     * <p>If an exception is thrown after the combiningCallable creates a {@code ClosingFuture},

          hasBody -> requestBody.buffer.readByteString()
          else -> null
        },
      connectionIndex = connectionIndex,
      exchangeIndex = exchangeIndex,
      socket = socket,
      failure = failure,
    )
  }

  @Throws(IOException::class)
  private fun handleWebSocketUpgrade(
    socket: MockWebServerSocket,
    request: RecordedRequest,
    response: MockResponse,
  ) {

        verify(handle, times(1)).hasCapability(captor.capture());
        assertEquals(cap, captor.getValue());
    }

    @Test
    @DisplayName("hasCapability(cap): propagates CIFSException on failure")
    void hasCapability_throws() throws Exception {
        // Arrange
        when(handle.hasCapability(anyInt())).thenThrow(new CIFSException("capability check failed"));

        // Act + Assert

      seenExceptionsLocal = newConcurrentHashSet();
      /*
       * Other handleException() callers may see this as soon as we publish it. We need to populate
       * it with the initial failure before we do, or else they may think that the initial failure
       * has never been seen before.
       */
      addInitialException(seenExceptionsLocal);

      ATOMIC_HELPER.compareAndSetSeenExceptions(this, null, seenExceptionsLocal);