grpc/test/end2end_test.go

87 type s struct{}  struct
100 func (s) Setup(t *testing.T) {
104 func (s) Teardown(t *testing.T) {
114 func Test(t *testing.T) {
588 func newTest(t *testing.T, e env) *test {
714 	s *http.Server  member
937 func (s) TestContextDeadlineNotIgnored(t *testing.T) {
970 func (s) TestTimeoutOnDeadServer(t *testing.T) {
976 func testTimeoutOnDeadServer(t *testing.T, e env) {
1014 func (s) TestServerGracefulStopIdempotent(t *testing.T) {
1023 func testServerGracefulStopIdempotent(t *testing.T, e env) {
1034 func (s) TestServerGoAway(t *testing.T) {
1043 func testServerGoAway(t *testing.T, e env) {
1081 func (s) TestServerGoAwayPendingRPC(t *testing.T) {
1090 func testServerGoAwayPendingRPC(t *testing.T, e env) {
1155 func (s) TestServerMultipleGoAwayPendingRPC(t *testing.T) {
1164 func testServerMultipleGoAwayPendingRPC(t *testing.T, e env) {
1242 func (s) TestConcurrentClientConnCloseAndServerGoAway(t *testing.T) {
1251 func testConcurrentClientConnCloseAndServerGoAway(t *testing.T, e env) {
1279 func (s) TestConcurrentServerStopAndGoAway(t *testing.T) {
1288 func testConcurrentServerStopAndGoAway(t *testing.T, e env) {
1360 func (s) TestClientConnCloseAfterGoAwayWithActiveStream(t *testing.T) {
1369 func testClientConnCloseAfterGoAwayWithActiveStream(t *testing.T, e env) {
1396 func (s) TestFailFast(t *testing.T) {
1402 func testFailFast(t *testing.T, e env) {
1444 func testServiceConfigSetup(t *testing.T, e env) *test {
1470 func (s) TestGetMethodConfig(t *testing.T) {
1556 func (s) TestServiceConfigWaitForReady(t *testing.T) {
1645 func (s) TestServiceConfigTimeout(t *testing.T) {
1744 func (s) TestServiceConfigMaxMsgSize(t *testing.T) {
2005 func (s) TestStreamingRPCWithTimeoutInServiceConfigRecv(t *testing.T) {
2075 func (s) TestPreloaderClientSend(t *testing.T) {
2081 func testPreloaderClientSend(t *testing.T, e env) {
2149 func (s) TestMaxMsgSizeClientDefault(t *testing.T) {
2155 func testMaxMsgSizeClientDefault(t *testing.T, e env) {
2209 func (s) TestMaxMsgSizeClientAPI(t *testing.T) {
2215 func testMaxMsgSizeClientAPI(t *testing.T, e env) {
2296 func (s) TestMaxMsgSizeServerAPI(t *testing.T) {
2302 func testMaxMsgSizeServerAPI(t *testing.T, e env) {
2384 func (s) TestTap(t *testing.T) {
2408 func testTap(t *testing.T, e env) {
2456 func verifyHealthCheckStatus(t *testing.T, d time.Duration, cc *grpc.ClientConn, service string, wa…
2469 func verifyHealthCheckErrCode(t *testing.T, d time.Duration, cc *grpc.ClientConn, service string, w…
2478 func newHealthCheckStream(t *testing.T, cc *grpc.ClientConn, service string) (healthgrpc.Health_Wat…
2491 func healthWatchChecker(t *testing.T, stream healthgrpc.Health_WatchClient, wantStatus healthpb.Hea…
2504 func (s) TestHealthCheckSuccess(t *testing.T) {
2510 func testHealthCheckSuccess(t *testing.T, e env) {
2522 func (s) TestHealthCheckFailure(t *testing.T) {
2528 func testHealthCheckFailure(t *testing.T, e env) {
2546 func (s) TestHealthCheckOff(t *testing.T) {
2556 func testHealthCheckOff(t *testing.T, e env) {
2567 func (s) TestHealthWatchMultipleClients(t *testing.T) {
2573 func testHealthWatchMultipleClients(t *testing.T, e env) {
2596 func (s) TestHealthWatchSameStatus(t *testing.T) {
2602 func testHealthWatchSameStatus(t *testing.T, e env) {
2622 func (s) TestHealthWatchServiceStatusSetBeforeStartingServer(t *testing.T) {
2628 func testHealthWatchSetServiceStatusBeforeStartingServer(t *testing.T, e env) {
2645 func (s) TestHealthWatchDefaultStatusChange(t *testing.T) {
2651 func testHealthWatchDefaultStatusChange(t *testing.T, e env) {
2666 func (s) TestHealthWatchSetServiceStatusBeforeClientCallsWatch(t *testing.T) {
2672 func testHealthWatchSetServiceStatusBeforeClientCallsWatch(t *testing.T, e env) {
2686 func (s) TestHealthWatchOverallServerHealthChange(t *testing.T) {
2692 func testHealthWatchOverallServerHealthChange(t *testing.T, e env) {
2708 func (s) TestUnknownHandler(t *testing.T) {
2724 func testUnknownHandler(t *testing.T, e env, unknownHandler grpc.StreamHandler) {
2734 func (s) TestHealthCheckServingStatus(t *testing.T) {
2740 func testHealthCheckServingStatus(t *testing.T, e env) {
2755 func (s) TestEmptyUnaryWithUserAgent(t *testing.T) {
2761 func testEmptyUnaryWithUserAgent(t *testing.T, e env) {
2781 func (s) TestFailedEmptyUnary(t *testing.T) {
2792 func testFailedEmptyUnary(t *testing.T, e env) {
2806 func (s) TestLargeUnary(t *testing.T) {
2812 func testLargeUnary(t *testing.T, e env) {
2843 func (s) TestExceedMsgLimit(t *testing.T) {
2849 func testExceedMsgLimit(t *testing.T, e env) {
2923 func (s) TestPeerClientSide(t *testing.T) {
2929 func testPeerClientSide(t *testing.T, e env) {
2962 func (s) TestPeerNegative(t *testing.T) {
2968 func testPeerNegative(t *testing.T, e env) {
2981 func (s) TestPeerFailedRPC(t *testing.T) {
2987 func testPeerFailedRPC(t *testing.T, e env) {
3036 func (s) TestMetadataUnaryRPC(t *testing.T) {
3042 func testMetadataUnaryRPC(t *testing.T, e env) {
3081 func (s) TestMetadataOrderUnaryRPC(t *testing.T) {
3087 func testMetadataOrderUnaryRPC(t *testing.T, e env) {
3118 func (s) TestMultipleSetTrailerUnaryRPC(t *testing.T) {
3124 func testMultipleSetTrailerUnaryRPC(t *testing.T, e env) {
3155 func (s) TestMultipleSetTrailerStreamingRPC(t *testing.T) {
3161 func testMultipleSetTrailerStreamingRPC(t *testing.T, e env) {
3186 func (s) TestSetAndSendHeaderUnaryRPC(t *testing.T) {
3196 func testSetAndSendHeaderUnaryRPC(t *testing.T, e env) {
3229 func (s) TestMultipleSetHeaderUnaryRPC(t *testing.T) {
3239 func testMultipleSetHeaderUnaryRPC(t *testing.T, e env) {
3273 func (s) TestMultipleSetHeaderUnaryRPCError(t *testing.T) {
3283 func testMultipleSetHeaderUnaryRPCError(t *testing.T, e env) {
3316 func (s) TestSetAndSendHeaderStreamingRPC(t *testing.T) {
3326 func testSetAndSendHeaderStreamingRPC(t *testing.T, e env) {
3356 func (s) TestMultipleSetHeaderStreamingRPC(t *testing.T) {
3366 func testMultipleSetHeaderStreamingRPC(t *testing.T, e env) {
3420 func (s) TestMultipleSetHeaderStreamingRPCError(t *testing.T) {
3430 func testMultipleSetHeaderStreamingRPCError(t *testing.T, e env) {
3484 func (s) TestMalformedHTTP2Metadata(t *testing.T) {
3495 func testMalformedHTTP2Metadata(t *testing.T, e env) {
3517 func (s) TestTransparentRetry(t *testing.T) {
3529 func testTransparentRetry(t *testing.T, e env) {
3580 func (s) TestCancel(t *testing.T) {
3586 func testCancel(t *testing.T, e env) {
3616 func (s) TestCancelNoIO(t *testing.T) {
3622 func testCancelNoIO(t *testing.T, e env) {
3684 func (s) TestNoService(t *testing.T) {
3690 func testNoService(t *testing.T, e env) {
3707 func (s) TestPingPong(t *testing.T) {
3713 func testPingPong(t *testing.T, e env) {
3766 func (s) TestMetadataStreamingRPC(t *testing.T) {
3772 func testMetadataStreamingRPC(t *testing.T, e env) {
3843 func (s) TestServerStreaming(t *testing.T) {
3849 func testServerStreaming(t *testing.T, e env) {
3897 func (s) TestFailedServerStreaming(t *testing.T) {
3903 func testFailedServerStreaming(t *testing.T, e env) {
3957 func (s) TestServerStreamingConcurrent(t *testing.T) {
3963 func testServerStreamingConcurrent(t *testing.T, e env) {
4036 func (s) TestClientStreaming(t *testing.T) {
4044 func testClientStreaming(t *testing.T, e env, sizes []int) {
4081 func (s) TestClientStreamingError(t *testing.T) {
4090 func testClientStreamingError(t *testing.T, e env) {
4123 func (s) TestExceedMaxStreamsLimit(t *testing.T) {
4129 func testExceedMaxStreamsLimit(t *testing.T, e env) {
4163 func (s) TestStreamsQuotaRecovery(t *testing.T) {
4169 func testStreamsQuotaRecovery(t *testing.T, e env) {
4236 func (s) TestCompressServerHasNoSupport(t *testing.T) {
4242 func testCompressServerHasNoSupport(t *testing.T, e env) {
4275 func (s) TestCompressOK(t *testing.T) {
4281 func testCompressOK(t *testing.T, e env) {
4338 func (s) TestIdentityEncoding(t *testing.T) {
4344 func testIdentityEncoding(t *testing.T, e env) {
4392 func (s) TestUnaryClientInterceptor(t *testing.T) {
4406 func testUnaryClientInterceptor(t *testing.T, e env) {
4419 func (s) TestStreamClientInterceptor(t *testing.T) {
4433 func testStreamClientInterceptor(t *testing.T, e env) {
4459 func (s) TestUnaryServerInterceptor(t *testing.T) {
4469 func testUnaryServerInterceptor(t *testing.T, e env) {
4481 func (s) TestStreamServerInterceptor(t *testing.T) {
4499 func testStreamServerInterceptor(t *testing.T, e env) {
4562 func (s) TestClientRequestBodyErrorUnexpectedEOF(t *testing.T) {
4568 func testClientRequestBodyErrorUnexpectedEOF(t *testing.T, e env) {
4585 func (s) TestClientRequestBodyErrorCloseAfterLength(t *testing.T) {
4591 func testClientRequestBodyErrorCloseAfterLength(t *testing.T, e env) {
4609 func (s) TestClientRequestBodyErrorCancel(t *testing.T) {
4615 func testClientRequestBodyErrorCancel(t *testing.T, e env) {
4645 func (s) TestClientRequestBodyErrorCancelStreamingInput(t *testing.T) {
4651 func testClientRequestBodyErrorCancelStreamingInput(t *testing.T, e env) {
4679 func (s) TestClientResourceExhaustedCancelFullDuplex(t *testing.T) {
4689 func testClientResourceExhaustedCancelFullDuplex(t *testing.T, e env) {
4772 func (s) TestNonFailFastRPCSucceedOnTimeoutCreds(t *testing.T) {
4818 func (s) TestServerCredsDispatch(t *testing.T) {
4867 func (s) TestCredsHandshakeAuthority(t *testing.T) {
4911 	const testServerName = "test.server.name"
4970 func (s) TestFailfastRPCFailOnFatalHandshakeError(t *testing.T) {
4992 func (s) TestFlowControlLogicalRace(t *testing.T) {
5173 func declareLogNoise(t *testing.T, phrases ...string) (restore func()) {
5234 	s      *grpc.Server  member
5318 func (s) TestGRPCMethod(t *testing.T) {
5345 func (s) TestUnaryProxyDoesNotForwardMetadata(t *testing.T) {
5393 func (s) TestStreamingProxyDoesNotForwardMetadata(t *testing.T) {
5457 func (s) TestStatsTagsAndTrace(t *testing.T) {
5512 func (s) TestTapTimeout(t *testing.T) {
5548 func (s) TestClientWriteFailsAfterServerClosesStream(t *testing.T) {
5590 func (s) TestConfigurableWindowSizeWithLargeWindow(t *testing.T) {
5602 func (s) TestConfigurableWindowSizeWithSmallWindow(t *testing.T) {
5614 func testConfigurableWindowSize(t *testing.T, e env, wc windowSizeConfig) {
5696 func (s) TestPerRPCCredentialsViaDialOptions(t *testing.T) {
5702 func testPerRPCCredentialsViaDialOptions(t *testing.T, e env) {
5716 func (s) TestPerRPCCredentialsViaCallOptions(t *testing.T) {
5722 func testPerRPCCredentialsViaCallOptions(t *testing.T, e env) {
5735 func (s) TestPerRPCCredentialsViaDialOptionsAndCallOptions(t *testing.T) {
5741 func testPerRPCCredentialsViaDialOptionsAndCallOptions(t *testing.T, e env) {
5775 func (s) TestWaitForReadyConnection(t *testing.T) {
5782 func testWaitForReadyConnection(t *testing.T, e env) {
5826 func (s) TestEncodeDoesntPanic(t *testing.T) {
5832 func testEncodeDoesntPanic(t *testing.T, e env) {
5849 func (s) TestSvrWriteStatusEarlyWrite(t *testing.T) {
5855 func testSvrWriteStatusEarlyWrite(t *testing.T, e env) {
5912 func testServiceConfigSetupTD(t *testing.T, e env) (*test, chan grpc.ServiceConfig) {
5927 func (s) TestServiceConfigGetMethodConfigTD(t *testing.T) {
5933 func testGetMethodConfigTD(t *testing.T, e env) {
5977 func (s) TestServiceConfigWaitForReadyTD(t *testing.T) {
5983 func testServiceConfigWaitForReadyTD(t *testing.T, e env) {
6040 func (s) TestServiceConfigTimeoutTD(t *testing.T) {
6046 func testServiceConfigTimeoutTD(t *testing.T, e env) {
6111 func (s) TestServiceConfigMaxMsgSizeTD(t *testing.T) {
6117 func testServiceConfigMaxMsgSizeTD(t *testing.T, e env) {
6328 func (s) TestMethodFromServerStream(t *testing.T) {
6347 func (s) TestInterceptorCanAccessCallOptions(t *testing.T) {
6449 func (s) TestCompressorRegister(t *testing.T) {
6455 func testCompressorRegister(t *testing.T, e env) {
6510 func (s) TestServeExitsWhenListenerClosed(t *testing.T) {
6558 func (s) TestStatusInvalidUTF8Message(t *testing.T) {
6586 func (s) TestStatusInvalidUTF8Details(t *testing.T) {
6622 func (s) TestClientDoesntDeadlockWhileWritingErrornousLargeMessages(t *testing.T) {
6631 func testClientDoesntDeadlockWhileWritingErrornousLargeMessages(t *testing.T, e env) {
6687 func (s) TestFailFastRPCErrorOnBadCertificates(t *testing.T) {
6715 func (s) TestWaitForReadyRPCErrorOnBadCertificates(t *testing.T) {
6738 func (s) TestRPCTimeout(t *testing.T) {
6744 func testRPCTimeout(t *testing.T, e env) {
6774 func (s) TestDisabledIOBuffers(t *testing.T) {
6857 func (s) TestServerMaxHeaderListSizeClientUserViolation(t *testing.T) {
6866 func testServerMaxHeaderListSizeClientUserViolation(t *testing.T, e env) {
6889 func (s) TestClientMaxHeaderListSizeServerUserViolation(t *testing.T) {
6898 func testClientMaxHeaderListSizeServerUserViolation(t *testing.T, e env) {
6920 func (s) TestServerMaxHeaderListSizeClientIntentionalViolation(t *testing.T) {
6929 func testServerMaxHeaderListSizeClientIntentionalViolation(t *testing.T, e env) {
6962 func (s) TestClientMaxHeaderListSizeServerIntentionalViolation(t *testing.T) {
6971 func testClientMaxHeaderListSizeServerIntentionalViolation(t *testing.T, e env) {
7016 func (s) TestNetPipeConn(t *testing.T) {
7040 func (s) TestLargeTimeout(t *testing.T) {
7046 func testLargeTimeout(t *testing.T, e env) {
7085 func (s) TestGoAwayThenClose(t *testing.T) {
7187 func (s) TestRPCWaitsForResolver(t *testing.T) {
7240 func (s) TestHTTPHeaderFrameErrorHandlingHTTPMode(t *testing.T) {
7271 func (s) TestHTTPHeaderFrameErrorHandlingInitialHeader(t *testing.T) {
7318 func (s) TestHTTPHeaderFrameErrorHandlingNormalTrailer(t *testing.T) {
7352 func (s) TestHTTPHeaderFrameErrorHandlingMoreThanTwoHeaders(t *testing.T) {
7431 func doHTTPHeaderTest(t *testing.T, errCode codes.Code, headerFields ...[]string) {
7478 func (s) TestGRPCMethodAccessibleToCredsViaContextRequestInfo(t *testing.T) {
7494 func (s) TestClientCancellationPropagatesUnary(t *testing.T) {
7559 func (s) TestGzipBadChecksum(t *testing.T) {