Nested and Inner Type Summary

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

Field Summary

Modifier and Type	Field and 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 volatile 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

Access	Constructor and Description
public	SpdySessionHandler(SpdyVersion the protocol version version, boolean `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. server) Creates a new session handler.

Method Summary

Modifier and Type	Method and Description
private boolean	acceptStream(int streamId, byte priority, boolean remoteSideClosed, boolean localSideClosed)
public void	channelInactive(ChannelHandlerContext ctx) Overrides io.netty.channel.ChannelInboundHandlerAdapter.channelInactive. Implements io.netty.channel.ChannelInboundHandler.channelInactive. Calls `ChannelHandlerContext#fireChannelInactive()` to forward to the next `ChannelInboundHandler` in the `ChannelPipeline`.
public void	channelRead(ChannelHandlerContext ctx, Object msg) Overrides io.netty.channel.ChannelInboundHandlerAdapter.channelRead. Implements io.netty.channel.ChannelInboundHandler.channelRead. Calls `ChannelHandlerContext#fireChannelRead(Object)` to forward to the next `ChannelInboundHandler` in the `ChannelPipeline`.
public void	close(ChannelHandlerContext the `ChannelHandlerContext` for which the close operation is made ctx, ChannelPromise the `ChannelPromise` to notify once the operation completes promise) Overrides io.netty.channel.ChannelDuplexHandler.close. Implements io.netty.channel.ChannelOutboundHandler.close. Calls `ChannelHandlerContext#close(ChannelPromise)` to forward to the next `ChannelOutboundHandler` in the `ChannelPipeline`.
public void	exceptionCaught(ChannelHandlerContext ctx, Throwable cause) Overrides io.netty.channel.ChannelInboundHandlerAdapter.exceptionCaught. Implements io.netty.channel.ChannelHandler.exceptionCaught, io.netty.channel.ChannelInboundHandler.exceptionCaught. Gets called if a `Throwable` was thrown.
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)
public void	setSessionReceiveWindowSize(int sessionReceiveWindowSize)
private void	updateInitialReceiveWindowSize(int newInitialWindowSize)
private void	updateInitialSendWindowSize(int newInitialWindowSize)
private void	updateSendWindowSize(final ChannelHandlerContext ctx, int streamId, int deltaWindowSize)
public void	write(ChannelHandlerContext the `ChannelHandlerContext` for which the write operation is made ctx, Object the message to write msg, ChannelPromise the `ChannelPromise` to notify once the operation completes promise) Overrides io.netty.channel.ChannelDuplexHandler.write. Implements io.netty.channel.ChannelOutboundHandler.write. Calls `ChannelHandlerContext#write(Object, ChannelPromise)` to forward to the next `ChannelOutboundHandler` in the `ChannelPipeline`.

Inherited from io.netty.channel.ChannelDuplexHandler:: bind connect deregister disconnect flush read

Field Detail

closeSessionFutureListener	back to summary
private ChannelFutureListener closeSessionFutureListener

DEFAULT_MAX_CONCURRENT_STREAMS	back to summary
private static final int DEFAULT_MAX_CONCURRENT_STREAMS

DEFAULT_WINDOW_SIZE	back to summary
private static final int DEFAULT_WINDOW_SIZE

initialReceiveWindowSize	back to summary
private int initialReceiveWindowSize

initialSendWindowSize	back to summary
private int initialSendWindowSize

initialSessionReceiveWindowSize	back to summary
private volatile int initialSessionReceiveWindowSize

lastGoodStreamId	back to summary
private int lastGoodStreamId

localConcurrentStreams	back to summary
private int localConcurrentStreams

minorVersion	back to summary
private final int minorVersion

pings	back to summary
private final AtomicInteger pings

PROTOCOL_EXCEPTION	back to summary
private static final SpdyProtocolException PROTOCOL_EXCEPTION

receivedGoAwayFrame	back to summary
private boolean receivedGoAwayFrame

remoteConcurrentStreams	back to summary
private int remoteConcurrentStreams

sentGoAwayFrame	back to summary
private boolean sentGoAwayFrame

server	back to summary
private final boolean server

spdySession	back to summary
private final SpdySession spdySession

STREAM_CLOSED	back to summary
private static final SpdyProtocolException STREAM_CLOSED

Constructor Detail

SpdySessionHandler back to summary

