io.grpc.internal.testing

Class AbstractTransportTest

java.lang.Object

io.grpc.internal.testing.AbstractTransportTest

public abstract class AbstractTransportTest
extends Object

Standard unit tests for ClientTransports and ServerTransports.

Field Summary

Fields

Modifier and Type	Field and Description
org.junit.rules.ExpectedException	thrown

Constructor Summary

Constructors

Constructor and Description
AbstractTransportTest()

Method Summary

Modifier and Type	Method and Description
void	authorityPropagation()
void	basicStream()
void	clientCancel()
void	clientCancelFromWithinMessageRead()
void	clientStartAndStopOnceConnected()
void	clientStartStop()
void	earlyServerClose_noServerHeaders()
void	earlyServerClose_serverFailure()
void	earlyServerClose_withServerHeaders()
void	flowControlPushBack()
void	frameAfterRstStreamShouldNotBreakClientChannel() Test for issue https://github.com/grpc/grpc-java/issues/1682
void	interactionsAfterClientStreamCancelAreNoops()
void	interactionsAfterServerStreamCloseAreNoops()
protected abstract boolean	metricsExpected() Returns true if the transport creates StatsTraceContext for each stream and records measurements with it.
protected abstract io.grpc.internal.ManagedClientTransport	newClientTransport(io.grpc.internal.InternalServer server) Returns a new transport that when started will be able to connect to server.
protected abstract io.grpc.internal.InternalServer	newServer(io.grpc.internal.InternalServer server, List<io.grpc.ServerStreamTracer.Factory> streamTracerFactories) Builds a new server that is listening on the same location as the given server instance does.
protected abstract io.grpc.internal.InternalServer	newServer(List<io.grpc.ServerStreamTracer.Factory> streamTracerFactories) Returns a new server that when started will be able to be connected to from the client.
void	newStream_afterTermination()
void	newStream_duringShutdown()
void	openStreamPreventsTermination()
void	ping_afterTermination()
void	ping_duringShutdown()
void	ping()
void	serverAlreadyListening()
void	serverCancel()
void	serverNotListening()
void	setUp()
void	shutdownNowKillsClientStream()
void	shutdownNowKillsServerStream()
void	tearDown()
protected abstract String	testAuthority(io.grpc.internal.InternalServer server) Returns the authority string used by a client to connect to server.
void	transportInUse_clientCancel()
void	transportInUse_normalClose()
void	zeroMessageStream()

Methods inherited from class java.lang.Object

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

Field Detail

thrown

public org.junit.rules.ExpectedException thrown

Constructor Detail

AbstractTransportTest

public AbstractTransportTest()

Method Detail

newServer

protected abstract io.grpc.internal.InternalServer newServer(List<io.grpc.ServerStreamTracer.Factory> streamTracerFactories)

Returns a new server that when started will be able to be connected to from the client. Each returned instance should be new and yet be accessible by new client transports.

newServer

protected abstract io.grpc.internal.InternalServer newServer(io.grpc.internal.InternalServer server,
                                                             List<io.grpc.ServerStreamTracer.Factory> streamTracerFactories)

Builds a new server that is listening on the same location as the given server instance does.

newClientTransport

protected abstract io.grpc.internal.ManagedClientTransport newClientTransport(io.grpc.internal.InternalServer server)

Returns a new transport that when started will be able to connect to server.

testAuthority

protected abstract String testAuthority(io.grpc.internal.InternalServer server)

Returns the authority string used by a client to connect to server.

metricsExpected

protected abstract boolean metricsExpected()

Returns true if the transport creates StatsTraceContext for each stream and records measurements with it.

setUp

public void setUp()

tearDown

public void tearDown()
              throws InterruptedException

Throws:

InterruptedException

frameAfterRstStreamShouldNotBreakClientChannel

public void frameAfterRstStreamShouldNotBreakClientChannel()
                                                    throws Exception

Test for issue https://github.com/grpc/grpc-java/issues/1682

Throws:

Exception

serverNotListening

public void serverNotListening()
                        throws Exception

Throws:

Exception

clientStartStop

public void clientStartStop()
                     throws Exception

Throws:

Exception

clientStartAndStopOnceConnected

public void clientStartAndStopOnceConnected()
                                     throws Exception

Throws:

Exception

serverAlreadyListening

public void serverAlreadyListening()
                            throws Exception

Throws:

Exception

openStreamPreventsTermination

public void openStreamPreventsTermination()
                                   throws Exception

Throws:

Exception

shutdownNowKillsClientStream

public void shutdownNowKillsClientStream()
                                  throws Exception

Throws:

Exception

shutdownNowKillsServerStream

public void shutdownNowKillsServerStream()
                                  throws Exception

Throws:

Exception

ping

public void ping()
          throws Exception

Throws:

Exception

ping_duringShutdown

public void ping_duringShutdown()
                         throws Exception

Throws:

Exception

ping_afterTermination

public void ping_afterTermination()
                           throws Exception

Throws:

Exception

newStream_duringShutdown

public void newStream_duringShutdown()
                              throws Exception

Throws:

Exception

newStream_afterTermination

public void newStream_afterTermination()
                                throws Exception

Throws:

Exception

transportInUse_normalClose

public void transportInUse_normalClose()
                                throws Exception

Throws:

Exception

transportInUse_clientCancel

public void transportInUse_clientCancel()
                                 throws Exception

Throws:

Exception

basicStream

public void basicStream()
                 throws Exception

Throws:

Exception

authorityPropagation

public void authorityPropagation()
                          throws Exception

Throws:

Exception

zeroMessageStream

public void zeroMessageStream()
                       throws Exception

Throws:

Exception

earlyServerClose_withServerHeaders

public void earlyServerClose_withServerHeaders()
                                        throws Exception

Throws:

Exception

earlyServerClose_noServerHeaders

public void earlyServerClose_noServerHeaders()
                                      throws Exception

Throws:

Exception

earlyServerClose_serverFailure

public void earlyServerClose_serverFailure()
                                    throws Exception

Throws:

Exception

clientCancel

public void clientCancel()
                  throws Exception

Throws:

Exception

clientCancelFromWithinMessageRead

public void clientCancelFromWithinMessageRead()
                                       throws Exception

Throws:

Exception

serverCancel

public void serverCancel()
                  throws Exception

Throws:

Exception

flowControlPushBack

public void flowControlPushBack()
                         throws Exception

Throws:

Exception

interactionsAfterServerStreamCloseAreNoops

public void interactionsAfterServerStreamCloseAreNoops()
                                                throws Exception

Throws:

Exception

interactionsAfterClientStreamCancelAreNoops

public void interactionsAfterClientStreamCancelAreNoops()
                                                 throws Exception

Throws:

Exception