Method addStatementTimeout

server/src/main/java/io/crate/session/Session.java:644–672

(CompletableFuture<?> result, TimeoutToken timeoutToken)

    }

    private void addStatementTimeout(CompletableFuture<?> result, TimeoutToken timeoutToken) {
        long durationNs = timeoutToken.disable();
        TimeValue timeout = timeoutToken.timeout();
        final UUID jobId = mostRecentJobID;
        long timeoutNanos = timeout.nanos();
        if (jobId == null || timeoutNanos <= 0) {
            return;
        }
        long remainingTimeoutNs = timeoutNanos - durationNs;
        Runnable kill = () -> {
            if (result.isDone()) {
                return;
            }
            KillJobsNodeRequest request = new KillJobsNodeRequest(
                List.of(),
                List.of(jobId),
                sessionSettings.userName(),
                JobKilledException.of("statement_timeout (" + timeout.toString() + "/exec)")
            );
            executor.client().execute(KillJobsNodeAction.INSTANCE, request);
        };
        if (remainingTimeoutNs <= 0) {
            kill.run();
        } else {
            ScheduledExecutorService scheduler = executor.scheduler();
            ScheduledFuture<?> schedule = scheduler.schedule(kill, remainingTimeoutNs, TimeUnit.NANOSECONDS);
            result.whenComplete((_, _) -> schedule.cancel(false));
        }
    }

    private CompletableFuture<?> triggerDeferredExecutions(boolean forceBulk) {
        int numDeferred = deferredExecutionsByStmt.size();