public class SslConduit extends Object implements org.xnio.conduits.StreamSourceConduit, org.xnio.conduits.StreamSinkConduit
| Modifier and Type | Field and Description |
|---|---|
static ByteBuffer | EMPTY_BUFFER |
static int | MAX_READ_LISTENER_INVOCATIONS |
| Modifier and Type | Method and Description |
|---|---|
void | awaitReadable() |
void | awaitReadable(long time, TimeUnit timeUnit) |
void | awaitWritable() |
void | awaitWritable(long time, TimeUnit timeUnit) |
void | close() forcibly closes the connection |
boolean | flush() |
org.xnio.XnioIoThread | getReadThread() |
SSLEngine | getSSLEngine() |
SSLSession | getSslSession() |
org.xnio.XnioWorker | getWorker() |
org.xnio.XnioIoThread | getWriteThread() |
boolean | isReadResumed() |
boolean | isReadShutdown() |
boolean | isWriteResumed() |
boolean | isWriteShutdown() |
int | read(ByteBuffer dst) |
long | read(ByteBuffer[] dsts, int offs, int len) |
void | resumeReads() |
void | resumeWrites() |
void | setReadReadyHandler(org.xnio.conduits.ReadReadyHandler handler) |
void | setSslEngine(SSLEngine engine) |
void | setWriteReadyHandler(org.xnio.conduits.WriteReadyHandler handler) |
void | startHandshake() |
void | suspendReads() |
void | suspendWrites() |
void | terminateReads() |
void | terminateWrites() |
String | toString() |
long | transferFrom(FileChannel src, long position, long count) |
long | transferFrom(org.xnio.channels.StreamSourceChannel source, long count, ByteBuffer throughBuffer) |
long | transferTo(long count, ByteBuffer throughBuffer, org.xnio.channels.StreamSinkChannel target) |
long | transferTo(long position, long count, FileChannel target) |
void | truncateWrites() |
void | wakeupReads() |
void | wakeupWrites() |
int | write(ByteBuffer src) |
long | write(ByteBuffer[] srcs, int offs, int len) |
int | writeFinal(ByteBuffer src) |
long | writeFinal(ByteBuffer[] srcs, int offset, int length) |
public static final int MAX_READ_LISTENER_INVOCATIONS
public static final ByteBuffer EMPTY_BUFFER
public void terminateReads()
throws IOException terminateReads in interface org.xnio.conduits.SourceConduitIOExceptionpublic boolean isReadShutdown()
isReadShutdown in interface org.xnio.conduits.SourceConduitpublic void resumeReads()
resumeReads in interface org.xnio.conduits.SourceConduitpublic void suspendReads()
suspendReads in interface org.xnio.conduits.SourceConduitpublic void wakeupReads()
wakeupReads in interface org.xnio.conduits.SourceConduitpublic boolean isReadResumed()
isReadResumed in interface org.xnio.conduits.SourceConduitpublic void awaitReadable()
throws IOException awaitReadable in interface org.xnio.conduits.SourceConduitIOExceptionpublic void awaitReadable(long time,
TimeUnit timeUnit)
throws IOException awaitReadable in interface org.xnio.conduits.SourceConduitIOExceptionpublic org.xnio.XnioIoThread getReadThread()
getReadThread in interface org.xnio.conduits.SourceConduitpublic void setReadReadyHandler(org.xnio.conduits.ReadReadyHandler handler)
setReadReadyHandler in interface org.xnio.conduits.SourceConduitpublic long transferFrom(FileChannel src, long position, long count) throws IOException
transferFrom in interface org.xnio.conduits.StreamSinkConduitIOExceptionpublic long transferFrom(org.xnio.channels.StreamSourceChannel source,
long count,
ByteBuffer throughBuffer)
throws IOException transferFrom in interface org.xnio.conduits.StreamSinkConduitIOExceptionpublic int write(ByteBuffer src) throws IOException
write in interface org.xnio.conduits.StreamSinkConduitIOExceptionpublic long write(ByteBuffer[] srcs, int offs, int len) throws IOException
write in interface org.xnio.conduits.StreamSinkConduitIOExceptionpublic int writeFinal(ByteBuffer src) throws IOException
writeFinal in interface org.xnio.conduits.StreamSinkConduitIOExceptionpublic long writeFinal(ByteBuffer[] srcs, int offset, int length) throws IOException
writeFinal in interface org.xnio.conduits.StreamSinkConduitIOExceptionpublic void terminateWrites()
throws IOException terminateWrites in interface org.xnio.conduits.SinkConduitIOExceptionpublic boolean isWriteShutdown()
isWriteShutdown in interface org.xnio.conduits.SinkConduitpublic void resumeWrites()
resumeWrites in interface org.xnio.conduits.SinkConduitpublic void suspendWrites()
suspendWrites in interface org.xnio.conduits.SinkConduitpublic void wakeupWrites()
wakeupWrites in interface org.xnio.conduits.SinkConduitpublic boolean isWriteResumed()
isWriteResumed in interface org.xnio.conduits.SinkConduitpublic void awaitWritable()
throws IOException awaitWritable in interface org.xnio.conduits.SinkConduitIOExceptionpublic void awaitWritable(long time,
TimeUnit timeUnit)
throws IOException awaitWritable in interface org.xnio.conduits.SinkConduitIOExceptionpublic org.xnio.XnioIoThread getWriteThread()
getWriteThread in interface org.xnio.conduits.SinkConduitpublic void setWriteReadyHandler(org.xnio.conduits.WriteReadyHandler handler)
setWriteReadyHandler in interface org.xnio.conduits.SinkConduitpublic void truncateWrites()
throws IOException truncateWrites in interface org.xnio.conduits.SinkConduitIOExceptionpublic boolean flush()
throws IOException flush in interface org.xnio.conduits.SinkConduitIOExceptionpublic long transferTo(long position,
long count,
FileChannel target)
throws IOException transferTo in interface org.xnio.conduits.StreamSourceConduitIOExceptionpublic long transferTo(long count,
ByteBuffer throughBuffer,
org.xnio.channels.StreamSinkChannel target)
throws IOException transferTo in interface org.xnio.conduits.StreamSourceConduitIOExceptionpublic int read(ByteBuffer dst) throws IOException
read in interface org.xnio.conduits.StreamSourceConduitIOExceptionpublic long read(ByteBuffer[] dsts, int offs, int len) throws IOException
read in interface org.xnio.conduits.StreamSourceConduitIOExceptionpublic org.xnio.XnioWorker getWorker()
getWorker in interface org.xnio.conduits.Conduitpublic void startHandshake()
throws SSLException SSLExceptionpublic SSLSession getSslSession()
public SSLEngine getSSLEngine()
public void close()
public void setSslEngine(SSLEngine engine)
Copyright © 2020 JBoss by Red Hat. All rights reserved.