grpc/test/end2end_test.go

84 type s struct {  struct
85 	grpctest.Tester
88 func Test(t *testing.T) {
562 func newTest(t *testing.T, e env) *test {
686 	s *http.Server  member
905 func (s) TestContextDeadlineNotIgnored(t *testing.T) {
940 func (s) TestTimeoutOnDeadServer(t *testing.T) {
946 func testTimeoutOnDeadServer(t *testing.T, e env) {
986 func (s) TestServerGracefulStopIdempotent(t *testing.T) {
995 func testServerGracefulStopIdempotent(t *testing.T, e env) {
1006 func (s) TestServerGoAway(t *testing.T) {
1015 func testServerGoAway(t *testing.T, e env) {
1053 func (s) TestServerGoAwayPendingRPC(t *testing.T) {
1062 func testServerGoAwayPendingRPC(t *testing.T, e env) {
1127 func (s) TestServerMultipleGoAwayPendingRPC(t *testing.T) {
1136 func testServerMultipleGoAwayPendingRPC(t *testing.T, e env) {
1214 func (s) TestConcurrentClientConnCloseAndServerGoAway(t *testing.T) {
1223 func testConcurrentClientConnCloseAndServerGoAway(t *testing.T, e env) {
1253 func (s) TestConcurrentServerStopAndGoAway(t *testing.T) {
1262 func testConcurrentServerStopAndGoAway(t *testing.T, e env) {
1338 func (s) TestDetailedConnectionCloseErrorPropagatesToRpcError(t *testing.T) {
1385 func (s) TestDetailedGoawayErrorOnGracefulClosePropagatesToRPCError(t *testing.T) {
1418 func (s) TestDetailedGoawayErrorOnAbruptClosePropagatesToRPCError(t *testing.T) {
1463 func (s) TestClientConnCloseAfterGoAwayWithActiveStream(t *testing.T) {
1472 func testClientConnCloseAfterGoAwayWithActiveStream(t *testing.T, e env) {
1499 func (s) TestFailFast(t *testing.T) {
1505 func testFailFast(t *testing.T, e env) {
1547 func testServiceConfigSetup(t *testing.T, e env) *test {
1573 func (s) TestGetMethodConfig(t *testing.T) {
1660 func (s) TestServiceConfigWaitForReady(t *testing.T) {
1749 func (s) TestServiceConfigTimeout(t *testing.T) {
1847 func (s) TestServiceConfigMaxMsgSize(t *testing.T) {
2108 func (s) TestStreamingRPCWithTimeoutInServiceConfigRecv(t *testing.T) {
2177 func (s) TestPreloaderClientSend(t *testing.T) {
2183 func testPreloaderClientSend(t *testing.T, e env) {
2251 func (s) TestMaxMsgSizeClientDefault(t *testing.T) {
2257 func testMaxMsgSizeClientDefault(t *testing.T, e env) {
2314 func (s) TestMaxMsgSizeClientAPI(t *testing.T) {
2320 func testMaxMsgSizeClientAPI(t *testing.T, e env) {
2404 func (s) TestMaxMsgSizeServerAPI(t *testing.T) {
2410 func testMaxMsgSizeServerAPI(t *testing.T, e env) {
2495 func (s) TestTap(t *testing.T) {
2522 func testTap(t *testing.T, e env) {
2579 func verifyHealthCheckStatus(t *testing.T, d time.Duration, cc *grpc.ClientConn, service string, wa…
2592 func verifyHealthCheckErrCode(t *testing.T, d time.Duration, cc *grpc.ClientConn, service string, w…
2601 func newHealthCheckStream(t *testing.T, cc *grpc.ClientConn, service string) (healthgrpc.Health_Wat…
2614 func healthWatchChecker(t *testing.T, stream healthgrpc.Health_WatchClient, wantStatus healthpb.Hea…
2627 func (s) TestHealthCheckSuccess(t *testing.T) {
2633 func testHealthCheckSuccess(t *testing.T, e env) {
2645 func (s) TestHealthCheckFailure(t *testing.T) {
2651 func testHealthCheckFailure(t *testing.T, e env) {
2669 func (s) TestHealthCheckOff(t *testing.T) {
2679 func testHealthCheckOff(t *testing.T, e env) {
2690 func (s) TestHealthWatchMultipleClients(t *testing.T) {
2696 func testHealthWatchMultipleClients(t *testing.T, e env) {
2719 func (s) TestHealthWatchSameStatus(t *testing.T) {
2725 func testHealthWatchSameStatus(t *testing.T, e env) {
2745 func (s) TestHealthWatchServiceStatusSetBeforeStartingServer(t *testing.T) {
2751 func testHealthWatchSetServiceStatusBeforeStartingServer(t *testing.T, e env) {
2768 func (s) TestHealthWatchDefaultStatusChange(t *testing.T) {
2774 func testHealthWatchDefaultStatusChange(t *testing.T, e env) {
2789 func (s) TestHealthWatchSetServiceStatusBeforeClientCallsWatch(t *testing.T) {
2795 func testHealthWatchSetServiceStatusBeforeClientCallsWatch(t *testing.T, e env) {
2809 func (s) TestHealthWatchOverallServerHealthChange(t *testing.T) {
2815 func testHealthWatchOverallServerHealthChange(t *testing.T, e env) {
2831 func (s) TestUnknownHandler(t *testing.T) {
2847 func testUnknownHandler(t *testing.T, e env, unknownHandler grpc.StreamHandler) {
2857 func (s) TestHealthCheckServingStatus(t *testing.T) {
2863 func testHealthCheckServingStatus(t *testing.T, e env) {
2878 func (s) TestEmptyUnaryWithUserAgent(t *testing.T) {
2884 func testEmptyUnaryWithUserAgent(t *testing.T, e env) {
2906 func (s) TestFailedEmptyUnary(t *testing.T) {
2917 func testFailedEmptyUnary(t *testing.T, e env) {
2931 func (s) TestLargeUnary(t *testing.T) {
2937 func testLargeUnary(t *testing.T, e env) {
2971 func (s) TestExceedMsgLimit(t *testing.T) {
2977 func testExceedMsgLimit(t *testing.T, e env) {
3054 func (s) TestPeerClientSide(t *testing.T) {
3060 func testPeerClientSide(t *testing.T, e env) {
3095 func (s) TestPeerNegative(t *testing.T) {
3101 func testPeerNegative(t *testing.T, e env) {
3114 func (s) TestPeerFailedRPC(t *testing.T) {
3120 func testPeerFailedRPC(t *testing.T, e env) {
3171 func (s) TestMetadataUnaryRPC(t *testing.T) {
3177 func testMetadataUnaryRPC(t *testing.T, e env) {
3216 func (s) TestMetadataOrderUnaryRPC(t *testing.T) {
3222 func testMetadataOrderUnaryRPC(t *testing.T, e env) {
3253 func (s) TestMultipleSetTrailerUnaryRPC(t *testing.T) {
3259 func testMultipleSetTrailerUnaryRPC(t *testing.T, e env) {
3290 func (s) TestMultipleSetTrailerStreamingRPC(t *testing.T) {
3296 func testMultipleSetTrailerStreamingRPC(t *testing.T, e env) {
3321 func (s) TestSetAndSendHeaderUnaryRPC(t *testing.T) {
3331 func testSetAndSendHeaderUnaryRPC(t *testing.T, e env) {
3364 func (s) TestMultipleSetHeaderUnaryRPC(t *testing.T) {
3374 func testMultipleSetHeaderUnaryRPC(t *testing.T, e env) {
3408 func (s) TestMultipleSetHeaderUnaryRPCError(t *testing.T) {
3418 func testMultipleSetHeaderUnaryRPCError(t *testing.T, e env) {
3451 func (s) TestSetAndSendHeaderStreamingRPC(t *testing.T) {
3461 func testSetAndSendHeaderStreamingRPC(t *testing.T, e env) {
3491 func (s) TestMultipleSetHeaderStreamingRPC(t *testing.T) {
3501 func testMultipleSetHeaderStreamingRPC(t *testing.T, e env) {
3555 func (s) TestMultipleSetHeaderStreamingRPCError(t *testing.T) {
3565 func testMultipleSetHeaderStreamingRPCError(t *testing.T, e env) {
3619 func (s) TestMalformedHTTP2Metadata(t *testing.T) {
3630 func testMalformedHTTP2Metadata(t *testing.T, e env) {
3654 func (s) TestTransparentRetry(t *testing.T) {
3726 func (s) TestCancel(t *testing.T) {
3732 func testCancel(t *testing.T, e env) {
3762 func (s) TestCancelNoIO(t *testing.T) {
3768 func testCancelNoIO(t *testing.T, e env) {
3830 func (s) TestNoService(t *testing.T) {
3836 func testNoService(t *testing.T, e env) {
3853 func (s) TestPingPong(t *testing.T) {
3859 func testPingPong(t *testing.T, e env) {
3912 func (s) TestMetadataStreamingRPC(t *testing.T) {
3918 func testMetadataStreamingRPC(t *testing.T, e env) {
3989 func (s) TestServerStreaming(t *testing.T) {
3995 func testServerStreaming(t *testing.T, e env) {
4046 func (s) TestFailedServerStreaming(t *testing.T) {
4052 func testFailedServerStreaming(t *testing.T, e env) {
4106 func (s) TestServerStreamingConcurrent(t *testing.T) {
4112 func testServerStreamingConcurrent(t *testing.T, e env) {
4187 func (s) TestClientStreaming(t *testing.T) {
4195 func testClientStreaming(t *testing.T, e env, sizes []int) {
4232 func (s) TestClientStreamingError(t *testing.T) {
4241 func testClientStreamingError(t *testing.T, e env) {
4274 func (s) TestExceedMaxStreamsLimit(t *testing.T) {
4280 func testExceedMaxStreamsLimit(t *testing.T, e env) {
4314 func (s) TestStreamsQuotaRecovery(t *testing.T) {
4320 func testStreamsQuotaRecovery(t *testing.T, e env) {
4387 func (s) TestCompressServerHasNoSupport(t *testing.T) {
4393 func testCompressServerHasNoSupport(t *testing.T, e env) {
4429 func (s) TestCompressOK(t *testing.T) {
4435 func testCompressOK(t *testing.T, e env) {
4492 func (s) TestIdentityEncoding(t *testing.T) {
4498 func testIdentityEncoding(t *testing.T, e env) {
4546 func (s) TestUnaryClientInterceptor(t *testing.T) {
4560 func testUnaryClientInterceptor(t *testing.T, e env) {
4575 func (s) TestStreamClientInterceptor(t *testing.T) {
4589 func testStreamClientInterceptor(t *testing.T, e env) {
4617 func (s) TestUnaryServerInterceptor(t *testing.T) {
4627 func testUnaryServerInterceptor(t *testing.T, e env) {
4641 func (s) TestStreamServerInterceptor(t *testing.T) {
4659 func testStreamServerInterceptor(t *testing.T, e env) {
4724 func (s) TestClientRequestBodyErrorUnexpectedEOF(t *testing.T) {
4730 func testClientRequestBodyErrorUnexpectedEOF(t *testing.T, e env) {
4747 func (s) TestClientRequestBodyErrorCloseAfterLength(t *testing.T) {
4753 func testClientRequestBodyErrorCloseAfterLength(t *testing.T, e env) {
4771 func (s) TestClientRequestBodyErrorCancel(t *testing.T) {
4777 func testClientRequestBodyErrorCancel(t *testing.T, e env) {
4807 func (s) TestClientRequestBodyErrorCancelStreamingInput(t *testing.T) {
4813 func testClientRequestBodyErrorCancelStreamingInput(t *testing.T, e env) {
4841 func (s) TestClientInitialHeaderEndStream(t *testing.T) {
4850 func testClientInitialHeaderEndStream(t *testing.T, e env) {
4885 func (s) TestClientSendDataAfterCloseSend(t *testing.T) {
4894 func testClientSendDataAfterCloseSend(t *testing.T, e env) {
4941 func (s) TestClientResourceExhaustedCancelFullDuplex(t *testing.T) {
4951 func testClientResourceExhaustedCancelFullDuplex(t *testing.T, e env) {
5033 func (s) TestFailfastRPCFailOnFatalHandshakeError(t *testing.T) {
5055 func (s) TestFlowControlLogicalRace(t *testing.T) {
5234 func declareLogNoise(t *testing.T, phrases ...string) (restore func()) {
5281 func (s) TestGRPCMethod(t *testing.T) {
5319 func (s) TestForceCodecName(t *testing.T) {
5357 func (s) TestForceServerCodec(t *testing.T) {
5388 func (s) TestUnaryProxyDoesNotForwardMetadata(t *testing.T) {
5436 func (s) TestStreamingProxyDoesNotForwardMetadata(t *testing.T) {
5500 func (s) TestStatsTagsAndTrace(t *testing.T) {
5555 func (s) TestTapTimeout(t *testing.T) {
5591 func (s) TestClientWriteFailsAfterServerClosesStream(t *testing.T) {
5633 func (s) TestConfigurableWindowSizeWithLargeWindow(t *testing.T) {
5645 func (s) TestConfigurableWindowSizeWithSmallWindow(t *testing.T) {
5657 func testConfigurableWindowSize(t *testing.T, e env, wc windowSizeConfig) {
5706 func (s) TestWaitForReadyConnection(t *testing.T) {
5713 func testWaitForReadyConnection(t *testing.T, e env) {
5784 func (s) TestEncodeDoesntPanic(t *testing.T) {
5790 func testEncodeDoesntPanic(t *testing.T, e env) {
5809 func (s) TestSvrWriteStatusEarlyWrite(t *testing.T) {
5815 func testSvrWriteStatusEarlyWrite(t *testing.T, e env) {
5872 func testServiceConfigSetupTD(t *testing.T, e env) (*test, chan grpc.ServiceConfig) {
5887 func (s) TestServiceConfigGetMethodConfigTD(t *testing.T) {
5893 func testGetMethodConfigTD(t *testing.T, e env) {
5938 func (s) TestServiceConfigWaitForReadyTD(t *testing.T) {
5944 func testServiceConfigWaitForReadyTD(t *testing.T, e env) {
6003 func (s) TestServiceConfigTimeoutTD(t *testing.T) {
6009 func testServiceConfigTimeoutTD(t *testing.T, e env) {
6074 func (s) TestServiceConfigMaxMsgSizeTD(t *testing.T) {
6080 func testServiceConfigMaxMsgSizeTD(t *testing.T, e env) {
6294 func (s) TestMethodFromServerStream(t *testing.T) {
6315 func (s) TestInterceptorCanAccessCallOptions(t *testing.T) {
6419 func (s) TestCompressorRegister(t *testing.T) {
6425 func testCompressorRegister(t *testing.T, e env) {
6480 func (s) TestServeExitsWhenListenerClosed(t *testing.T) {
6528 func (s) TestStatusInvalidUTF8Message(t *testing.T) {
6555 func (s) TestStatusInvalidUTF8Details(t *testing.T) {
6592 func (s) TestClientDoesntDeadlockWhileWritingErrornousLargeMessages(t *testing.T) {
6601 func testClientDoesntDeadlockWhileWritingErrornousLargeMessages(t *testing.T, e env) {
6635 func (s) TestRPCTimeout(t *testing.T) {
6641 func testRPCTimeout(t *testing.T, e env) {
6671 func (s) TestDisabledIOBuffers(t *testing.T) {
6751 func (s) TestServerMaxHeaderListSizeClientUserViolation(t *testing.T) {
6760 func testServerMaxHeaderListSizeClientUserViolation(t *testing.T, e env) {
6783 func (s) TestClientMaxHeaderListSizeServerUserViolation(t *testing.T) {
6792 func testClientMaxHeaderListSizeServerUserViolation(t *testing.T, e env) {
6814 func (s) TestServerMaxHeaderListSizeClientIntentionalViolation(t *testing.T) {
6823 func testServerMaxHeaderListSizeClientIntentionalViolation(t *testing.T, e env) {
6856 func (s) TestClientMaxHeaderListSizeServerIntentionalViolation(t *testing.T) {
6865 func testClientMaxHeaderListSizeServerIntentionalViolation(t *testing.T, e env) {
6910 func (s) TestNetPipeConn(t *testing.T) {
6934 func (s) TestLargeTimeout(t *testing.T) {
6940 func testLargeTimeout(t *testing.T, e env) {
6979 func (s) TestGoAwayThenClose(t *testing.T) {
7090 func (s) TestRPCWaitsForResolver(t *testing.T) {
7142 func (s) TestHTTPHeaderFrameErrorHandlingHTTPMode(t *testing.T) {
7173 func (s) TestHTTPHeaderFrameErrorHandlingInitialHeader(t *testing.T) {
7220 func (s) TestHTTPHeaderFrameErrorHandlingNormalTrailer(t *testing.T) {
7254 func (s) TestHTTPHeaderFrameErrorHandlingMoreThanTwoHeaders(t *testing.T) {
7343 func doHTTPHeaderTest(t *testing.T, errCode codes.Code, headerFields ...[]string) {
7379 func (s) TestClientCancellationPropagatesUnary(t *testing.T) {
7444 func (s) TestGzipBadChecksum(t *testing.T) {
7471 func (s) TestCanceledRPCCallOptionRace(t *testing.T) {