org.apache.tomcat.util.net
public class NioChannel extends java.lang.Object implements java.nio.channels.ByteChannel
Modifier and Type | Field and Description |
---|---|
protected SecureNioChannel.ApplicationBufferHandler |
bufHandler |
protected static java.nio.ByteBuffer |
emptyBuf |
protected NioEndpoint.Poller |
poller |
protected java.nio.channels.SocketChannel |
sc |
protected boolean |
sendFile |
Constructor and Description |
---|
NioChannel(java.nio.channels.SocketChannel channel,
SecureNioChannel.ApplicationBufferHandler bufHandler) |
Modifier and Type | Method and Description |
---|---|
void |
close()
Closes this channel.
|
void |
close(boolean force) |
boolean |
flush(boolean block,
java.nio.channels.Selector s,
long timeout,
MutableInteger lastWrite)
returns true if the network buffer has
been flushed out and is empty
|
boolean |
flushOutbound()
Return true if the buffer wrote data
|
java.lang.Object |
getAttachment(boolean remove) |
int |
getBufferSize() |
SecureNioChannel.ApplicationBufferHandler |
getBufHandler()
getBufHandler
|
java.nio.channels.SocketChannel |
getIOChannel()
getIOChannel
|
int |
getOutboundRemaining() |
NioEndpoint.Poller |
getPoller() |
int |
handshake(boolean read,
boolean write) |
boolean |
isClosing()
isClosing
|
boolean |
isInitHandshakeComplete()
isInitHandshakeComplete
|
boolean |
isOpen()
Tells whether or not this channel is open.
|
boolean |
isSendFile() |
int |
read(java.nio.ByteBuffer dst)
Reads a sequence of bytes from this channel into the given buffer.
|
void |
reset() |
void |
setIOChannel(java.nio.channels.SocketChannel IOChannel) |
void |
setPoller(NioEndpoint.Poller poller) |
void |
setSendFile(boolean s) |
java.lang.String |
toString() |
int |
write(java.nio.ByteBuffer src)
Writes a sequence of bytes to this channel from the given buffer.
|
protected static java.nio.ByteBuffer emptyBuf
protected java.nio.channels.SocketChannel sc
protected SecureNioChannel.ApplicationBufferHandler bufHandler
protected NioEndpoint.Poller poller
protected boolean sendFile
public NioChannel(java.nio.channels.SocketChannel channel, SecureNioChannel.ApplicationBufferHandler bufHandler) throws java.io.IOException
java.io.IOException
public void reset() throws java.io.IOException
java.io.IOException
public int getBufferSize()
public boolean flush(boolean block, java.nio.channels.Selector s, long timeout, MutableInteger lastWrite) throws java.io.IOException
java.io.IOException
public void close() throws java.io.IOException
close
in interface java.io.Closeable
close
in interface java.nio.channels.Channel
java.io.IOException
- If an I/O error occurspublic void close(boolean force) throws java.io.IOException
java.io.IOException
public boolean isOpen()
isOpen
in interface java.nio.channels.Channel
public int write(java.nio.ByteBuffer src) throws java.io.IOException
write
in interface java.nio.channels.WritableByteChannel
src
- The buffer from which bytes are to be retrievedjava.io.IOException
- If some other I/O error occurspublic int read(java.nio.ByteBuffer dst) throws java.io.IOException
read
in interface java.nio.channels.ReadableByteChannel
dst
- The buffer into which bytes are to be transferredjava.io.IOException
- If some other I/O error occurspublic java.lang.Object getAttachment(boolean remove)
public SecureNioChannel.ApplicationBufferHandler getBufHandler()
public NioEndpoint.Poller getPoller()
public java.nio.channels.SocketChannel getIOChannel()
public boolean isClosing()
public boolean isInitHandshakeComplete()
public int handshake(boolean read, boolean write) throws java.io.IOException
java.io.IOException
public void setPoller(NioEndpoint.Poller poller)
public void setIOChannel(java.nio.channels.SocketChannel IOChannel)
public java.lang.String toString()
toString
in class java.lang.Object
public int getOutboundRemaining()
public boolean flushOutbound() throws java.io.IOException
java.io.IOException
public boolean isSendFile()
public void setSendFile(boolean s)
Copyright © 2000-2013 Apache Software Foundation. All Rights Reserved.