Class SpdySessionHandler

java.lang.Object

io.netty.channel.ChannelHandlerAdapter

io.netty.channel.ChannelInboundHandlerAdapter

io.netty.channel.ChannelDuplexHandler

io.netty.handler.codec.spdy.SpdySessionHandler

All Implemented Interfaces:

ChannelHandler, ChannelInboundHandler, ChannelOutboundHandler

public class SpdySessionHandler
extends ChannelDuplexHandler

Manages streams within a SPDY session.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private static final class	SpdySessionHandler.ClosingChannelFutureListener

Nested classes/interfaces inherited from interface ChannelHandler

ChannelHandler.Sharable

Field Summary

Fields

Modifier and Type	Field	Description
private ChannelFutureListener	closeSessionFutureListener
private static final int	DEFAULT_MAX_CONCURRENT_STREAMS
private static final int	DEFAULT_WINDOW_SIZE
private int	initialReceiveWindowSize
private int	initialSendWindowSize
private int	initialSessionReceiveWindowSize
private int	lastGoodStreamId
private int	localConcurrentStreams
private final int	minorVersion
private final AtomicInteger	pings
private static final SpdyProtocolException	PROTOCOL_EXCEPTION
private boolean	receivedGoAwayFrame
private int	remoteConcurrentStreams
private boolean	sentGoAwayFrame
private final boolean	server
private final SpdySession	spdySession
private static final SpdyProtocolException	STREAM_CLOSED

Constructor Summary

Constructors

Constructor	Description
SpdySessionHandler(SpdyVersion version, boolean server)	Creates a new session handler.

Method Summary

Modifier and Type	Method	Description
private boolean	acceptStream(int streamId, byte priority, boolean remoteSideClosed, boolean localSideClosed)
void	channelInactive(ChannelHandlerContext ctx)	Calls ChannelHandlerContext.fireChannelInactive() to forward to the next ChannelInboundHandler in the ChannelPipeline.
void	channelRead(ChannelHandlerContext ctx, Object msg)	Calls ChannelHandlerContext.fireChannelRead(Object) to forward to the next ChannelInboundHandler in the ChannelPipeline.
void	close(ChannelHandlerContext ctx, ChannelPromise promise)	Calls ChannelOutboundInvoker.close(ChannelPromise) to forward to the next ChannelOutboundHandler in the ChannelPipeline.
void	exceptionCaught(ChannelHandlerContext ctx, Throwable cause)	Calls ChannelHandlerContext.fireExceptionCaught(Throwable) to forward to the next ChannelHandler in the ChannelPipeline.
private void	halfCloseStream(int streamId, boolean remote, ChannelFuture future)
private void	handleOutboundMessage(ChannelHandlerContext ctx, Object msg, ChannelPromise promise)
private boolean	isRemoteInitiatedId(int id)
private void	issueSessionError(ChannelHandlerContext ctx, SpdySessionStatus status)
private void	issueStreamError(ChannelHandlerContext ctx, int streamId, SpdyStreamStatus status)
private void	removeStream(int streamId, ChannelFuture future)
private void	sendGoAwayFrame(ChannelHandlerContext ctx, ChannelPromise future)
private ChannelFuture	sendGoAwayFrame(ChannelHandlerContext ctx, SpdySessionStatus status)
void	setSessionReceiveWindowSize(int sessionReceiveWindowSize)
private void	updateInitialReceiveWindowSize(int newInitialWindowSize)
private void	updateInitialSendWindowSize(int newInitialWindowSize)
private void	updateSendWindowSize(ChannelHandlerContext ctx, int streamId, int deltaWindowSize)
void	write(ChannelHandlerContext ctx, Object msg, ChannelPromise promise)	Calls ChannelOutboundInvoker.write(Object, ChannelPromise) to forward to the next ChannelOutboundHandler in the ChannelPipeline.

Methods inherited from class ChannelDuplexHandler

bind, connect, deregister, disconnect, flush, read

Methods inherited from class ChannelInboundHandlerAdapter

channelActive, channelReadComplete, channelRegistered, channelUnregistered, channelWritabilityChanged, userEventTriggered

Methods inherited from class ChannelHandlerAdapter

ensureNotSharable, handlerAdded, handlerRemoved, isSharable

Methods inherited from class Object

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

Methods inherited from interface ChannelHandler

handlerAdded, handlerRemoved

Field Details

PROTOCOL_EXCEPTION

private static final SpdyProtocolException PROTOCOL_EXCEPTION

STREAM_CLOSED

private static final SpdyProtocolException STREAM_CLOSED

DEFAULT_WINDOW_SIZE

private static final int DEFAULT_WINDOW_SIZE

See Also:

• Constant Field Values

initialSendWindowSize

private int initialSendWindowSize

initialReceiveWindowSize

private int initialReceiveWindowSize

initialSessionReceiveWindowSize

private volatile int initialSessionReceiveWindowSize

spdySession

private final SpdySession spdySession

lastGoodStreamId

private int lastGoodStreamId

DEFAULT_MAX_CONCURRENT_STREAMS

private static final int DEFAULT_MAX_CONCURRENT_STREAMS

See Also:

