org.mortbay.jetty.nio
Class BlockingChannelConnector.Connection

java.lang.Object
  org.mortbay.io.nio.ChannelEndPoint
      org.mortbay.jetty.nio.BlockingChannelConnector.Connection

All Implemented Interfaces:

Runnable, EndPoint

Enclosing class:

BlockingChannelConnector

private class BlockingChannelConnector.Connection
extends ChannelEndPoint
implements Runnable

Field Summary

(package private) HttpConnection	_connection
(package private) boolean	_dispatched

Constructor Summary

BlockingChannelConnector.Connection(ByteChannel channel)

Method Summary

(package private) void	dispatch()
int	fill(Buffer buffer) Fill the buffer from the current putIndex to it's capacity from whatever byte source is backing the buffer.
void	run()

Methods inherited from class org.mortbay.io.nio.ChannelEndPoint

blockReadable, blockWritable, close, flush, flush, getChannel, getConnection, getLocalAddr, getLocalHost, getLocalPort, getRemoteAddr, getRemoteHost, getRemotePort, isBlocking, isOpen

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

_dispatched

boolean _dispatched

_connection

HttpConnection _connection

Constructor Detail

BlockingChannelConnector.Connection

BlockingChannelConnector.Connection(ByteChannel channel)
                              throws IOException

Throws:

IOException

Method Detail

dispatch

void dispatch()
        throws InterruptedException,
               IOException

Throws:

InterruptedException

IOException

fill

public int fill(Buffer buffer)
         throws IOException

Description copied from interface: EndPoint

Fill the buffer from the current putIndex to it's capacity from whatever byte source is backing the buffer. The putIndex is increased if bytes filled. The buffer may chose to do a compact before filling.

Specified by:

fill in interface EndPoint

Overrides:

fill in class ChannelEndPoint

Returns:

an int value indicating the number of bytes filled or -1 if EOF is reached.

Throws:

IOException

run

public void run()

Specified by:

run in interface Runnable