Package io.deephaven.enterprise.niowrapper.sched
package io.deephaven.enterprise.niowrapper.sched
-
ClassDescriptionThis class creates new IOJobs by listening for incoming connections on a ServerSocket.This class is modified from the original fork from com.fishlib.io.sched.Connector, with the following changes:
Connector.maybeRetry(IOException)quits trying when the job has been canceled.IOJobImplLenientis used instead of com.fishlib.io.sched.IOJobImpl when configured to do so Fishlib: "This class creates a new IOJob by connecting to a specific SocketAddress."these are the states the connector can be inThread that monitors our reconnects and causes a server exit when the reconnect attempts are done with.Created by IntelliJ IDEA.FutureJob<RESULT_TYPE>Created by rcaudy on 6/6/14.These are the I/O events that can be generated by the NIO scheduler.Created by IntelliJ IDEA.Created by IntelliJ IDEA.This is a clone ofIOJobImpl, with optional added protection against write queue overflows.Created by IntelliJ IDEA.Created by IntelliJ IDEA.Created by IntelliJ IDEA.Created with IntelliJ IDEA.The interface to a module which consumes messages.A MessageProducer sends Message instances to a set of MessageConsumers.A ByteBuffer sink which provides its stream with buffers from a message pool, and collects filled buffers into an array of messages.Created by IntelliJ IDEA.User: dsmith Date: 3/30/11An IOHandler which implements all methods as no-ops, useful for situations in which only one method is really of interest.Created by rcaudy on 3/12/15.A wrapper for byte buffers which provides a protocol for message pooling and multiple, independent consumers of the message content.This is the interface for message pools.This class provides a singleton wrapper for scheduling invocations of multiple Job instances from a single thread.Created by IntelliJ IDEA.Created by IntelliJ IDEA.Contains the trust store and SSL context.Created by cwright on 2/20/2015.Created by cwright on 2/20/2015.This is the base class for jobs which are only interested in timing events.Created by IntelliJ IDEA.Yet Another implementation of the Scheduler interface -- the best one yet.