org.onosproject.ovsdb.controller.impl

Class OvsdbJsonRpcHandler

java.lang.Object

io.netty.channel.ChannelHandlerAdapter

io.netty.channel.ChannelInboundHandlerAdapter

org.onosproject.ovsdb.controller.impl.OvsdbJsonRpcHandler

All Implemented Interfaces:

io.netty.channel.ChannelHandler, io.netty.channel.ChannelInboundHandler

public final class OvsdbJsonRpcHandler
extends io.netty.channel.ChannelInboundHandlerAdapter

Channel handler deals with the node connection and dispatches ovsdb messages to the appropriate locations.

Nested Class Summary

Nested classes/interfaces inherited from interface io.netty.channel.ChannelHandler

io.netty.channel.ChannelHandler.Sharable

Constructor Summary

Constructors

Constructor and Description
OvsdbJsonRpcHandler(org.onosproject.ovsdb.controller.OvsdbNodeId ovsdbNodeId) Constructor from a OvsdbNodeId ovsdbNodeId.

Method Summary

Modifier and Type	Method and Description
void	channelRead(io.netty.channel.ChannelHandlerContext ctx, Object msg)
void	channelReadComplete(io.netty.channel.ChannelHandlerContext ctx)
void	exceptionCaught(io.netty.channel.ChannelHandlerContext context, Throwable cause)
org.onosproject.ovsdb.controller.OvsdbNodeId	getNodeId() Gets the OvsdbNodeId instance.
org.onosproject.ovsdb.controller.driver.OvsdbProviderService	getOvsdbProviderService() Gets the ovsdbProviderService instance.
void	setNodeId(org.onosproject.ovsdb.controller.OvsdbNodeId ovsdbNodeId) Sets the ovsdb node id.
void	setOvsdbProviderService(org.onosproject.ovsdb.controller.driver.OvsdbProviderService ovsdbNodeDriver) Sets the ovsdbProviderService instance.

Methods inherited from class io.netty.channel.ChannelInboundHandlerAdapter

channelActive, channelInactive, channelRegistered, channelUnregistered, channelWritabilityChanged, userEventTriggered

Methods inherited from class io.netty.channel.ChannelHandlerAdapter

ensureNotSharable, handlerAdded, handlerRemoved, isSharable

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.netty.channel.ChannelHandler

handlerAdded, handlerRemoved

Constructor Detail

OvsdbJsonRpcHandler

public OvsdbJsonRpcHandler(org.onosproject.ovsdb.controller.OvsdbNodeId ovsdbNodeId)

Constructor from a OvsdbNodeId ovsdbNodeId.

Parameters:

ovsdbNodeId - the ovsdbNodeId to use

Method Detail

getOvsdbProviderService

public org.onosproject.ovsdb.controller.driver.OvsdbProviderService getOvsdbProviderService()

Gets the ovsdbProviderService instance.

Returns:

the instance of the ovsdbProviderService

setOvsdbProviderService

public void setOvsdbProviderService(org.onosproject.ovsdb.controller.driver.OvsdbProviderService ovsdbNodeDriver)

Sets the ovsdbProviderService instance.

Parameters:

ovsdbNodeDriver - the ovsdbNodeDriver to use

getNodeId

public org.onosproject.ovsdb.controller.OvsdbNodeId getNodeId()

Gets the OvsdbNodeId instance.

Returns:

the instance of the OvsdbNodeId

setNodeId

public void setNodeId(org.onosproject.ovsdb.controller.OvsdbNodeId ovsdbNodeId)

Sets the ovsdb node id.

Parameters:

ovsdbNodeId - the ovsdbNodeId to use

channelRead

public void channelRead(io.netty.channel.ChannelHandlerContext ctx,
                        Object msg)
                 throws Exception

Specified by:

channelRead in interface io.netty.channel.ChannelInboundHandler

Overrides:

channelRead in class io.netty.channel.ChannelInboundHandlerAdapter

Throws:

Exception

channelReadComplete

public void channelReadComplete(io.netty.channel.ChannelHandlerContext ctx)
                         throws Exception

Specified by:

channelReadComplete in interface io.netty.channel.ChannelInboundHandler

Overrides:

channelReadComplete in class io.netty.channel.ChannelInboundHandlerAdapter

Throws:

Exception

exceptionCaught

public void exceptionCaught(io.netty.channel.ChannelHandlerContext context,
                            Throwable cause)

Specified by:

exceptionCaught in interface io.netty.channel.ChannelHandler

Specified by:

exceptionCaught in interface io.netty.channel.ChannelInboundHandler

Overrides:

exceptionCaught in class io.netty.channel.ChannelInboundHandlerAdapter