fix duration when err

bilibili · Mar 14, 2019 · ad50cd1 · ad50cd1
1 parent 18a75b3
commit ad50cd1
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/proxy/proto/pipe.go b/proxy/proto/pipe.go
@@ -176,9 +176,10 @@ func (mp *msgPipe) pipe() {
 			msg.WithError(err) // NOTE: maybe err is nil
 			msg.Done()
 			if prom.On {
-				prom.HandleTime(nc.Cluster(), nc.Addr(), msg.Request().CmdString(), int64(msg.RemoteDur()/time.Microsecond))
 				if err != nil {
 					prom.ErrIncr(nc.Cluster(), nc.Addr(), msg.Request().CmdString(), perr.Cause(err).Error())
+				} else {
+					prom.HandleTime(nc.Cluster(), nc.Addr(), msg.Request().CmdString(), int64(msg.RemoteDur()/time.Microsecond))
 				}
 			}
 		}