server: Record MilPixelsProcessed on B

livepeer · May 24, 2021 · d6d50c2 · d6d50c2
1 parent f3ee006
commit d6d50c2
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/server/segment_rpc.go b/server/segment_rpc.go
@@ -528,6 +528,10 @@ func SubmitSegment(sess *BroadcastSession, seg *stream.HLSSegment, nonce uint64)
 		}
 
 		balUpdate.Debit.Mul(new(big.Rat).SetInt64(pixelCount), priceInfo)
+
+		if monitor.Enabled {
+			monitor.MilPixelsProcessed(float64(pixelCount) / 1000000.0)
+		}
 	}
 
 	// transcode succeeded; continue processing response