SpdySessionHandler	back to summary
public SpdySessionHandler(SpdyVersion version, boolean server) Creates a new session handler. Parameters version:SpdyVersion the protocol version server:boolean `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.

public SpdySessionHandler(SpdyVersion version, boolean server)

Creates a new session handler.

Parameters

version:SpdyVersion: the protocol version
server:boolean: 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 Detail

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

channelInactive back to summary

channelInactive	back to summary
public void channelInactive(ChannelHandlerContext ctx) throws Exception Overrides io.netty.channel.ChannelInboundHandlerAdapter.channelInactive. Implements io.netty.channel.ChannelInboundHandler.channelInactive. Doc from io.netty.channel.ChannelInboundHandlerAdapter.channelInactive. Calls `ChannelHandlerContext#fireChannelInactive()` to forward to the next `ChannelInboundHandler` in the `ChannelPipeline`. Sub-classes may override this method to change behavior. Annotations @Override

public void channelInactive(ChannelHandlerContext ctx) throws Exception

Overrides io.netty.channel.ChannelInboundHandlerAdapter.channelInactive.

Implements io.netty.channel.ChannelInboundHandler.channelInactive.

Doc from io.netty.channel.ChannelInboundHandlerAdapter.channelInactive.

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

Annotations

@Override

channelRead back to summary

channelRead	back to summary
public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception Overrides io.netty.channel.ChannelInboundHandlerAdapter.channelRead. Implements io.netty.channel.ChannelInboundHandler.channelRead. Doc from io.netty.channel.ChannelInboundHandlerAdapter.channelRead. Calls `ChannelHandlerContext#fireChannelRead(Object)` to forward to the next `ChannelInboundHandler` in the `ChannelPipeline`. Sub-classes may override this method to change behavior. Annotations @Override

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

Overrides io.netty.channel.ChannelInboundHandlerAdapter.channelRead.

Implements io.netty.channel.ChannelInboundHandler.channelRead.

Doc from io.netty.channel.ChannelInboundHandlerAdapter.channelRead.

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

Annotations

@Override

close back to summary

close	back to summary
public void close(ChannelHandlerContext ctx, ChannelPromise promise) throws Exception Overrides io.netty.channel.ChannelDuplexHandler.close. Implements io.netty.channel.ChannelOutboundHandler.close. Doc from io.netty.channel.ChannelDuplexHandler.close. Calls `ChannelHandlerContext#close(ChannelPromise)` to forward to the next `ChannelOutboundHandler` in the `ChannelPipeline`. Sub-classes may override this method to change behavior. Parameters ctx:ChannelHandlerContext Doc from io.netty.channel.ChannelOutboundHandler.close. the `ChannelHandlerContext` for which the close operation is made promise:ChannelPromise Doc from io.netty.channel.ChannelOutboundHandler.close. the `ChannelPromise` to notify once the operation completes Annotations @Override Exceptions Exception: Doc from io.netty.channel.ChannelOutboundHandler.close. thrown if an error occurs

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

Overrides io.netty.channel.ChannelDuplexHandler.close.

Implements io.netty.channel.ChannelOutboundHandler.close.

Doc from io.netty.channel.ChannelDuplexHandler.close.

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

Parameters

ctx:ChannelHandlerContext

Doc from io.netty.channel.ChannelOutboundHandler.close.

the ChannelHandlerContext for which the close operation is made

promise:ChannelPromise

Doc from io.netty.channel.ChannelOutboundHandler.close.

the ChannelPromise to notify once the operation completes

Annotations

@Override

Exceptions

Exception:

Doc from io.netty.channel.ChannelOutboundHandler.close.

thrown if an error occurs

exceptionCaught back to summary

exceptionCaught	back to summary
public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws Exception Overrides io.netty.channel.ChannelInboundHandlerAdapter.exceptionCaught. Implements io.netty.channel.ChannelHandler.exceptionCaught, io.netty.channel.ChannelInboundHandler.exceptionCaught. Doc from io.netty.channel.ChannelHandler.exceptionCaught. Gets called if a `Throwable` was thrown. Annotations @Override

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

Overrides io.netty.channel.ChannelInboundHandlerAdapter.exceptionCaught.

Implements io.netty.channel.ChannelHandler.exceptionCaught, io.netty.channel.ChannelInboundHandler.exceptionCaught.

Doc from io.netty.channel.ChannelHandler.exceptionCaught.

Gets called if a Throwable was thrown.

Annotations

@Override

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

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

isRemoteInitiatedId	back to summary
private boolean isRemoteInitiatedId(int id)

issueSessionError	back to summary
private void issueSessionError(ChannelHandlerContext ctx, SpdySessionStatus status)

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

removeStream	back to summary
private void removeStream(int streamId, ChannelFuture future)

sendGoAwayFrame	back to summary
private void sendGoAwayFrame(ChannelHandlerContext ctx, ChannelPromise future)

sendGoAwayFrame	back to summary
private ChannelFuture sendGoAwayFrame(ChannelHandlerContext ctx, SpdySessionStatus status)

