org.eclipse.jetty.spdy

Class StandardSession

java.lang.Object

org.eclipse.jetty.spdy.StandardSession

All Implemented Interfaces:

EventListener, Handler<StandardSession.FrameBytes>, Session, ISession, Parser.Listener

public class StandardSession
extends Object
implements ISession, Parser.Listener, Handler<StandardSession.FrameBytes>

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static interface	StandardSession.FrameBytes

Nested classes/interfaces inherited from interface org.eclipse.jetty.spdy.api.Session

Session.Listener, Session.StreamListener

Nested classes/interfaces inherited from interface org.eclipse.jetty.spdy.parser.Parser.Listener

Parser.Listener.Adapter

Nested classes/interfaces inherited from interface org.eclipse.jetty.spdy.api.Handler

Handler.Adapter<C>

Constructor Summary

Constructors

Constructor and Description
StandardSession(short version, ByteBufferPool bufferPool, Executor threadPool, ScheduledExecutorService scheduler, Controller<StandardSession.FrameBytes> controller, IdleListener idleListener, int initialStreamId, SessionFrameListener listener, Generator generator)

Method Summary

Methods

Modifier and Type	Method and Description
void	addListener(Session.Listener listener) Registers the given listener to be notified of session events.
protected void	close()
void	completed(StandardSession.FrameBytes frameBytes) Callback invoked when the operation completes.
<C> void	control(IStream stream, ControlFrame frame, long timeout, TimeUnit unit, Handler<C> handler, C context)
<C> void	data(IStream stream, DataInfo dataInfo, long timeout, TimeUnit unit, Handler<C> handler, C context)
void	failed(Throwable x) Callback invoked when the operation fails.
void	flush() Initiates the flush of data to the other peer.
List<Stream>	getStreams()
short	getVersion()
int	getWindowSize()
Future<Void>	goAway() Closes gracefully this session, sending a GO_AWAY frame and then closing the TCP connection.
void	goAway(long timeout, TimeUnit unit, Handler<Void> handler) Closes gracefully this session, sending a GO_AWAY frame and then closing the TCP connection.
void	onControlFrame(ControlFrame frame)
void	onDataFrame(DataFrame frame, ByteBuffer data)
void	onSessionException(SessionException x)
void	onStreamException(StreamException x)
Future<PingInfo>	ping() Sends asynchronously a PING, normally to measure round-trip time.
void	ping(long timeout, TimeUnit unit, Handler<PingInfo> handler) Sends asynchronously a PING, normally to measure round-trip time.
void	removeListener(Session.Listener listener) Deregisters the give listener from being notified of session events.
Future<Void>	rst(RstInfo rstInfo) Sends asynchronously a RST_STREAM to abort a stream.
void	rst(RstInfo rstInfo, long timeout, TimeUnit unit, Handler<Void> handler) Sends asynchronously a RST_STREAM to abort a stream.
Future<Void>	settings(SettingsInfo settingsInfo) Sends asynchronously a SETTINGS to configure the SPDY connection.
void	settings(SettingsInfo settingsInfo, long timeout, TimeUnit unit, Handler<Void> handler) Sends asynchronously a SETTINGS to configure the SPDY connection.
Future<Stream>	syn(SynInfo synInfo, StreamFrameListener listener) Sends asynchronously a SYN_FRAME to create a new SPDY stream.
void	syn(SynInfo synInfo, StreamFrameListener listener, long timeout, TimeUnit unit, Handler<Stream> handler) Sends asynchronously a SYN_FRAME to create a new SPDY stream.
protected void	write(ByteBuffer buffer, Handler<StandardSession.FrameBytes> handler, StandardSession.FrameBytes frameBytes)

Methods inherited from class java.lang.Object

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

Constructor Detail

StandardSession

public StandardSession(short version,
               ByteBufferPool bufferPool,
               Executor threadPool,
               ScheduledExecutorService scheduler,
               Controller<StandardSession.FrameBytes> controller,
               IdleListener idleListener,
               int initialStreamId,
               SessionFrameListener listener,
               Generator generator)

Method Detail

getVersion

public short getVersion()

Specified by:

getVersion in interface Session

Returns:

the SPDY protocol version used by this session

addListener

public void addListener(Session.Listener listener)

Description copied from interface: Session

Registers the given listener to be notified of session events.

Specified by:

addListener in interface Session

Parameters:

listener - the listener to register

See Also:

Session.removeListener(Listener)

removeListener

public void removeListener(Session.Listener listener)

Description copied from interface: Session

Deregisters the give listener from being notified of session events.

Specified by:

removeListener in interface Session

Parameters:

listener - the listener to deregister

See Also:

Session.addListener(Listener)

syn

public Future<Stream> syn(SynInfo synInfo,
                 StreamFrameListener listener)

Description copied from interface: Session

Sends asynchronously a SYN_FRAME to create a new SPDY stream.

Callers may use the returned future to wait for the stream to be created, and use the stream, for example, to send data frames.

Specified by:

syn in interface Session

Parameters:

synInfo - the metadata to send on stream creation

listener - the listener to invoke when events happen on the stream just created

Returns:

a future for the stream that will be created

See Also:

Session.syn(SynInfo, StreamFrameListener, long, TimeUnit, Handler)

syn

public void syn(SynInfo synInfo,
       StreamFrameListener listener,
       long timeout,
       TimeUnit unit,
       Handler<Stream> handler)

Description copied from interface: Session

Sends asynchronously a SYN_FRAME to create a new SPDY stream.

Callers may pass a non-null completion handler to be notified of when the stream has been created and use the stream, for example, to send data frames.

Specified by:

syn in interface Session

Parameters:

synInfo - the metadata to send on stream creation

listener - the listener to invoke when events happen on the stream just created

