com.aliyun.openservices.iot.api.http2.connection.impl

Class ConnectionImpl

java.lang.Object

com.aliyun.openservices.iot.api.http2.connection.impl.ConnectionImpl

All Implemented Interfaces:

Connection, ConnectionReader, ConnectionWriter

public class ConnectionImpl
extends Object
implements Connection

wrapper for NettyHttp2Handler

Author:

brhao

Date:

23/03/2018

Constructor Summary

Constructors

Constructor and Description
ConnectionImpl(NettyHttp2Handler nettyHttp2Handler, io.netty.channel.ChannelHandlerContext ctx)

Method Summary

Modifier and Type	Method and Description
void	close() close connection
Object	getProperty(io.netty.handler.codec.http2.Http2Connection.PropertyKey key) get property
io.netty.handler.codec.http2.Http2Connection.PropertyKey	getPropertyKey(String keyName) get property key
ConnectionStatus	getStatus() get connection status
boolean	isAuthorized() is connection authorized
void	onConnectionClosed() callback when connection closed
int	onDataRead(io.netty.channel.ChannelHandlerContext ctx, int streamId, io.netty.buffer.ByteBuf data, int padding, boolean endOfStream) callback for DataFrame
void	onError(io.netty.channel.ChannelHandlerContext ctx, boolean outbound, Throwable cause) callback when error occurs
void	onGoAwayRead(io.netty.channel.ChannelHandlerContext ctx, int lastStreamId, long errorCode, io.netty.buffer.ByteBuf debugData) callback for GoAway
void	onHeadersRead(io.netty.channel.ChannelHandlerContext ctx, int streamId, io.netty.handler.codec.http2.Http2Headers headers, int streamDependency, short weight, boolean exclusive, int padding, boolean endOfStream) callback for HeaderFrame
void	onRstStreamRead(io.netty.channel.ChannelHandlerContext ctx, int streamId, long errorCode) callback for rst
void	onSettingsRead(io.netty.channel.ChannelHandlerContext ctx, io.netty.handler.codec.http2.Http2Settings settings) callback for SettingFrame
void	onUnknownFrame(io.netty.channel.ChannelHandlerContext ctx, byte frameType, int streamId, io.netty.handler.codec.http2.Http2Flags flags, io.netty.buffer.ByteBuf payload) callback for Unknown Frame
void	removeConnectListener() remove connection listener
void	setConnectionListener(ConnectionListener listener) set listener for connection
void	setDefaultStreamListener(Http2StreamListener http2StreamListener) set default stream listener
void	setProperty(io.netty.handler.codec.http2.Http2Connection.PropertyKey key, Object object) set property
void	setStatus(ConnectionStatus status) set connection status
String	toString()
CompletableFuture<StreamWriteContext>	writeData(int streamId, byte[] data, boolean endStream) write DATA frame
CompletableFuture<Connection>	writeGoAway(int lastStreamId, int errorCode, byte[] debugData) write GoAway frame
CompletableFuture<StreamWriteContext>	writeHeaders(io.netty.handler.codec.http2.Http2Headers headers, boolean endStream, Http2StreamListener http2StreamListener) start a new stream and write Header Frame
CompletableFuture<Connection>	writeRst(int streamId, int errorCode) write RST_STEAM frame

Methods inherited from class java.lang.Object

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

Constructor Detail

ConnectionImpl

public ConnectionImpl(NettyHttp2Handler nettyHttp2Handler,
                      io.netty.channel.ChannelHandlerContext ctx)

Method Detail

onDataRead

public int onDataRead(io.netty.channel.ChannelHandlerContext ctx,
                      int streamId,
                      io.netty.buffer.ByteBuf data,
                      int padding,
                      boolean endOfStream)

Description copied from interface: ConnectionReader

callback for DataFrame

Specified by:

onDataRead in interface ConnectionReader

Parameters:

ctx - context

streamId - streamId

data - data

padding - padding

endOfStream - end of stream

Returns:

size of read

onHeadersRead

public void onHeadersRead(io.netty.channel.ChannelHandlerContext ctx,
                          int streamId,
                          io.netty.handler.codec.http2.Http2Headers headers,
                          int streamDependency,
                          short weight,
                          boolean exclusive,
                          int padding,
                          boolean endOfStream)

Description copied from interface: ConnectionReader

callback for HeaderFrame

Specified by:

onHeadersRead in interface ConnectionReader

Parameters:

ctx - context

streamId - streamId

headers - http2 Header

streamDependency - stream dependency

weight - weight

exclusive - exclusive

padding - padding

endOfStream - end of stream

setConnectionListener

public void setConnectionListener(ConnectionListener listener)

Description copied from interface: Connection

set listener for connection

Specified by:

setConnectionListener in interface Connection

Parameters:

listener - ConnectionListener

removeConnectListener

public void removeConnectListener()

Description copied from interface: Connection

remove connection listener

Specified by:

removeConnectListener in interface Connection

onSettingsRead

public void onSettingsRead(io.netty.channel.ChannelHandlerContext ctx,
                           io.netty.handler.codec.http2.Http2Settings settings)

Description copied from interface: ConnectionReader

