opensource/grpc-go
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Add comments and no longer export helper func

Browse Source
This commit is contained in:
Noah Eisen
2016-11-02 15:19:21 -07:00
parent 687c958422
commit 86765df8f8
1 changed files with 5 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
interop/test_utils.go
View File

@ -465,7 +465,7 @@ var (
) )
) )
func ValidateMetadata(header, trailer metadata.MD) { func validateMetadata(header, trailer metadata.MD) {
if len(header[initialMetadataKey]) != 1 { if len(header[initialMetadataKey]) != 1 {
grpclog.Fatalf("Expected exactly one header from server. Received %d", len(header[initialMetadataKey])) grpclog.Fatalf("Expected exactly one header from server. Received %d", len(header[initialMetadataKey]))
} }
@ -505,7 +505,7 @@ func DoCustomMetadata(tc testpb.TestServiceClient) {
if t != testpb.PayloadType_COMPRESSABLE || s != 1 { if t != testpb.PayloadType_COMPRESSABLE || s != 1 {
grpclog.Fatalf("Got the reply with type %d len %d; want %d, %d", t, s, testpb.PayloadType_COMPRESSABLE, 1) grpclog.Fatalf("Got the reply with type %d len %d; want %d, %d", t, s, testpb.PayloadType_COMPRESSABLE, 1)
} }
ValidateMetadata(header, trailer) validateMetadata(header, trailer)
// Testing with FullDuplex // Testing with FullDuplex
stream, err := tc.FullDuplexCall(ctx) stream, err := tc.FullDuplexCall(ctx)
@ -539,7 +539,7 @@ func DoCustomMetadata(tc testpb.TestServiceClient) {
grpclog.Fatalf("%v failed to complete the custom metadata test: %v", stream, err) grpclog.Fatalf("%v failed to complete the custom metadata test: %v", stream, err)
} }
streamTrailer := stream.Trailer() streamTrailer := stream.Trailer()
ValidateMetadata(streamHeader, streamTrailer) validateMetadata(streamHeader, streamTrailer)
} }
// DoStatusCodeAndMessage checks that the status code is propagated back to the client. // DoStatusCodeAndMessage checks that the status code is propagated back to the client.
@ -577,6 +577,7 @@ func DoStatusCodeAndMessage(tc testpb.TestServiceClient) {
} }
} }
// DoUnimplementedService attempts to call a method from an unimplemented service.
func DoUnimplementedService(tc testpb.UnimplementedServiceClient) { func DoUnimplementedService(tc testpb.UnimplementedServiceClient) {
var code int32 = 12 var code int32 = 12
expectedCode := codes.Code(code) expectedCode := codes.Code(code)
@ -586,6 +587,7 @@ func DoUnimplementedService(tc testpb.UnimplementedServiceClient) {
} }
} }
// DoUnimplementedMethod attempts to call an unimplemented method.
func DoUnimplementedMethod(serverAddr string) { func DoUnimplementedMethod(serverAddr string) {
cc, err := grpc.Dial(serverAddr, grpc.WithInsecure(), grpc.WithBlock()) cc, err := grpc.Dial(serverAddr, grpc.WithInsecure(), grpc.WithBlock())
if err != nil { if err != nil {