org.apache.hadoop.hbase.thrift

Class TestThriftServerCmdLine

java.lang.Object

org.apache.hadoop.hbase.thrift.TestThriftServerCmdLine

Direct Known Subclasses:

TestThrift2ServerCmdLine

public class TestThriftServerCmdLine
extends Object

Start the HBase Thrift server on a random port through the command-line interface and talk to it from client side.

Field Summary

Fields

Modifier and Type	Field and Description
static HBaseClassTestRule	CLASS_RULE
protected org.apache.hadoop.hbase.thrift.ImplType	implType
private static org.slf4j.Logger	LOG
protected boolean	specifyBindIP
protected boolean	specifyCompact
protected boolean	specifyFramed
protected static boolean	tableCreated
protected static HBaseTestingUtility	TEST_UTIL

Constructor Summary

Constructors

Constructor and Description
TestThriftServerCmdLine(org.apache.hadoop.hbase.thrift.ImplType implType, boolean specifyFramed, boolean specifyBindIP, boolean specifyCompact)

Method Summary

Modifier and Type	Method and Description
(package private) static ThriftServerRunner	createBoundServer(Supplier<org.apache.hadoop.hbase.thrift.ThriftServer> thriftServerSupplier)
(package private) static ThriftServerRunner	createBoundServer(Supplier<org.apache.hadoop.hbase.thrift.ThriftServer> thriftServerSupplier, boolean protocolPortClash, boolean infoPortClash)
(package private) static ThriftServerRunner	createBoundServer(Supplier<org.apache.hadoop.hbase.thrift.ThriftServer> thriftServerSupplier, org.apache.hadoop.hbase.thrift.ImplType implType, boolean specifyFramed, boolean specifyCompact, boolean specifyBindIP)
(package private) static ThriftServerRunner	createBoundServer(Supplier<org.apache.hadoop.hbase.thrift.ThriftServer> thriftServerSupplier, org.apache.hadoop.hbase.thrift.ImplType implType, boolean specifyFramed, boolean specifyCompact, boolean specifyBindIP, boolean protocolPortClash, boolean infoPortClash)
static Collection<Object[]>	getParameters()
private String	getParametersString()
(package private) static int	getRandomPort()
protected Supplier<org.apache.hadoop.hbase.thrift.ThriftServer>	getThriftServerSupplier()
private static boolean	isBindException(Exception cmdLineException)
static void	setUpBeforeClass()
(package private) static ThriftServerRunner	startCmdLineThread(Supplier<org.apache.hadoop.hbase.thrift.ThriftServer> supplier, String[] args)
protected void	talkToThriftServer(int port)
static void	tearDownAfterClass()
void	testRunThriftServer()

Methods inherited from class java.lang.Object

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

Field Detail

CLASS_RULE

public static final HBaseClassTestRule CLASS_RULE

LOG

private static final org.slf4j.Logger LOG

implType

protected final org.apache.hadoop.hbase.thrift.ImplType implType

specifyFramed

protected boolean specifyFramed

specifyBindIP

protected boolean specifyBindIP

specifyCompact

protected boolean specifyCompact

TEST_UTIL

protected static final HBaseTestingUtility TEST_UTIL

tableCreated

protected static volatile boolean tableCreated

Constructor Detail

TestThriftServerCmdLine

public TestThriftServerCmdLine(org.apache.hadoop.hbase.thrift.ImplType implType,
                               boolean specifyFramed,
                               boolean specifyBindIP,
                               boolean specifyCompact)

Method Detail

getParameters

public static Collection<Object[]> getParameters()

getParametersString

private String getParametersString()

setUpBeforeClass

public static void setUpBeforeClass()
                             throws Exception

Throws:

Exception

tearDownAfterClass

public static void tearDownAfterClass()
                               throws Exception

Throws:

Exception

startCmdLineThread

static ThriftServerRunner startCmdLineThread(Supplier<org.apache.hadoop.hbase.thrift.ThriftServer> supplier,
                                             String[] args)

getRandomPort

static int getRandomPort()

getThriftServerSupplier

protected Supplier<org.apache.hadoop.hbase.thrift.ThriftServer> getThriftServerSupplier()

createBoundServer

static ThriftServerRunner createBoundServer(Supplier<org.apache.hadoop.hbase.thrift.ThriftServer> thriftServerSupplier)
                                     throws Exception

Throws:

Exception

createBoundServer

static ThriftServerRunner createBoundServer(Supplier<org.apache.hadoop.hbase.thrift.ThriftServer> thriftServerSupplier,
                                            boolean protocolPortClash,
                                            boolean infoPortClash)
                                     throws Exception

Throws:

Exception

createBoundServer

static ThriftServerRunner createBoundServer(Supplier<org.apache.hadoop.hbase.thrift.ThriftServer> thriftServerSupplier,
                                            org.apache.hadoop.hbase.thrift.ImplType implType,
                                            boolean specifyFramed,
                                            boolean specifyCompact,
                                            boolean specifyBindIP)
                                     throws Exception

Throws:

Exception

createBoundServer

static ThriftServerRunner createBoundServer(Supplier<org.apache.hadoop.hbase.thrift.ThriftServer> thriftServerSupplier,
                                            org.apache.hadoop.hbase.thrift.ImplType implType,
                                            boolean specifyFramed,
                                            boolean specifyCompact,
                                            boolean specifyBindIP,
                                            boolean protocolPortClash,
                                            boolean infoPortClash)
                                     throws Exception

Parameters:

protocolPortClash - This param is just so we can manufacture a port clash so we can test the code does the right thing when this happens during actual test runs. Ugly but works.

Throws:

Exception

See Also:

TestBindExceptionHandling.testProtocolPortClash()

isBindException

private static boolean isBindException(Exception cmdLineException)

testRunThriftServer

public void testRunThriftServer()
                         throws Exception

Throws:

Exception

talkToThriftServer

protected void talkToThriftServer(int port)
                           throws Exception

Throws:

Exception