/*
         * We cannot use Transport.sendrecv() yet because
         * the Transport thread is not setup until doConnect()
         * returns and we want to suppress all communication
         * until we have properly negotiated.
         */
        synchronized (this.inLock) {
            if (prt == 139) {
                ssn139();
            } else {
                if (prt == 0) {

REGISTER_OP("TestNonCommUnavailable")
    .Output("out: string")
    .Doc(R"doc(Test non-communication op throwing Unavailable error.)doc");

REGISTER_OP("TestCommUnavailable")
    .Output("out: string")
    .SetIsDistributedCommunication()
    .Doc(R"doc(Test communication op throwing Unavailable error.)doc");

// Kernel that throws an Unavailable error.

    /** Buffer size reserved when truncating context to fit within max chars limit. */
    protected static final int CONTEXT_TRUNCATION_BUFFER = 100;

    /** The HTTP client used for API communication. */
    protected CloseableHttpClient httpClient;

    /** Cached availability status of the LLM provider. */
    protected volatile Boolean cachedAvailability = null;