Packages that use QueuedI2CPMessageReader
Package
Description
Internal communication between a router and a client running in the same JVM, using queues instead of socket-based I2CP (the Invisible Internet Client Protocol), to avoid the serialization and socket overhead.
Uses of QueuedI2CPMessageReader in net.i2p.internal
Fields in net.i2p.internal with type parameters of type QueuedI2CPMessageReaderModifier and TypeFieldDescriptionprivate final Set<QueuedI2CPMessageReader> QueuedI2CPMessageReader.InternalI2CPDispatcher.readersThe readers currently registered.private final LinkedBlockingQueue<QueuedI2CPMessageReader> QueuedI2CPMessageReader.InternalI2CPDispatcher.readyReaders waiting to be served.Methods in net.i2p.internal with parameters of type QueuedI2CPMessageReaderModifier and TypeMethodDescription(package private) voidQueuedI2CPMessageReader.InternalI2CPDispatcher.register(QueuedI2CPMessageReader reader) Add a reader and make sure something will serve it.(package private) voidQueuedI2CPMessageReader.InternalI2CPDispatcher.unregister(QueuedI2CPMessageReader reader) Stop serving a reader.private static voidQueuedI2CPMessageReader.InternalI2CPDispatcher.warnIfSlowPass(QueuedI2CPMessageReader reader, long startedMs) Warn when one pass over a reader took long enough to look like a blocked handler.