Package org.apache.hadoop.oncrpc

Class RpcUtil

java.lang.Object

org.apache.hadoop.oncrpc.RpcUtil

public final class RpcUtil
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
static final io.netty.channel.ChannelInboundHandlerAdapter	STAGE_RPC_MESSAGE_PARSER
static final io.netty.channel.ChannelInboundHandlerAdapter	STAGE_RPC_TCP_RESPONSE
static final io.netty.channel.ChannelInboundHandlerAdapter	STAGE_RPC_UDP_RESPONSE

Constructor Summary

Constructors

Constructor	Description
RpcUtil()

Method Summary

Modifier and Type	Method	Description
static io.netty.handler.codec.ByteToMessageDecoder	constructRpcFrameDecoder()
static int	getNewXid(String caller)
static void	sendRpcResponse(io.netty.channel.ChannelHandlerContext ctx, RpcResponse response)

Methods inherited from class java.lang.Object

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

Field Details

STAGE_RPC_MESSAGE_PARSER

public static final io.netty.channel.ChannelInboundHandlerAdapter STAGE_RPC_MESSAGE_PARSER

STAGE_RPC_TCP_RESPONSE

public static final io.netty.channel.ChannelInboundHandlerAdapter STAGE_RPC_TCP_RESPONSE

STAGE_RPC_UDP_RESPONSE

public static final io.netty.channel.ChannelInboundHandlerAdapter STAGE_RPC_UDP_RESPONSE

Constructor Details

RpcUtil

public RpcUtil()

Method Details

getNewXid

public static int getNewXid(String caller)

sendRpcResponse

public static void sendRpcResponse(io.netty.channel.ChannelHandlerContext ctx,
 RpcResponse response)

constructRpcFrameDecoder

public static io.netty.handler.codec.ByteToMessageDecoder constructRpcFrameDecoder()