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

Code review changes.

Browse Source
This commit is contained in:
Mark D. Roth
2016-08-26 12:59:51 -07:00
parent 43b65b892d
commit 44e75c33ee
1 changed files with 5 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
interop/test_utils.go
View File

@ -458,7 +458,7 @@ func DoCancelAfterFirstResponse(tc testpb.TestServiceClient) {
func DoStatusCodeAndMessage(tc testpb.TestServiceClient) { func DoStatusCodeAndMessage(tc testpb.TestServiceClient) {
var code int32 = 2 var code int32 = 2
msg := "test status message" msg := "test status message"
expectedErr := grpc.Errorf(codes.Code(code), msg) expectedErr := grpc.Errorf(codes.Code(code), msg)
respStatus := &testpb.EchoStatus{ respStatus := &testpb.EchoStatus{
Code: proto.Int32(code), Code: proto.Int32(code),
Message: proto.String(msg), Message: proto.String(msg),
@ -468,7 +468,7 @@ func DoStatusCodeAndMessage(tc testpb.TestServiceClient) {
ResponseStatus: respStatus, ResponseStatus: respStatus,
} }
if _, err := tc.UnaryCall(context.Background(), req); err.Error() != expectedErr.Error() { if _, err := tc.UnaryCall(context.Background(), req); err.Error() != expectedErr.Error() {
grpclog.Fatalf("UnaryCall RPC returned error %v, want %v", err, expectedErr) grpclog.Fatalf("%v.UnaryCall(_, %v) = _, %v, want _, %v", tc, req, err, expectedErr)
} }
// Test FullDuplexCall. // Test FullDuplexCall.
stream, err := tc.FullDuplexCall(context.Background()) stream, err := tc.FullDuplexCall(context.Background())
@ -479,13 +479,13 @@ func DoStatusCodeAndMessage(tc testpb.TestServiceClient) {
ResponseStatus: respStatus, ResponseStatus: respStatus,
} }
if err := stream.Send(stream_req); err != nil { if err := stream.Send(stream_req); err != nil {
grpclog.Fatalf("stream %v.Send(%v) = %v, want <nil>", stream, stream_req, err) grpclog.Fatalf("%v.Send(%v) = %v, want <nil>", stream, stream_req, err)
} }
if err := stream.CloseSend(); err != nil { if err := stream.CloseSend(); err != nil {
grpclog.Fatalf("stream %v.CloseSend() = %v, want <nil>", stream, err) grpclog.Fatalf("%v.CloseSend() = %v, want <nil>", stream, err)
} }
if _, err = stream.Recv(); err.Error() != expectedErr.Error() { if _, err = stream.Recv(); err.Error() != expectedErr.Error() {
grpclog.Fatalf("stream %v.Recv() returned error %v, want %v", err, expectedErr) grpclog.Fatalf("%v.Recv() returned error %v, want %v", stream, err, expectedErr)
} }
} }