alluxio.network.netty

Class NettyRPC

java.lang.Object

alluxio.network.netty.NettyRPC

public final class NettyRPC
extends Object

Netty blocking RPC client. This provides a simple way to send a request and wait for response via netty. The user needs to make sure that the request is properly handled on the server.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	NettyRPC.RPCHandler Netty RPC client handler.

Method Summary

Modifier and Type	Method and Description
static ProtoMessage	call(NettyRPCContext context, ProtoMessage request) Sends a request and waits for a response.
static void	fireAndForget(NettyRPCContext context, ProtoMessage request) Sends a request and waits until the request is flushed to network.

Methods inherited from class java.lang.Object

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

Method Detail

call

public static ProtoMessage call(NettyRPCContext context,
                                ProtoMessage request)
                         throws IOException

Sends a request and waits for a response.

Parameters:

context - the netty RPC context

request - the RPC request

Returns:

the RPC response

Throws:

IOException

fireAndForget

public static void fireAndForget(NettyRPCContext context,
                                 ProtoMessage request)
                          throws IOException

Sends a request and waits until the request is flushed to network. The caller of this method should expect no response from the server and hence the service handler on server side should not return any response or there will be issues. This method is typically used for RPCs providing best efforts (e.g., async cache).

Parameters:

context - the netty RPC context

request - the RPC request

Throws:

IOException