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

get rid of extra payload local variable

Browse Source
This commit is contained in:
Alexander Polcyn
2017-02-09 16:16:18 -08:00
parent a0bd789da9
commit bcc367f343
1 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
benchmark/benchmark.go
View File

@ -81,8 +81,9 @@ func (s *testServer) UnaryCall(ctx context.Context, in *testpb.SimpleRequest) (*
} }
func (s *testServer) StreamingCall(stream testpb.BenchmarkService_StreamingCallServer) error { func (s *testServer) StreamingCall(stream testpb.BenchmarkService_StreamingCallServer) error {
response := new(testpb.SimpleResponse) response := &testpb.SimpleResponse{
payload := new(testpb.Payload) Payload: new(testpb.Payload),
}
in := new(testpb.SimpleRequest) in := new(testpb.SimpleRequest)
for { for {
// use ServerStream directly to reuse the same testpb.SimpleRequest object // use ServerStream directly to reuse the same testpb.SimpleRequest object
@ -94,8 +95,7 @@ func (s *testServer) StreamingCall(stream testpb.BenchmarkService_StreamingCallS
if err != nil { if err != nil {
return err return err
} }
setPayload(payload, in.ResponseType, int(in.ResponseSize)) setPayload(response.Payload, in.ResponseType, int(in.ResponseSize))
response.Payload = payload
if err := stream.Send(response); err != nil { if err := stream.Send(response); err != nil {
return err return err
} }