Package org.apache.hadoop.oncrpc

Class SimpleTcpClient

java.lang.Object

org.apache.hadoop.oncrpc.SimpleTcpClient

Direct Known Subclasses:

RegistrationClient

public class SimpleTcpClient
extends Object

A simple TCP based RPC client which just sends a request to a server.

Field Summary

Fields

Modifier and Type	Field	Description
protected final String	host
protected final boolean	oneShot
protected final int	port
protected final XDR	request

Constructor Summary

Constructors

Constructor	Description
SimpleTcpClient(String host, int port, XDR request)
SimpleTcpClient(String host, int port, XDR request, Boolean oneShot)

Method Summary

Modifier and Type	Method	Description
void	run()
protected io.netty.channel.ChannelInitializer<io.netty.channel.socket.SocketChannel>	setChannelHandler()
void	stop()

Methods inherited from class java.lang.Object

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

Field Details

host

protected final String host

port

protected final int port

request

protected final XDR request

oneShot

protected final boolean oneShot

Constructor Details

SimpleTcpClient

public SimpleTcpClient(String host,
 int port,
 XDR request)

SimpleTcpClient

public SimpleTcpClient(String host,
 int port,
 XDR request,
 Boolean oneShot)

Method Details

setChannelHandler

protected io.netty.channel.ChannelInitializer<io.netty.channel.socket.SocketChannel> setChannelHandler()

run

@VisibleForTesting
public void run()

stop

public void stop()