Package org.apache.hadoop.hbase.thrift

Class TestThriftServerCmdLine

java.lang.Object

org.apache.hadoop.hbase.thrift.TestThriftServerCmdLine

Direct Known Subclasses:

TestThrift2ServerCmdLine

@Tag("org.apache.hadoop.hbase.testclassification.ClientTests") @Tag("org.apache.hadoop.hbase.testclassification.LargeTests")
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
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 HBaseTestingUtil	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)
private String	getParametersString()
(package private) static int	getRandomPort()
protected Supplier<org.apache.hadoop.hbase.thrift.ThriftServer>	getThriftServerSupplier()
private static boolean	isBindException(Exception cmdLineException)
static Stream<org.junit.jupiter.params.provider.Arguments>	parameters()
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

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 HBaseTestingUtil 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

parameters

public static Stream<org.junit.jupiter.params.provider.Arguments> parameters()

getParametersString

private String getParametersString()

setUpBeforeClass

@BeforeAll
public static void setUpBeforeClass()
                             throws Exception

Throws:

Exception

tearDownAfterClass

@AfterAll
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

@TestTemplate
public void testRunThriftServer()
                         throws Exception

Throws:

Exception

talkToThriftServer

protected void talkToThriftServer(int port)
                           throws Exception

Throws:

Exception