setSessionReceiveWindowSize	back to summary
public void setSessionReceiveWindowSize(int sessionReceiveWindowSize)

updateInitialReceiveWindowSize	back to summary
private void updateInitialReceiveWindowSize(int newInitialWindowSize)

updateInitialSendWindowSize	back to summary
private void updateInitialSendWindowSize(int newInitialWindowSize)

updateSendWindowSize	back to summary
private void updateSendWindowSize(final ChannelHandlerContext ctx, int streamId, int deltaWindowSize)

write back to summary

write	back to summary
public void write(ChannelHandlerContext ctx, Object msg, ChannelPromise promise) throws Exception Overrides io.netty.channel.ChannelDuplexHandler.write. Implements io.netty.channel.ChannelOutboundHandler.write. Doc from io.netty.channel.ChannelDuplexHandler.write. Calls `ChannelHandlerContext#write(Object, ChannelPromise)` to forward to the next `ChannelOutboundHandler` in the `ChannelPipeline`. Sub-classes may override this method to change behavior. Parameters ctx:ChannelHandlerContext Doc from io.netty.channel.ChannelOutboundHandler.write. the `ChannelHandlerContext` for which the write operation is made msg:Object Doc from io.netty.channel.ChannelOutboundHandler.write. the message to write promise:ChannelPromise Doc from io.netty.channel.ChannelOutboundHandler.write. the `ChannelPromise` to notify once the operation completes Annotations @Override Exceptions Exception: Doc from io.netty.channel.ChannelOutboundHandler.write. thrown if an error occurs

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

Overrides io.netty.channel.ChannelDuplexHandler.write.

Implements io.netty.channel.ChannelOutboundHandler.write.

Doc from io.netty.channel.ChannelDuplexHandler.write.

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

Parameters

ctx:ChannelHandlerContext

Doc from io.netty.channel.ChannelOutboundHandler.write.

the ChannelHandlerContext for which the write operation is made

msg:Object

Doc from io.netty.channel.ChannelOutboundHandler.write.

the message to write

promise:ChannelPromise

Doc from io.netty.channel.ChannelOutboundHandler.write.

the ChannelPromise to notify once the operation completes

Annotations

@Override

Exceptions

Exception:

Doc from io.netty.channel.ChannelOutboundHandler.write.

thrown if an error occurs

io.netty.handler.codec.spdy back to summary

private final Class SpdySessionHandler.ClosingChannelFutureListener

Class Inheritance

extends Object
implements ChannelFutureListener

java.lang.Object
io.netty.handler.codec.spdy.SpdySessionHandler.ClosingChannelFutureListener

All Implemented Interfaces

io.netty.channel.ChannelFutureListener, io.netty.util.concurrent.GenericFutureListener, java.util.EventListener

Field Summary

Modifier and Type	Field and Description
private final ChannelHandlerContext	ctx
private final ChannelPromise	promise

Constructor Summary

Access	Constructor and Description
pack-priv	ClosingChannelFutureListener(ChannelHandlerContext ctx, ChannelPromise promise)

Method Summary

Modifier and Type	Method and Description
public void	operationComplete(ChannelFuture the source `Future` which called this callback sentGoAwayFuture) Implements io.netty.util.concurrent.GenericFutureListener.operationComplete. Invoked when the operation associated with the `Future` has been completed.

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

Field Detail

ctx	back to summary
private final ChannelHandlerContext ctx

promise	back to summary
private final ChannelPromise promise

Constructor Detail

ClosingChannelFutureListener	back to summary
pack-priv ClosingChannelFutureListener(ChannelHandlerContext ctx, ChannelPromise promise)

Method Detail

operationComplete back to summary

operationComplete	back to summary
public void operationComplete(ChannelFuture sentGoAwayFuture) throws Exception Implements io.netty.util.concurrent.GenericFutureListener.operationComplete. Doc from io.netty.util.concurrent.GenericFutureListener.operationComplete. Invoked when the operation associated with the `Future` has been completed. Parameters sentGoAwayFuture:ChannelFuture the source `Future` which called this callback Annotations @Override

public void operationComplete(ChannelFuture sentGoAwayFuture) throws Exception

Implements io.netty.util.concurrent.GenericFutureListener.operationComplete.

Doc from io.netty.util.concurrent.GenericFutureListener.operationComplete.

Invoked when the operation associated with the Future has been completed.

Parameters

sentGoAwayFuture:ChannelFuture: the source Future which called this callback

Annotations

@Override

public Class SpdySessionHandler

Nested and Inner Type Summary

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

private final Class SpdySessionHandler.ClosingChannelFutureListener

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail