public class IdleTimeoutConduit extends Object implements org.xnio.conduits.StreamSinkConduit, org.xnio.conduits.StreamSourceConduit
Constructor and Description |
---|
IdleTimeoutConduit(org.xnio.StreamConnection connection) |
Modifier and Type | Method and Description |
---|---|
void | awaitReadable() |
void | awaitReadable(long time, TimeUnit timeUnit) |
void | awaitWritable() |
void | awaitWritable(long time, TimeUnit timeUnit) |
protected void | doClose() |
boolean | flush() |
long | getIdleTimeout() |
org.xnio.XnioIoThread | getReadThread() |
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 offset, int length) |
void | resumeReads() |
void | resumeWrites() |
void | setIdleTimeout(long idleTimeout) |
void | setReadReadyHandler(org.xnio.conduits.ReadReadyHandler handler) |
void | setWriteReadyHandler(org.xnio.conduits.WriteReadyHandler handler) |
void | suspendReads() |
void | suspendWrites() |
void | terminateReads() |
void | terminateWrites() |
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 offset, int length) |
int | writeFinal(ByteBuffer src) |
long | writeFinal(ByteBuffer[] srcs, int offset, int length) |
public IdleTimeoutConduit(org.xnio.StreamConnection connection)
protected void doClose()
public int write(ByteBuffer src) throws IOException
write
in interface org.xnio.conduits.StreamSinkConduit
IOException
public long write(ByteBuffer[] srcs, int offset, int length) throws IOException
write
in interface org.xnio.conduits.StreamSinkConduit
IOException
public int writeFinal(ByteBuffer src) throws IOException
writeFinal
in interface org.xnio.conduits.StreamSinkConduit
IOException
public long writeFinal(ByteBuffer[] srcs, int offset, int length) throws IOException
writeFinal
in interface org.xnio.conduits.StreamSinkConduit
IOException
public long transferTo(long position, long count, FileChannel target) throws IOException
transferTo
in interface org.xnio.conduits.StreamSourceConduit
IOException
public long transferTo(long count, ByteBuffer throughBuffer, org.xnio.channels.StreamSinkChannel target) throws IOException
transferTo
in interface org.xnio.conduits.StreamSourceConduit
IOException
public long read(ByteBuffer[] dsts, int offset, int length) throws IOException
read
in interface org.xnio.conduits.StreamSourceConduit
IOException
public int read(ByteBuffer dst) throws IOException
read
in interface org.xnio.conduits.StreamSourceConduit
IOException
public long transferFrom(FileChannel src, long position, long count) throws IOException
transferFrom
in interface org.xnio.conduits.StreamSinkConduit
IOException
public long transferFrom(org.xnio.channels.StreamSourceChannel source, long count, ByteBuffer throughBuffer) throws IOException
transferFrom
in interface org.xnio.conduits.StreamSinkConduit
IOException
public void suspendReads()
suspendReads
in interface org.xnio.conduits.SourceConduit
public void terminateReads() throws IOException
terminateReads
in interface org.xnio.conduits.SourceConduit
IOException
public boolean isReadShutdown()
isReadShutdown
in interface org.xnio.conduits.SourceConduit
public void resumeReads()
resumeReads
in interface org.xnio.conduits.SourceConduit
public boolean isReadResumed()
isReadResumed
in interface org.xnio.conduits.SourceConduit
public void wakeupReads()
wakeupReads
in interface org.xnio.conduits.SourceConduit
public void awaitReadable() throws IOException
awaitReadable
in interface org.xnio.conduits.SourceConduit
IOException
public void awaitReadable(long time, TimeUnit timeUnit) throws IOException
awaitReadable
in interface org.xnio.conduits.SourceConduit
IOException
public org.xnio.XnioIoThread getReadThread()
getReadThread
in interface org.xnio.conduits.SourceConduit
public void setReadReadyHandler(org.xnio.conduits.ReadReadyHandler handler)
setReadReadyHandler
in interface org.xnio.conduits.SourceConduit
public void terminateWrites() throws IOException
terminateWrites
in interface org.xnio.conduits.SinkConduit
IOException
public boolean isWriteShutdown()
isWriteShutdown
in interface org.xnio.conduits.SinkConduit
public void resumeWrites()
resumeWrites
in interface org.xnio.conduits.SinkConduit
public void suspendWrites()
suspendWrites
in interface org.xnio.conduits.SinkConduit
public void wakeupWrites()
wakeupWrites
in interface org.xnio.conduits.SinkConduit
public boolean isWriteResumed()
isWriteResumed
in interface org.xnio.conduits.SinkConduit
public void awaitWritable() throws IOException
awaitWritable
in interface org.xnio.conduits.SinkConduit
IOException
public void awaitWritable(long time, TimeUnit timeUnit) throws IOException
awaitWritable
in interface org.xnio.conduits.SinkConduit
IOException
public org.xnio.XnioIoThread getWriteThread()
getWriteThread
in interface org.xnio.conduits.SinkConduit
public void setWriteReadyHandler(org.xnio.conduits.WriteReadyHandler handler)
setWriteReadyHandler
in interface org.xnio.conduits.SinkConduit
public void truncateWrites() throws IOException
truncateWrites
in interface org.xnio.conduits.SinkConduit
IOException
public boolean flush() throws IOException
flush
in interface org.xnio.conduits.SinkConduit
IOException
public org.xnio.XnioWorker getWorker()
getWorker
in interface org.xnio.conduits.Conduit
public long getIdleTimeout()
public void setIdleTimeout(long idleTimeout)
Copyright © 2020 JBoss by Red Hat. All rights reserved.