Package com.ultikits.ultitools.websocket

Class PanelResponderRegistry.Invocation

java.lang.Object

com.ultikits.ultitools.websocket.PanelResponderRegistry.Invocation

All Implemented Interfaces:

Runnable

Enclosing class:

PanelResponderRegistry

private final class PanelResponderRegistry.Invocation
extends Object
implements Runnable

One admitted request: the responder entry captured at admission, its deadline and its outcome. Runs on a worker; every settlement goes through settle(com.google.gson.JsonElement, java.lang.Throwable).

Field Summary

Fields

Modifier and Type	Field	Description
private final ClassLoader	admittingLoader	The admitting thread's context class loader, installed for the call.
private final UltiToolsPlugin	admittingScope	This registry's registration scope on the admitting thread, possibly null.
private final AtomicBoolean	claimed	Set by whichever comes first: a worker starting the call, or a settlement before it started.
private final com.google.gson.JsonObject	data
private ScheduledFuture<?>	deadline
private final AtomicBoolean	ended
private final PanelResponderRegistry.ResponderEntry	entry
private final String	messageType
private final CompletableFuture<com.google.gson.JsonElement>	outcome
private final Runnable	workEnded	Runs once when the module's work ends; see PanelResponderRegistry.dispatch(String, JsonObject, String, Runnable).

Constructor Summary

Constructors

Modifier	Constructor	Description
private	Invocation(String messageType, PanelResponderRegistry.ResponderEntry entry, com.google.gson.JsonObject data, CompletableFuture<com.google.gson.JsonElement> outcome, Runnable workEnded)

Method Summary

Modifier and Type	Method	Description
private CompletableFuture<? extends com.google.gson.JsonElement>	callResponder()	Calls the responder at the framework's boundary to module code: whatever the call throws becomes this request's outcome instead of being lost in the worker.
private void	endWork()	Runs workEnded once.
private void	expire()	The deadline action: take a not-yet-started invocation back, then fail the outcome.
private void	installScope(UltiToolsPlugin scope)	Sets this registry's registration scope on the current thread; null removes it.
private RejectedExecutionException	refusal()
private void	release()	The completion hook: frees the queue slot and the deadline, and stops tracking.
void	run()
private void	settle(com.google.gson.JsonElement value, Throwable failure)	The one settle path.
private RejectedExecutionException	shutDownFailure()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

messageType

private final String messageType

entry

private final PanelResponderRegistry.ResponderEntry entry

data

private final com.google.gson.JsonObject data

outcome

private final CompletableFuture<com.google.gson.JsonElement> outcome

admittingLoader

private final ClassLoader admittingLoader

The admitting thread's context class loader, installed for the call.

admittingScope

private final UltiToolsPlugin admittingScope

This registry's registration scope on the admitting thread, possibly null.

deadline

private volatile ScheduledFuture<?> deadline

workEnded

private final Runnable workEnded

Runs once when the module's work ends; see PanelResponderRegistry.dispatch(String, JsonObject, String, Runnable).

claimed

private final AtomicBoolean claimed

Set by whichever comes first: a worker starting the call, or a settlement before it started.

ended

private final AtomicBoolean ended

Constructor Details

Invocation

private Invocation(String messageType,
 PanelResponderRegistry.ResponderEntry entry,
 com.google.gson.JsonObject data,
 CompletableFuture<com.google.gson.JsonElement> outcome,
 Runnable workEnded)

Method Details

run

public void run()

Specified by:

run in interface Runnable

endWork

private void endWork()

Runs workEnded once.

callResponder

private CompletableFuture<? extends com.google.gson.JsonElement> callResponder()

Calls the responder at the framework's boundary to module code: whatever the call throws becomes this request's outcome instead of being lost in the worker. Returns null when the outcome is already settled here.

installScope

private void installScope(UltiToolsPlugin scope)

Sets this registry's registration scope on the current thread; null removes it.

release

private void release()

The completion hook: frees the queue slot and the deadline, and stops tracking.

refusal

private RejectedExecutionException refusal()

shutDownFailure

private RejectedExecutionException shutDownFailure()

expire

private void expire()

The deadline action: take a not-yet-started invocation back, then fail the outcome.

settle

private void settle(com.google.gson.JsonElement value,
 Throwable failure)

The one settle path. Cancels the deadline before completing the outcome: a CompletableFuture runs later-registered dependents first, so a caller waiting on the outcome must find the deadline already gone. A second settlement is a no-op.