timeout - the operation's timeout

unit - the timeout's unit

handler - the completion handler that gets notified of stream creation

See Also:

Session.syn(SynInfo, StreamFrameListener)

rst

public Future<Void> rst(RstInfo rstInfo)

Description copied from interface: Session

Sends asynchronously a RST_STREAM to abort a stream.

Callers may use the returned future to wait for the reset to be sent.

Specified by:

rst in interface Session

Parameters:

rstInfo - the metadata to reset the stream

Returns:

a future to wait for the reset to be sent

See Also:

Session.rst(RstInfo, long, TimeUnit, Handler)

rst

public void rst(RstInfo rstInfo,
       long timeout,
       TimeUnit unit,
       Handler<Void> handler)

Description copied from interface: Session

Sends asynchronously a RST_STREAM to abort a stream.

Callers may pass a non-null completion handler to be notified of when the reset has been actually sent.

Specified by:

rst in interface Session

Parameters:

rstInfo - the metadata to reset the stream

timeout - the operation's timeout

unit - the timeout's unit

handler - the completion handler that gets notified of reset's send

See Also:

Session.rst(RstInfo)

settings

public Future<Void> settings(SettingsInfo settingsInfo)

Description copied from interface: Session

Sends asynchronously a SETTINGS to configure the SPDY connection.

Callers may use the returned future to wait for the settings to be sent.

Specified by:

settings in interface Session

Parameters:

settingsInfo - the metadata to send

Returns:

a future to wait for the settings to be sent

See Also:

Session.settings(SettingsInfo, long, TimeUnit, Handler)

settings

public void settings(SettingsInfo settingsInfo,
            long timeout,
            TimeUnit unit,
            Handler<Void> handler)

Description copied from interface: Session

Sends asynchronously a SETTINGS to configure the SPDY connection.

Callers may pass a non-null completion handler to be notified of when the settings has been actually sent.

Specified by:

settings in interface Session

Parameters:

settingsInfo - the metadata to send

timeout - the operation's timeout

unit - the timeout's unit

handler - the completion handler that gets notified of settings' send

See Also:

Session.settings(SettingsInfo)

ping

public Future<PingInfo> ping()

Description copied from interface: Session

Sends asynchronously a PING, normally to measure round-trip time.

Callers may use the returned future to wait for the ping to be sent.

Specified by:

ping in interface Session

Returns:

a future for the metadata sent

See Also:

Session.ping(long, TimeUnit, Handler)

ping

public void ping(long timeout,
        TimeUnit unit,
        Handler<PingInfo> handler)

Description copied from interface: Session

Sends asynchronously a PING, normally to measure round-trip time.

Callers may pass a non-null completion handler to be notified of when the ping has been actually sent.

Specified by:

ping in interface Session

Parameters:

timeout - the operation's timeout

unit - the timeout's unit

handler - the completion handler that gets notified of ping's send

See Also:

Session.ping()

goAway

public Future<Void> goAway()

Description copied from interface: Session

Closes gracefully this session, sending a GO_AWAY frame and then closing the TCP connection.

Callers may use the returned future to wait for the go away to be sent.

Specified by:

goAway in interface Session

Returns:

a future to wait for the go away to be sent

See Also:

Session.goAway(long, TimeUnit, Handler)

goAway

public void goAway(long timeout,
          TimeUnit unit,
          Handler<Void> handler)

Description copied from interface: Session

Closes gracefully this session, sending a GO_AWAY frame and then closing the TCP connection.

Callers may pass a non-null completion handler to be notified of when the go away has been actually sent.

Specified by:

goAway in interface Session

Parameters:

timeout - the operation's timeout

unit - the timeout's unit

handler - the completion handler that gets notified of go away's send

See Also:

Session.goAway()

getStreams

public List<Stream> getStreams()

Specified by:

getStreams in interface Session

Returns:

the streams currently active in this session

onControlFrame

public void onControlFrame(ControlFrame frame)

Specified by:

onControlFrame in interface Parser.Listener

onDataFrame

public void onDataFrame(DataFrame frame,
               ByteBuffer data)

Specified by:

onDataFrame in interface Parser.Listener

onStreamException

public void onStreamException(StreamException x)

Specified by:

onStreamException in interface Parser.Listener

onSessionException

public void onSessionException(SessionException x)

Specified by:

onSessionException in interface Parser.Listener

close

protected void close()

control

public <C> void control(IStream stream,
               ControlFrame frame,
               long timeout,
               TimeUnit unit,
               Handler<C> handler,
               C context)

Specified by:

control in interface ISession

data

public <C> void data(IStream stream,
            DataInfo dataInfo,
            long timeout,
            TimeUnit unit,
            Handler<C> handler,
            C context)

Specified by:

data in interface ISession

getWindowSize

public int getWindowSize()

Specified by:

getWindowSize in interface ISession

flush

public void flush()

Description copied from interface: ISession

Initiates the flush of data to the other peer.

Note that the flush may do nothing if, for example, there is nothing to flush, or if the data to be flushed belong to streams that have their flow-control stalled.

Specified by:

flush in interface ISession

completed

public void completed(StandardSession.FrameBytes frameBytes)

Description copied from interface: Handler

Callback invoked when the operation completes.

Specified by:

completed in interface Handler<StandardSession.FrameBytes>

Parameters:

frameBytes - the context

See Also:

Handler.failed(Throwable)

failed

public void failed(Throwable x)

Description copied from interface: Handler

Callback invoked when the operation fails.

Specified by:

failed in interface Handler<StandardSession.FrameBytes>

Parameters:

x - the reason for the operation failure

write

protected void write(ByteBuffer buffer,
         Handler<StandardSession.FrameBytes> handler,
         StandardSession.FrameBytes frameBytes)