org.eclipse.jetty.spdy

Class SPDYAsyncConnection

java.lang.Object

org.eclipse.jetty.io.AbstractConnection

org.eclipse.jetty.spdy.SPDYAsyncConnection

All Implemented Interfaces:

Connection, AsyncConnection, Controller<StandardSession.FrameBytes>, IdleListener

public class SPDYAsyncConnection
extends AbstractConnection
implements AsyncConnection, Controller<StandardSession.FrameBytes>, IdleListener

Field Summary

Fields inherited from class org.eclipse.jetty.io.AbstractConnection

_endp

Constructor Summary

Constructors

Constructor and Description
SPDYAsyncConnection(AsyncEndPoint endPoint, ByteBufferPool bufferPool, Parser parser)

Method Summary

Methods

Modifier and Type	Method and Description
void	close(boolean onlyOutput)
int	fill()
int	flush()
AsyncEndPoint	getEndPoint()
protected Session	getSession()
Connection	handle() Handle the connection.
boolean	isIdle()
boolean	isSuspended() The semantic of this method is to return true to indicate interest in further reads, or false otherwise, but it is misnamed and should be really called isReadInterested().
void	onClose() Called after the connection is closed
void	onIdle(boolean idle)
void	onIdleExpired(long idleForMs) Called when the connection idle timeout expires
void	onInputShutdown()
protected void	setSession(Session session)
int	write(ByteBuffer buffer, Handler<StandardSession.FrameBytes> handler, StandardSession.FrameBytes context)

Methods inherited from class org.eclipse.jetty.io.AbstractConnection

getTimeStamp, toString

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.eclipse.jetty.io.Connection

getTimeStamp

Constructor Detail

SPDYAsyncConnection

public SPDYAsyncConnection(AsyncEndPoint endPoint,
                   ByteBufferPool bufferPool,
                   Parser parser)

Method Detail

handle

public Connection handle()
                  throws IOException

Description copied from interface: Connection

Handle the connection.

Specified by:

handle in interface Connection

Returns:

The Connection to use for the next handling of the connection. This allows protocol upgrades and support for CONNECT.

Throws:

IOException - if the handling of I/O operations fail

fill

public int fill()
         throws IOException

Throws:

IOException

flush

public int flush()

write

public int write(ByteBuffer buffer,
        Handler<StandardSession.FrameBytes> handler,
        StandardSession.FrameBytes context)

Specified by:

write in interface Controller<StandardSession.FrameBytes>

close

public void close(boolean onlyOutput)

Specified by:

close in interface Controller<StandardSession.FrameBytes>

onIdle

public void onIdle(boolean idle)

Specified by:

onIdle in interface IdleListener

getEndPoint

public AsyncEndPoint getEndPoint()

Overrides:

getEndPoint in class AbstractConnection

isIdle

public boolean isIdle()

Specified by:

isIdle in interface Connection

Returns:

whether this connection is idle, that is not parsing and not generating

See Also:

Connection.onIdleExpired(long)

isSuspended

public boolean isSuspended()

Description copied from interface: Connection

The semantic of this method is to return true to indicate interest in further reads, or false otherwise, but it is misnamed and should be really called isReadInterested().

Specified by:

isSuspended in interface Connection

Returns:

true to indicate interest in further reads, false otherwise

onClose

public void onClose()

Description copied from interface: Connection

Called after the connection is closed

Specified by:

onClose in interface Connection

onInputShutdown

public void onInputShutdown()
                     throws IOException

Specified by:

onInputShutdown in interface AsyncConnection

Throws:

IOException

onIdleExpired

public void onIdleExpired(long idleForMs)

Description copied from interface: Connection

Called when the connection idle timeout expires

Specified by:

onIdleExpired in interface Connection

Overrides:

onIdleExpired in class AbstractConnection

Parameters:

idleForMs - how long the connection has been idle

See Also:

Connection.isIdle()

getSession

protected Session getSession()

setSession

protected void setSession(Session session)