*
     * @param body the upload form containing the CSV file
     * @return JSON response with result status
     */
    @Execute
    public JsonResponse<ApiResult> put$upload(final UploadForm body) {
        validateApi(body, messages -> {});
        CommonPoolUtil.execute(() -> {
            try (Reader reader = new BufferedReader(new InputStreamReader(body.badWordFile.getInputStream(), getCsvEncoding()))) {

    //                                                                      ==============
    /**
     * Displays the main path mapping administration page.
     *
     * @param form the search form containing search criteria
     * @return HTML response for the path mapping list page
     */
    @Execute
    @Secured({ ROLE, ROLE + VIEW })

        if (timeoutMillis < 0) {
            throw new IllegalArgumentException("Timeout must be non-negative");
        }
    }

    /**
     * Execute a callable through the circuit breaker
     *
     * @param <T> return type
     * @param callable the callable to execute
     * @return the result
     * @throws Exception if execution fails or circuit is open
     */

    //                                                                        ============
    /**
     * Verify that the CRUD mode matches the expected mode.
     * Throws validation error if modes don't match.
     *
     * @param crudMode The current CRUD mode
     * @param expectedMode The expected CRUD mode
     * @param dictId The dictionary ID for error context
     */

      client.newCall(
        Request
          .Builder()
          .url(server.url("/"))
          .build(),
      )
    assertFailsWith<IOException> {
      call.execute()
    }.also { expected ->
      assertThat(expected.message).isIn("timeout", "Read timed out")
    }
    assertThat(listener.recordedEventTypes()).containsExactly(
      "ConnectStart",
      "ConnectEnd",
      "ConnectionAcquired",

import org.codelibs.fess.app.web.api.ApiResult.Status;
import org.codelibs.fess.app.web.api.admin.FessApiAdminAction;
import org.codelibs.fess.opensearch.config.exentity.DuplicateHost;
import org.lastaflute.web.Execute;
import org.lastaflute.web.response.JsonResponse;

import jakarta.annotation.Resource;

/**
 * API action for admin duplicate host management.

    //                                                                      Search Execute
    //                                                                      ==============
    /**
     * Displays the role management index page.
     *
     * @param form the search form for filtering
     * @return HTML response for the role list page
     */
    @Execute
    @Secured({ ROLE, ROLE + VIEW })

        try {
          call.execute().use { response ->
            System.out.printf("%.2f Call was expected to fail, but completed: %s%n",
                (System.nanoTime() - startNanos) / 1e9f, response)
          }
        } catch (e: IOException) {
          System.out.printf("%.2f Call failed as expected: %s%n",
              (System.nanoTime() - startNanos) / 1e9f, e)
        }

HSPLandroidx/arch/core/executor/ArchTaskExecutor;-><init>()V
HSPLandroidx/arch/core/executor/ArchTaskExecutor;->getInstance()Landroidx/arch/core/executor/ArchTaskExecutor;
HSPLandroidx/arch/core/executor/DefaultTaskExecutor$1;-><init>(Landroidx/arch/core/executor/DefaultTaskExecutor;)V
HSPLandroidx/arch/core/executor/DefaultTaskExecutor;-><init>()V
HSPLandroidx/arch/core/executor/DefaultTaskExecutor;->isMainThread()Z
HSPLandroidx/arch/core/executor/TaskExecutor;-><init>()V

    executor.execute(task);
    return task;
  }

  /**
   * Executes {@code runnable} on the specified {@code executor}, returning a {@code Future} that
   * will complete after execution.
   *
   * @throws RejectedExecutionException if the task cannot be scheduled for execution
   * @since 28.2
   */
  public static ListenableFuture<@Nullable Void> submit(Runnable runnable, Executor executor) {