callback for SettingFrame

Specified by:

onSettingsRead in interface ConnectionReader

Parameters:

ctx - context

settings - http2 setting

onGoAwayRead

public void onGoAwayRead(io.netty.channel.ChannelHandlerContext ctx,
                         int lastStreamId,
                         long errorCode,
                         io.netty.buffer.ByteBuf debugData)

Description copied from interface: ConnectionReader

callback for GoAway

Specified by:

onGoAwayRead in interface ConnectionReader

Parameters:

ctx - ctx

lastStreamId - lastStreamId

errorCode - errorCode

debugData - debugData

onRstStreamRead

public void onRstStreamRead(io.netty.channel.ChannelHandlerContext ctx,
                            int streamId,
                            long errorCode)

Description copied from interface: ConnectionReader

callback for rst

Specified by:

onRstStreamRead in interface ConnectionReader

Parameters:

ctx - ctx

streamId - streamId

errorCode - errorCode

onUnknownFrame

public void onUnknownFrame(io.netty.channel.ChannelHandlerContext ctx,
                           byte frameType,
                           int streamId,
                           io.netty.handler.codec.http2.Http2Flags flags,
                           io.netty.buffer.ByteBuf payload)

Description copied from interface: ConnectionReader

callback for Unknown Frame

Specified by:

onUnknownFrame in interface ConnectionReader

Parameters:

ctx - ctx

frameType - frameType

streamId - streamId

flags - flags

payload - payload

onConnectionClosed

public void onConnectionClosed()

Description copied from interface: Connection

callback when connection closed

Specified by:

onConnectionClosed in interface Connection

setStatus

public void setStatus(ConnectionStatus status)

Description copied from interface: Connection

set connection status

Specified by:

setStatus in interface Connection

Parameters:

status - status

getStatus

public ConnectionStatus getStatus()

Description copied from interface: Connection

get connection status

Specified by:

getStatus in interface Connection

Returns:

connection status

isAuthorized

public boolean isAuthorized()

Description copied from interface: Connection

is connection authorized

Specified by:

isAuthorized in interface Connection

Returns:

is connection authorized

toString

public String toString()

Overrides:

toString in class Object

onError

public void onError(io.netty.channel.ChannelHandlerContext ctx,
                    boolean outbound,
                    Throwable cause)

Description copied from interface: Connection

callback when error occurs

Specified by:

onError in interface Connection

Parameters:

ctx - ctx

outbound - outbound

cause - cause

getPropertyKey

public io.netty.handler.codec.http2.Http2Connection.PropertyKey getPropertyKey(String keyName)

Description copied from interface: Connection

get property key

Specified by:

getPropertyKey in interface Connection

Parameters:

keyName - keyName

Returns:

propertyKey

setProperty

public void setProperty(io.netty.handler.codec.http2.Http2Connection.PropertyKey key,
                        Object object)

Description copied from interface: Connection

set property

Specified by:

setProperty in interface Connection

Parameters:

key - propertyKey

object - object

getProperty

public Object getProperty(io.netty.handler.codec.http2.Http2Connection.PropertyKey key)

Description copied from interface: Connection

get property

Specified by:

getProperty in interface Connection

Parameters:

key - propertyKey

Returns:

property

setDefaultStreamListener

public void setDefaultStreamListener(Http2StreamListener http2StreamListener)

Description copied from interface: Connection

set default stream listener

Specified by:

setDefaultStreamListener in interface Connection

Parameters:

http2StreamListener - listener

close

public void close()

Description copied from interface: Connection

close connection

Specified by:

close in interface Connection

writeHeaders

public CompletableFuture<StreamWriteContext> writeHeaders(io.netty.handler.codec.http2.Http2Headers headers,
                                                          boolean endStream,
                                                          Http2StreamListener http2StreamListener)

Description copied from interface: ConnectionWriter

start a new stream and write Header Frame

Specified by:

writeHeaders in interface ConnectionWriter

Parameters:

headers - headers

endStream - end of stream

http2StreamListener - stream listener

Returns:

CompletableFuture for IO

writeData

public CompletableFuture<StreamWriteContext> writeData(int streamId,
                                                       byte[] data,
                                                       boolean endStream)

Description copied from interface: ConnectionWriter

write DATA frame

Specified by:

writeData in interface ConnectionWriter

Parameters:

streamId - streamId

data - data

endStream - end of stream

Returns:

CompletableFuture for IO

writeRst

public CompletableFuture<Connection> writeRst(int streamId,
                                              int errorCode)

Description copied from interface: ConnectionWriter

write RST_STEAM frame

Specified by:

writeRst in interface ConnectionWriter

Parameters:

streamId - streamId

errorCode - errorCode

Returns:

CompletableFuture for IO

writeGoAway

public CompletableFuture<Connection> writeGoAway(int lastStreamId,
                                                 int errorCode,
                                                 byte[] debugData)

Description copied from interface: ConnectionWriter

write GoAway frame

Specified by:

writeGoAway in interface ConnectionWriter

Parameters:

lastStreamId - lastStreamId

errorCode - errorCode

debugData - debugData

Returns:

CompletableFuture for IO