- Greg Wilkins (Webtide, LLC)
- Jan Bartel (Webtide, LLC)
- Jesse McConnell (Webtide, LLC)
- Joakim Erdfelt (Webtide, LLC)
- Simone Bordet (Webtide, LLC)
- David Jencks (IBM)
- Olivier Lamy (Webtide, LLC)
- Ludovic Orban (Webtide, LLC)
Dependencies
Declarations
-
org
-
eclipse
-
jetty
-
io
-
AbstractByteBufferPool
-
_factor: int
-
_maxQueueLength: int
-
_maxHeapMemory: long
-
_heapMemory: AtomicLong
-
_maxDirectMemory: long
-
_directMemory: AtomicLong
-
AbstractByteBufferPool(int, int, long, long): void
-
getCapacityFactor(): int
-
getMaxQueueLength(): int
-
decrementMemory(ByteBuffer): void
-
incrementMemory(ByteBuffer): void
-
updateMemory(ByteBuffer, boolean): void
-
releaseExcessMemory(boolean, Consumer<Boolean>): void
-
getDirectMemory(): long
-
getHeapMemory(): long
-
getMemory(boolean): long
-
clear(): void
-
-
AbstractConnection
-
LOG: Logger
-
_listeners: List<Listener>
-
_created: long
-
_endPoint: EndPoint
-
_executor: Executor
-
_readCallback: Callback
-
_inputBufferSize: int
-
AbstractConnection(EndPoint, Executor): void
-
addEventListener(EventListener): void
-
removeEventListener(EventListener): void
-
getInputBufferSize(): int
-
setInputBufferSize(int): void
-
getExecutor(): Executor
-
failedCallback(Callback, Throwable): void
-
fillInterested(): void
-
tryFillInterested(): void
-
tryFillInterested(Callback): void
-
isFillInterested(): boolean
-
onFillable(): void
-
onFillInterestedFailed(Throwable): void
-
onReadTimeout(Throwable): boolean
-
onOpen(): void
-
onOpened(Listener): void
-
onClose(Throwable): void
-
onClosed(Listener): void
-
getEndPoint(): EndPoint
-
close(): void
-
onIdleExpired(): boolean
-
getMessagesIn(): long
-
getMessagesOut(): long
-
getBytesIn(): long
-
getBytesOut(): long
-
getCreatedTimeStamp(): long
-
toString(): String
-
toConnectionString(): String
-
ReadCallback
-
-
AbstractEndPoint
-
getConnection(): Connection
-
LOG: Logger
-
_state: AtomicReference<State>
-
_created: long
-
_connection: Connection
-
_fillInterest: FillInterest
-
_writeFlusher: WriteFlusher
-
AbstractEndPoint(Scheduler): void
-
shutdownInput(): void
-
shutdownOutput(): void
-
close(): void
-
close(Throwable): void
-
doShutdownInput(): void
-
doShutdownOutput(): void
-
doOnClose(Throwable): void
-
doClose(): void
-
isOutputShutdown(): boolean
-
isInputShutdown(): boolean
-
isOpen(): boolean
-
checkFlush(): void
-
checkFill(): void
-
getCreatedTimeStamp(): long
-
setConnection(Connection): void
-
reset(): void
-
onOpen(): void
-
onClose(): void
-
onClose(Throwable): void
-
fillInterested(Callback): void
-
tryFillInterested(Callback): boolean
-
isFillInterested(): boolean
-
write(Callback, ByteBuffer[]): void
-
onIncompleteFlush(): void
-
needsFillInterest(): void
-
getFillInterest(): FillInterest
-
getWriteFlusher(): WriteFlusher
-
onIdleExpired(TimeoutException): void
-
upgrade(Connection): void
-
toString(): String
-
toEndPointString(): String
-
toConnectionString(): String
-
State
-
-
ArrayByteBufferPool
-
LOG: Logger
-
_minCapacity: int
-
_direct: Bucket[]
-
_indirect: Bucket[]
-
ArrayByteBufferPool(): void
-
ArrayByteBufferPool(int, int, int): void
-
ArrayByteBufferPool(int, int, int, int): void
-
ArrayByteBufferPool(int, int, int, int, long, long): void
-
acquire(int, boolean): ByteBuffer
-
release(ByteBuffer): void
-
newBucket(int): Bucket
-
clear(): void
-
clearOldestBucket(boolean): void
-
bucketFor(int): int
-
bucketFor(int, boolean, IntFunction<Bucket>): Bucket
-
getDirectByteBufferCount(): long
-
getHeapByteBufferCount(): long
-
getByteBufferCount(boolean): long
-
bucketsFor(boolean): Bucket[]
-
-
ByteArrayEndPoint
-
LOG: Logger
-
NOIP: InetAddress
-
NOIPPORT: InetSocketAddress
-
static class initializer
-
EOF: ByteBuffer
-
_runFillable: Runnable
-
_lock: AutoLock
-
_hasOutput: Condition
-
_inQ: Queue<ByteBuffer>
-
_out: ByteBuffer
-
_growOutput: boolean
-
ByteArrayEndPoint(): void
-
ByteArrayEndPoint(byte[], int): void
-
ByteArrayEndPoint(String, int): void
-
ByteArrayEndPoint(Scheduler, long): void
-
ByteArrayEndPoint(Scheduler, long, byte[], int): void
-
ByteArrayEndPoint(Scheduler, long, String, int): void
-
ByteArrayEndPoint(Scheduler, long, ByteBuffer, ByteBuffer): void
-
doShutdownOutput(): void
-
doClose(): void
-
getLocalAddress(): InetSocketAddress
-
getRemoteAddress(): InetSocketAddress
-
onIncompleteFlush(): void
-
execute(Runnable): void
-
needsFillInterest(): void
-
addInputEOF(): void
-
addInput(ByteBuffer): void
-
addInput(String): void
-
addInput(String, Charset): void
-
addInputAndExecute(ByteBuffer): void
-
getOutput(): ByteBuffer
-
getOutputString(): String
-
getOutputString(Charset): String
-
takeOutput(): ByteBuffer
-
waitForOutput(long, TimeUnit): ByteBuffer
-
takeOutputString(): String
-
takeOutputString(Charset): String
-
setOutput(ByteBuffer): void
-
hasMore(): boolean
-
fill(ByteBuffer): int
-
flush(ByteBuffer[]): boolean
-
reset(): void
-
getTransport(): Object
-
isGrowOutput(): boolean
-
setGrowOutput(boolean): void
-
toString(): String
-
isEOF(ByteBuffer): boolean
-
-
ByteBufferOutputStream
-
ByteBufferPool
-
acquire(int, boolean): ByteBuffer
-
release(ByteBuffer): void
-
remove(ByteBuffer): void
-
newByteBuffer(int, boolean): ByteBuffer
-
Lease
-
byteBufferPool: ByteBufferPool
-
buffers: List<ByteBuffer>
-
recycles: List<Boolean>
-
Lease(ByteBufferPool): void
-
acquire(int, boolean): ByteBuffer
-
append(ByteBuffer, boolean): void
-
insert(int, ByteBuffer, boolean): void
-
getByteBuffers(): List<ByteBuffer>
-
getTotalLength(): long
-
getSize(): int
-
recycle(): void
-
release(ByteBuffer): void
-
-
Bucket
-
_queue: Deque<ByteBuffer>
-
_capacity: int
-
_maxSize: int
-
_size: AtomicInteger
-
_lastUpdate: long
-
Bucket(int, int): void
-
acquire(): ByteBuffer
-
release(ByteBuffer): void
-
clear(): void
-
clear(Consumer<ByteBuffer>): void
-
queueOffer(ByteBuffer): void
-
queuePoll(): ByteBuffer
-
isEmpty(): boolean
-
size(): int
-
getLastUpdate(): long
-
toString(): String
-
-
-
ClientConnectionFactory
-
ClientConnector
-
doStart(): void
-
CLIENT_CONNECTOR_CONTEXT_KEY: String
-
REMOTE_SOCKET_ADDRESS_CONTEXT_KEY: String
-
CLIENT_CONNECTION_FACTORY_CONTEXT_KEY: String
-
CONNECTION_PROMISE_CONTEXT_KEY: String
-
LOG: Logger
-
executor: Executor
-
scheduler: Scheduler
-
byteBufferPool: ByteBufferPool
-
sslContextFactory: Client
-
selectorManager: SelectorManager
-
selectors: int
-
connectBlocking: boolean
-
connectTimeout: Duration
-
idleTimeout: Duration
-
bindAddress: SocketAddress
-
reuseAddress: boolean
-
getExecutor(): Executor
-
setExecutor(Executor): void
-
getScheduler(): Scheduler
-
setScheduler(Scheduler): void
-
getByteBufferPool(): ByteBufferPool
-
setByteBufferPool(ByteBufferPool): void
-
getSslContextFactory(): Client
-
setSslContextFactory(Client): void
-
getSelectors(): int
-
setSelectors(int): void
-
isConnectBlocking(): boolean
-
setConnectBlocking(boolean): void
-
getConnectTimeout(): Duration
-
setConnectTimeout(Duration): void
-
getIdleTimeout(): Duration
-
setIdleTimeout(Duration): void
-
getBindAddress(): SocketAddress
-
setBindAddress(SocketAddress): void
-
getReuseAddress(): boolean
-
setReuseAddress(boolean): void
-
doStop(): void
-
newSslContextFactory(): Client
-
newSelectorManager(): SelectorManager
-
connect(SocketAddress, Map<String, Object>): void
-
accept(SocketChannel, Map<String, Object>): void
-
configure(SocketChannel): void
-
newEndPoint(SocketChannel, ManagedSelector, SelectionKey): EndPoint
-
connectFailed(Throwable, Map<String, Object>): void
-
ClientSelectorManager
-
-
Connection
-
addEventListener(EventListener): void
-
removeEventListener(EventListener): void
-
onOpen(): void
-
onClose(Throwable): void
-
getEndPoint(): EndPoint
-
close(): void
-
onIdleExpired(): boolean
-
getMessagesIn(): long
-
getMessagesOut(): long
-
getBytesIn(): long
-
getBytesOut(): long
-
getCreatedTimeStamp(): long
-
UpgradeFrom
-
UpgradeTo
-
Listener
-
-
ConnectionStatistics
-
_connections: CounterStatistic
-
_connectionsDuration: SampleStatistic
-
_rcvdBytes: LongAdder
-
_bytesInStamp: AtomicLong
-
_sentBytes: LongAdder
-
_bytesOutStamp: AtomicLong
-
_messagesIn: LongAdder
-
_messagesInStamp: AtomicLong
-
_messagesOut: LongAdder
-
_messagesOutStamp: AtomicLong
-
reset(): void
-
doStart(): void
-
onOpened(Connection): void
-
onClosed(Connection): void
-
getReceivedBytes(): long
-
getReceivedBytesRate(): long
-
getSentBytes(): long
-
getSentBytesRate(): long
-
getConnectionDurationMax(): long
-
getConnectionDurationMean(): double
-
getConnectionDurationStdDev(): double
-
getConnectionsTotal(): long
-
getConnections(): long
-
getConnectionsMax(): long
-
getReceivedMessages(): long
-
getReceivedMessagesRate(): long
-
getSentMessages(): long
-
getSentMessagesRate(): long
-
dump(): String
-
dump(Appendable, String): void
-
toString(): String
-
-
CyclicTimeout
-
EndPoint
-
Wrapper
-
getLocalAddress(): InetSocketAddress
-
getRemoteAddress(): InetSocketAddress
-
isOpen(): boolean
-
getCreatedTimeStamp(): long
-
shutdownOutput(): void
-
isOutputShutdown(): boolean
-
isInputShutdown(): boolean
-
close(): void
-
close(Throwable): void
-
fill(ByteBuffer): int
-
flush(ByteBuffer[]): boolean
-
getTransport(): Object
-
getIdleTimeout(): long
-
setIdleTimeout(long): void
-
fillInterested(Callback): void
-
tryFillInterested(Callback): boolean
-
isFillInterested(): boolean
-
write(Callback, ByteBuffer[]): void
-
getConnection(): Connection
-
setConnection(Connection): void
-
onOpen(): void
-
onClose(Throwable): void
-
upgrade(Connection): void
-
-
EofException
-
FillInterest
-
LOG: Logger
-
_interested: AtomicReference<Callback>
-
FillInterest(): void
-
register(Callback): void
-
tryRegister(Callback): boolean
-
fillable(): boolean
-
isInterested(): boolean
-
getCallbackInvocationType(): InvocationType
-
onFail(Throwable): boolean
-
onClose(): void
-
toString(): String
-
toStateString(): String
-
needsFillInterest(): void
-
-
IdleTimeout
-
LOG: Logger
-
_scheduler: Scheduler
-
_timeout: AtomicReference<Task>
-
_idleTimeout: long
-
_idleTimestamp: long
-
IdleTimeout(Scheduler): void
-
getScheduler(): Scheduler
-
getIdleFor(): long
-
getIdleTimeout(): long
-
setIdleTimeout(long): void
-
notIdle(): void
-
idleCheck(): void
-
scheduleIdleTimeout(long): void
-
onOpen(): void
-
activate(): void
-
onClose(): void
-
deactivate(): void
-
checkIdleTimeout(): long
-
onIdleExpired(TimeoutException): void
-
isOpen(): boolean
-
-
IncludeExcludeConnectionStatistics
-
LeakTrackingByteBufferPool
-
LOG: Logger
-
leakDetector: LeakDetector<ByteBuffer>
-
leakedAcquires: AtomicLong
-
leakedReleases: AtomicLong
-
leakedRemoves: AtomicLong
-
leaked: AtomicLong
-
delegate: ByteBufferPool
-
LeakTrackingByteBufferPool(ByteBufferPool): void
-
acquire(int, boolean): ByteBuffer
-
release(ByteBuffer): void
-
remove(ByteBuffer): void
-
clearTracking(): void
-
getLeakedAcquires(): long
-
getLeakedReleases(): long
-
getLeakedRemoves(): long
-
getLeakedResources(): long
-
leaked(LeakInfo): void
-
-
ManagedSelector
-
LOG: Logger
-
FORCE_SELECT_NOW: boolean
-
static class initializer
-
_lock: AutoLock
-
_started: AtomicBoolean
-
_selecting: boolean
-
_selectorManager: SelectorManager
-
_id: int
-
_strategy: ExecutionStrategy
-
_selector: Selector
-
_updates: Deque<SelectorUpdate>
-
_updateable: Deque<SelectorUpdate>
-
ManagedSelector(SelectorManager, int): void
-
getSelector(): Selector
-
doStart(): void
-
doStop(): void
-
nioSelect(Selector, boolean): int
-
select(Selector): int
-
handleSelectFailure(Selector, Throwable): void
-
onSelectFailed(Throwable): void
-
size(): int
-
submit(SelectorUpdate): void
-
submit(SelectorUpdate, boolean): void
-
wakeup(): void
-
execute(Runnable): void
-
processConnect(SelectionKey, Connect): void
-
endPointOpened(EndPoint): void
-
endPointClosed(EndPoint): void
-
createEndPoint(SelectableChannel, SelectionKey): void
-
destroyEndPoint(EndPoint, Throwable): void
-
getActionSize(): int
-
safeReadyOps(SelectionKey): int
-
safeInterestOps(SelectionKey): int
-
dump(Appendable, String): void
-
toString(): String
-
Selectable
-
SelectorProducer
-
SelectorUpdate
-
Start
-
DumpKeys
-
Acceptor
-
Accept
-
Connect
-
CloseConnections
-
StopSelector
-
CreateEndPoint
-
DestroyEndPoint
-
-
MappedByteBufferPool
-
LOG: Logger
-
_directBuffers: ConcurrentMap<Integer, Bucket>
-
_heapBuffers: ConcurrentMap<Integer, Bucket>
-
_newBucket: Function<Integer, Bucket>
-
MappedByteBufferPool(): void
-
MappedByteBufferPool(int): void
-
MappedByteBufferPool(int, int): void
-
MappedByteBufferPool(int, int, Function<Integer, Bucket>): void
-
MappedByteBufferPool(int, int, Function<Integer, Bucket>, long, long): void
-
newBucket(int): Bucket
-
acquire(int, boolean): ByteBuffer
-
release(ByteBuffer): void
-
clear(): void
-
clearOldestBucket(boolean): void
-
bucketFor(int): int
-
getDirectByteBufferCount(): long
-
getHeapByteBufferCount(): long
-
getByteBufferCount(boolean): long
-
bucketsFor(boolean): ConcurrentMap<Integer, Bucket>
-
Tagged
-
-
NegotiatingClientConnection
-
LOG: Logger
-
engine: SSLEngine
-
connectionFactory: ClientConnectionFactory
-
context: Map<String, Object>
-
protocol: String
-
completed: boolean
-
NegotiatingClientConnection(EndPoint, Executor, SSLEngine, ClientConnectionFactory, Map<String, Object>): void
-
getSSLEngine(): SSLEngine
-
getProtocol(): String
-
completed(String): void
-
onOpen(): void
-
onFillable(): void
-
fill(): int
-
replaceConnection(): void
-
close(): void
-
-
NegotiatingClientConnectionFactory
-
NetworkTrafficListener
-
NetworkTrafficSocketChannelEndPoint
-
LOG: Logger
-
listener: NetworkTrafficListener
-
NetworkTrafficSocketChannelEndPoint(SocketChannel, ManagedSelector, SelectionKey, Scheduler, long, NetworkTrafficListener): void
-
fill(ByteBuffer): int
-
flush(ByteBuffer[]): boolean
-
onOpen(): void
-
onClose(Throwable): void
-
notifyIncoming(ByteBuffer, int): void
-
notifyOutgoing(ByteBuffer): void
-
-
QuietException
-
RetainableByteBuffer
-
pool: ByteBufferPool
-
buffer: ByteBuffer
-
references: AtomicInteger
-
RetainableByteBuffer(ByteBufferPool, int): void
-
RetainableByteBuffer(ByteBufferPool, int, boolean): void
-
getBuffer(): ByteBuffer
-
getReferences(): int
-
retain(): void
-
release(): int
-
remaining(): int
-
hasRemaining(): boolean
-
isEmpty(): boolean
-
clear(): void
-
toString(): String
-
-
RuntimeIOException
-
SelectorManager
-
DEFAULT_CONNECT_TIMEOUT: int
-
LOG: Logger
-
executor: Executor
-
scheduler: Scheduler
-
_selectors: ManagedSelector[]
-
_selectorIndex: AtomicInteger
-
_selectorIndexUpdate: IntUnaryOperator
-
_acceptListeners: List<AcceptListener>
-
_connectTimeout: long
-
_lease: Lease
-
defaultSelectors(Executor): int
-
SelectorManager(Executor, Scheduler): void
-
SelectorManager(Executor, Scheduler, int): void
-
getExecutor(): Executor
-
getScheduler(): Scheduler
-
getConnectTimeout(): long
-
setConnectTimeout(long): void
-
execute(Runnable): void
-
getSelectorCount(): int
-
chooseSelector(): ManagedSelector
-
connect(SelectableChannel, Object): void
-
accept(SelectableChannel): void
-
accept(SelectableChannel, Object): void
-
acceptor(SelectableChannel): Closeable
-
accepted(SelectableChannel): void
-
doStart(): void
-
newSelector(int): ManagedSelector
-
newSelector(): Selector
-
doStop(): void
-
endPointOpened(EndPoint): void
-
endPointClosed(EndPoint): void
-
connectionOpened(Connection, Object): void
-
connectionClosed(Connection, Throwable): void
-
doFinishConnect(SelectableChannel): boolean
-
isConnectionPending(SelectableChannel): boolean
-
doAccept(SelectableChannel): SelectableChannel
-
connectionFailed(SelectableChannel, Throwable, Object): void
-
newEndPoint(SelectableChannel, ManagedSelector, SelectionKey): EndPoint
-
newConnection(SelectableChannel, EndPoint, Object): Connection
-
addEventListener(EventListener): boolean
-
removeEventListener(EventListener): boolean
-
onAccepting(SelectableChannel): void
-
onAcceptFailed(SelectableChannel, Throwable): void
-
onAccepted(SelectableChannel): void
-
SelectorManagerListener
-
AcceptListener
-
-
SocketChannelEndPoint
-
LOG: Logger
-
_lock: AutoLock
-
_channel: SocketChannel
-
_selector: ManagedSelector
-
_key: SelectionKey
-
_updatePending: boolean
-
_currentInterestOps: int
-
_desiredInterestOps: int
-
RunnableTask
-
RunnableCloseable
-
_updateKeyAction: SelectorUpdate
-
_runFillable: Runnable
-
_runCompleteWrite: Runnable
-
_runCompleteWriteFillable: Runnable
-
SocketChannelEndPoint(SocketChannel, ManagedSelector, SelectionKey, Scheduler): void
-
getLocalAddress(): InetSocketAddress
-
getRemoteAddress(): InetSocketAddress
-
isOpen(): boolean
-
doShutdownOutput(): void
-
doClose(): void
-
onClose(Throwable): void
-
fill(ByteBuffer): int
-
flush(ByteBuffer[]): boolean
-
getChannel(): SocketChannel
-
getTransport(): Object
-
needsFillInterest(): void
-
onIncompleteFlush(): void
-
onSelected(): Runnable
-
updateKeyAction(Selector): void
-
updateKey(): void
-
replaceKey(SelectionKey): void
-
changeInterests(int): void
-
toEndPointString(): String
-
-
WriteFlusher
-
LOG: Logger
-
DEBUG: boolean
-
EMPTY_BUFFERS: ByteBuffer[]
-
__stateTransitions: EnumMap<StateType, Set<StateType>>
-
__IDLE: State
-
__WRITING: State
-
__COMPLETING: State
-
_endPoint: EndPoint
-
_state: AtomicReference<State>
-
static class initializer
-
WriteFlusher(EndPoint): void
-
StateType
-
updateState(State, State): boolean
-
isTransitionAllowed(State, State): boolean
-
State
-
IdleState
-
WritingState
-
FailedState
-
CompletingState
-
PendingState
-
getCallbackInvocationType(): InvocationType
-
onIncompleteFlush(): void
-
write(Callback, ByteBuffer[]): void
-
fail(Callback, Throwable[]): void
-
completeWrite(): void
-
flush(ByteBuffer[]): ByteBuffer[]
-
onFail(Throwable): boolean
-
onClose(): void
-
isFailed(): boolean
-
isIdle(): boolean
-
isPending(): boolean
-
isState(StateType): boolean
-
toStateString(): String
-
toString(): String
-
Listener
-
-
WriterOutputStream
-
ssl
-
ALPNProcessor
-
SslClientConnectionFactory
-
SSL_ENGINE_CONTEXT_KEY: String
-
sslContextFactory: SslContextFactory
-
byteBufferPool: ByteBufferPool
-
executor: Executor
-
connectionFactory: ClientConnectionFactory
-
_directBuffersForEncryption: boolean
-
_directBuffersForDecryption: boolean
-
_requireCloseMessage: boolean
-
SslClientConnectionFactory(SslContextFactory, ByteBufferPool, Executor, ClientConnectionFactory): void
-
getClientConnectionFactory(): ClientConnectionFactory
-
setDirectBuffersForEncryption(boolean): void
-
setDirectBuffersForDecryption(boolean): void
-
isDirectBuffersForDecryption(): boolean
-
isDirectBuffersForEncryption(): boolean
-
isRequireCloseMessage(): boolean
-
setRequireCloseMessage(boolean): void
-
newConnection(EndPoint, Map<String, Object>): Connection
-
newSslConnection(ByteBufferPool, Executor, EndPoint, SSLEngine): SslConnection
-
customize(Connection, Map<String, Object>): Connection
-
HTTPSHandshakeListener
-
-
SslConnection
-
_underflown: boolean
-
LOG: Logger
-
TLS_1_3: String
-
HandshakeState
-
FillState
-
FlushState
-
_lock: AutoLock
-
handshakeListeners: List<SslHandshakeListener>
-
_bufferPool: ByteBufferPool
-
_sslEngine: SSLEngine
-
_decryptedEndPoint: DecryptedEndPoint
-
_decryptedInput: ByteBuffer
-
_encryptedInput: ByteBuffer
-
_encryptedOutput: ByteBuffer
-
_encryptedDirectBuffers: boolean
-
_decryptedDirectBuffers: boolean
-
_renegotiationAllowed: boolean
-
_renegotiationLimit: int
-
_closedOutbound: boolean
-
_requireCloseMessage: boolean
-
_flushState: FlushState
-
_fillState: FillState
-
_handshake: AtomicReference<HandshakeState>
-
RunnableTask
-
_runFillable: Runnable
-
_sslReadCallback: Callback
-
SslConnection(ByteBufferPool, Executor, EndPoint, SSLEngine): void
-
SslConnection(ByteBufferPool, Executor, EndPoint, SSLEngine, boolean, boolean): void
-
addHandshakeListener(SslHandshakeListener): void
-
removeHandshakeListener(SslHandshakeListener): boolean
-
newDecryptedEndPoint(): DecryptedEndPoint
-
getSSLEngine(): SSLEngine
-
getDecryptedEndPoint(): DecryptedEndPoint
-
isRenegotiationAllowed(): boolean
-
setRenegotiationAllowed(boolean): void
-
getRenegotiationLimit(): int
-
setRenegotiationLimit(int): void
-
isRequireCloseMessage(): boolean
-
setRequireCloseMessage(boolean): void
-
isHandshakeInitial(): boolean
-
isHandshakeSucceeded(): boolean
-
isHandshakeComplete(): boolean
-
getApplicationBufferSize(): int
-
getPacketBufferSize(): int
-
getBufferSize(ToIntFunction<SSLSession>): int
-
acquireEncryptedInput(): void
-
acquireEncryptedOutput(): void
-
onUpgradeTo(ByteBuffer): void
-
onOpen(): void
-
onClose(Throwable): void
-
close(): void
-
onIdleExpired(): boolean
-
onFillable(): void
-
onFillInterestedFailed(Throwable): void
-
wrap(SSLEngine, ByteBuffer[], ByteBuffer): SSLEngineResult
-
unwrap(SSLEngine, ByteBuffer, ByteBuffer): SSLEngineResult
-
toConnectionString(): String
-
releaseEncryptedInputBuffer(): void
-
releaseDecryptedInputBuffer(): void
-
releaseEncryptedOutputBuffer(): void
-
networkFill(ByteBuffer): int
-
networkFlush(ByteBuffer): boolean
-
DecryptedEndPoint
-
_incompleteWriteCallback: Callback
-
_failure: Throwable
-
DecryptedEndPoint(): void
-
unwrap(): EndPoint
-
getIdleTimeout(): long
-
setIdleTimeout(long): void
-
isOpen(): boolean
-
getLocalAddress(): InetSocketAddress
-
getRemoteAddress(): InetSocketAddress
-
getWriteFlusher(): WriteFlusher
-
onFillable(): void
-
onFillableFail(Throwable): void
-
setConnection(Connection): void
-
getSslConnection(): SslConnection
-
fill(ByteBuffer): int
-
needsFillInterest(): void
-
handshakeSucceeded(): void
-
handshakeFailed(Throwable): Throwable
-
terminateInput(): void
-
closeInbound(): Throwable
-
flush(ByteBuffer[]): boolean
-
onIncompleteFlush(): void
-
doShutdownOutput(): void
-
closeOutbound(): void
-
ensureFillInterested(): void
-
isOutputShutdown(): boolean
-
isOutboundDone(): boolean
-
doClose(): void
-
getTransport(): Object
-
isInputShutdown(): boolean
-
isInboundDone(): boolean
-
notifyHandshakeSucceeded(SSLEngine): void
-
notifyHandshakeFailed(SSLEngine, Throwable): void
-
isRenegotiating(): boolean
-
allowRenegotiate(): boolean
-
isTLS13(): boolean
-
handleException(Throwable, String): Throwable
-
rethrow(Throwable): void
-
toString(): String
-
IncompleteWriteCallback
-
-
-
SslHandshakeListener
-
-
-
-
-
Java files
org/eclipse/jetty/io/
Class files