Package 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	Description
static final HBaseClassTestRule	CLASS_RULE
protected final org.apache.hadoop.hbase.thrift.ImplType	implType
private static final org.slf4j.Logger	LOG
protected boolean	specifyBindIP
protected boolean	specifyCompact
protected boolean	specifyFramed
protected static boolean	tableCreated
protected static final HBaseTestingUtility	TEST_UTIL

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	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 Details

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 Details

TestThriftServerCmdLine

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

Method Details

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