alluxio.network.thrift

Class ThriftUtils

java.lang.Object

alluxio.network.thrift.ThriftUtils

public final class ThriftUtils
extends Object

Util class for methods to create Thrift communication with Alluxio services.

Method Summary

Modifier and Type	Method and Description
static org.apache.thrift.protocol.TProtocol	createThriftProtocol(org.apache.thrift.transport.TTransport transport, String serviceName)
static org.apache.thrift.protocol.TProtocolFactory	createThriftProtocolFactory()
static org.apache.thrift.transport.TServerSocket	createThriftServerSocket(InetSocketAddress address) Creates a new Thrift server socket that listen on the given address.
static org.apache.thrift.transport.TSocket	createThriftSocket(InetSocketAddress address) Creates a new Thrift socket that will connect to the given address.
static int	getThriftPort(org.apache.thrift.transport.TServerSocket thriftSocket) Gets the port for the underline socket.
static ServerSocket	getThriftSocket(org.apache.thrift.transport.TServerSocket thriftSocket) Extracts internal socket from the thrift socket.

Methods inherited from class java.lang.Object

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

Method Detail

createThriftProtocol

public static org.apache.thrift.protocol.TProtocol createThriftProtocol(org.apache.thrift.transport.TTransport transport,
                                                                        String serviceName)
                                                                 throws UnauthenticatedException

Parameters:

transport - a transport for communicating with an Alluxio Thrift server

serviceName - the service to communicate with

Returns:

a Thrift protocol for communicating with the given service through the transport

Throws:

UnauthenticatedException

createThriftProtocolFactory

public static org.apache.thrift.protocol.TProtocolFactory createThriftProtocolFactory()

Returns:

a Thrift protocol factory for communicating with server through the transport

createThriftSocket

public static org.apache.thrift.transport.TSocket createThriftSocket(InetSocketAddress address)

Creates a new Thrift socket that will connect to the given address.

Parameters:

address - The given address to connect

Returns:

An unconnected socket

createThriftServerSocket

public static org.apache.thrift.transport.TServerSocket createThriftServerSocket(InetSocketAddress address)
                                                                          throws org.apache.thrift.transport.TTransportException

Creates a new Thrift server socket that listen on the given address.

Parameters:

address - The given address to listen on

Returns:

A server socket

Throws:

org.apache.thrift.transport.TTransportException

getThriftPort

public static int getThriftPort(org.apache.thrift.transport.TServerSocket thriftSocket)

Gets the port for the underline socket.

Parameters:

thriftSocket - the underline socket

Returns:

the thrift port for the underline socket

getThriftSocket

public static ServerSocket getThriftSocket(org.apache.thrift.transport.TServerSocket thriftSocket)

Extracts internal socket from the thrift socket. As of thrift 0.9, the internal socket used is not exposed in the API, so this function will use reflection to get access to it.

Parameters:

thriftSocket - the underline thrift socket

Returns:

the server socket