• Constant Field Values

remoteConcurrentStreams

private int remoteConcurrentStreams

localConcurrentStreams

private int localConcurrentStreams

pings

private final AtomicInteger pings

sentGoAwayFrame

private boolean sentGoAwayFrame

receivedGoAwayFrame

private boolean receivedGoAwayFrame

closeSessionFutureListener

private ChannelFutureListener closeSessionFutureListener

server

private final boolean server

minorVersion

private final int minorVersion

Constructor Details

SpdySessionHandler

public SpdySessionHandler(SpdyVersion version,
 boolean server)

Creates a new session handler.

Parameters:

version - the protocol version

server - true if and only if this session handler should handle the server endpoint of the connection. false if and only if this session handler should handle the client endpoint of the connection.

Method Details

setSessionReceiveWindowSize

public void setSessionReceiveWindowSize(int sessionReceiveWindowSize)

channelRead

public void channelRead(ChannelHandlerContext ctx,
 Object msg)
                 throws Exception

Description copied from class: ChannelInboundHandlerAdapter

Calls ChannelHandlerContext.fireChannelRead(Object) to forward to the next ChannelInboundHandler in the ChannelPipeline. Sub-classes may override this method to change behavior.

Specified by:

channelRead in interface ChannelInboundHandler

Overrides:

channelRead in class ChannelInboundHandlerAdapter

Throws:

Exception

channelInactive

public void channelInactive(ChannelHandlerContext ctx)
                     throws Exception

Description copied from class: ChannelInboundHandlerAdapter

Calls ChannelHandlerContext.fireChannelInactive() to forward to the next ChannelInboundHandler in the ChannelPipeline. Sub-classes may override this method to change behavior.

Specified by:

channelInactive in interface ChannelInboundHandler

Overrides:

channelInactive in class ChannelInboundHandlerAdapter

Throws:

Exception

exceptionCaught

public void exceptionCaught(ChannelHandlerContext ctx,
 Throwable cause)
                     throws Exception

Description copied from class: ChannelInboundHandlerAdapter

Calls ChannelHandlerContext.fireExceptionCaught(Throwable) to forward to the next ChannelHandler in the ChannelPipeline. Sub-classes may override this method to change behavior.

Specified by:

exceptionCaught in interface ChannelHandler

Specified by:

exceptionCaught in interface ChannelInboundHandler

Overrides:

exceptionCaught in class ChannelInboundHandlerAdapter

Throws:

Exception

close

public void close(ChannelHandlerContext ctx,
 ChannelPromise promise)
           throws Exception

Description copied from class: ChannelDuplexHandler

Calls ChannelOutboundInvoker.close(ChannelPromise) to forward to the next ChannelOutboundHandler in the ChannelPipeline. Sub-classes may override this method to change behavior.

Specified by:

close in interface ChannelOutboundHandler

Overrides:

close in class ChannelDuplexHandler

Parameters:

ctx - the ChannelHandlerContext for which the close operation is made

promise - the ChannelPromise to notify once the operation completes

Throws:

Exception - thrown if an error occurs

write

public void write(ChannelHandlerContext ctx,
 Object msg,
 ChannelPromise promise)
           throws Exception

Description copied from class: ChannelDuplexHandler

Calls ChannelOutboundInvoker.write(Object, ChannelPromise) to forward to the next ChannelOutboundHandler in the ChannelPipeline. Sub-classes may override this method to change behavior.

Specified by:

write in interface ChannelOutboundHandler

Overrides:

write in class ChannelDuplexHandler

Parameters:

ctx - the ChannelHandlerContext for which the write operation is made

msg - the message to write

promise - the ChannelPromise to notify once the operation completes

Throws:

Exception - thrown if an error occurs

handleOutboundMessage

private void handleOutboundMessage(ChannelHandlerContext ctx,
 Object msg,
 ChannelPromise promise)
                            throws Exception

Throws:

Exception

issueSessionError

private void issueSessionError(ChannelHandlerContext ctx,
 SpdySessionStatus status)

issueStreamError

private void issueStreamError(ChannelHandlerContext ctx,
 int streamId,
 SpdyStreamStatus status)

isRemoteInitiatedId

private boolean isRemoteInitiatedId(int id)

updateInitialSendWindowSize

private void updateInitialSendWindowSize(int newInitialWindowSize)

updateInitialReceiveWindowSize

private void updateInitialReceiveWindowSize(int newInitialWindowSize)

acceptStream

private boolean acceptStream(int streamId,
 byte priority,
 boolean remoteSideClosed,
 boolean localSideClosed)

halfCloseStream

private void halfCloseStream(int streamId,
 boolean remote,
 ChannelFuture future)

removeStream

private void removeStream(int streamId,
 ChannelFuture future)

updateSendWindowSize

private void updateSendWindowSize(ChannelHandlerContext ctx,
 int streamId,
 int deltaWindowSize)

sendGoAwayFrame

private void sendGoAwayFrame(ChannelHandlerContext ctx,
 ChannelPromise future)

sendGoAwayFrame

private ChannelFuture sendGoAwayFrame(ChannelHandlerContext ctx,
 SpdySessionStatus status)