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.JsonObject, 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 com.google.gson.JsonObject	data
private ScheduledFuture<?>	deadline
private final PanelResponderRegistry.ResponderEntry	entry
private final String	messageType
private final CompletableFuture<com.google.gson.JsonObject>	outcome

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
private CompletableFuture<com.google.gson.JsonObject>	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	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.JsonObject 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.JsonObject> 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

Constructor Details

Invocation

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

Method Details

run

public void run()

Specified by:

run in interface Runnable

callResponder

private CompletableFuture<com.google.gson.JsonObject> 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.JsonObject 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.