Fixed multirpc logging (#487)

davidzhao · web-flow · commit 19fdb609a993 · 2023-10-01T19:28:19.000-07:00
diff --git a/psrpc/logging.go b/psrpc/logging.go
@@ -156,12 +156,12 @@ func (r *multiRPCLoggerInterceptor) Send(ctx context.Context, req proto.Message,
 }
 
 func (r *multiRPCLoggerInterceptor) Recv(msg proto.Message, err error) {
-	if err == nil {
+	if err != nil {
 		r.logger.Warnw("received error", err)
-		r.responseCount++
+		r.errorCount++
 	} else {
 		r.logger.Debugw("received response", "response", logger.Proto(msg))
-		r.errorCount++
+		r.responseCount++
 	}
 	r.ClientMultiRPCHandler.Recv(msg, err)
 }

Original file line number	Diff line number	Diff line change
`@@ -156,12 +156,12 @@ func (r *multiRPCLoggerInterceptor) Send(ctx context.Context, req proto.Message,`
`156`	`156`	`}`
`157`	`157`
`158`	`158`	`func (r *multiRPCLoggerInterceptor) Recv(msg proto.Message, err error) {`
`159`		`- if err == nil {`
	`159`	`+ if err != nil {`
`160`	`160`	`r.logger.Warnw("received error", err)`
`161`		`- r.responseCount++`
	`161`	`+ r.errorCount++`
`162`	`162`	`} else {`
`163`	`163`	`r.logger.Debugw("received response", "response", logger.Proto(msg))`
`164`		`- r.errorCount++`
	`164`	`+ r.responseCount++`
`165`	`165`	`}`
`166`	`166`	`r.ClientMultiRPCHandler.Recv(msg, err)`
`167`	`167`	`}`