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-09-28 13:53:27 -07:00
parent 6fd077118b
commit 23e20165e0
1 changed files with 6 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
interop/test_utils.go
View File

@ -520,9 +520,9 @@ func serverNewPayload(t testpb.PayloadType, size int32) (*testpb.Payload, error)
} }
func (s *testServer) UnaryCall(ctx context.Context, in *testpb.SimpleRequest) (*testpb.SimpleResponse, error) { func (s *testServer) UnaryCall(ctx context.Context, in *testpb.SimpleRequest) (*testpb.SimpleResponse, error) {
resp := in.GetResponseStatus() status := in.GetResponseStatus()
if resp != nil && *resp.Code != 0 { if status != nil && *status.Code != 0 {
return nil, grpc.Errorf(codes.Code(*resp.Code), *resp.Message) return nil, grpc.Errorf(codes.Code(*status.Code), *status.Message)
} }
pl, err := serverNewPayload(in.GetResponseType(), in.GetResponseSize()) pl, err := serverNewPayload(in.GetResponseType(), in.GetResponseSize())
if err != nil { if err != nil {
@ -579,9 +579,9 @@ func (s *testServer) FullDuplexCall(stream testpb.TestService_FullDuplexCallServ
if err != nil { if err != nil {
return err return err
} }
resp := in.GetResponseStatus() status := in.GetResponseStatus()
if resp != nil && *resp.Code != 0 { if status != nil && *status.Code != 0 {
return grpc.Errorf(codes.Code(*resp.Code), *resp.Message) return grpc.Errorf(codes.Code(*status.Code), *status.Message)
} }
cs := in.GetResponseParameters() cs := in.GetResponseParameters()
for _, c := range cs { for _, c := range cs {