enable metrics

consensus/metrics.go

@@ -334,18 +334,17 @@ func (m *Metrics) MarkStep(s cstypes.RoundStepType) {
 }
 
 type JSONMetrics struct {
-	dir                  string
-	interval             int
-	StartTime            time.Time
-	EndTime              time.Time
-	Blocks               uint64
-	Rounds               uint64
-	SentConsensusBytes   uint64
-	SentCompactBlocks    uint64
-	SentCompactBytes     uint64
-	CompactBlockFailures uint64
-	SentBlockParts       uint64
-	SentBlockPartsBytes  uint64
+	dir                   string
+	interval              int
+	StartTime             time.Time
+	EndTime               time.Time
+	Blocks                uint64
+	Rounds                uint64
+	SentCompactBlocks     uint64
+	CompactBlockFailures  uint64
+	SentBlockParts        uint64
+	ReceivedBlockParts    uint64
+	ReceivedCompactBlocks uint64
 }
 
 func NewJSONMetrics(dir string) *JSONMetrics {
@@ -371,10 +370,9 @@ func (m *JSONMetrics) Save() {
 func (m *JSONMetrics) reset() {
 	m.Blocks = 0
 	m.Rounds = 0
-	m.SentConsensusBytes = 0
 	m.SentBlockParts = 0
-	m.SentBlockPartsBytes = 0
 	m.SentCompactBlocks = 0
-	m.SentCompactBytes = 0
 	m.CompactBlockFailures = 0
+	m.ReceivedBlockParts = 0
+	m.ReceivedCompactBlocks = 0
 }

consensus/reactor.go

@@ -694,6 +694,7 @@ OUTER_LOOP:
 					},
 				}, logger) {
 					ps.SetHasBlock(prs.Height, prs.Round)
+					conR.conS.jsonMetrics.SentCompactBlocks++
 				}
 				continue OUTER_LOOP
 			}
@@ -840,6 +841,7 @@ func (conR *Reactor) gossipDataForCatchup(logger log.Logger, rs *cstypes.RoundSt
 				string(peer.ID()),
 				schema.Upload,
 			)
+			conR.conS.jsonMetrics.SentBlockParts++
 		} else {
 			logger.Debug("Sending block part for catchup failed")
 			// sleep to avoid retrying too fast

consensus/state.go

@@ -1801,7 +1801,11 @@ func (cs *State) finalizeCommit(height int64) {
 	// NewHeightStep!
 	cs.updateToState(stateCopy)
 
-	cs.jsonMetrics.Save()
+	cs.jsonMetrics.Blocks++
+	// Save every 20 blocks
+	if cs.Height%20 == 0 {
+		cs.jsonMetrics.Save()
+	}
 
 	fail.Fail() // XXX
 
@@ -2003,6 +2007,7 @@ func (cs *State) addCompactBlock(msg *CompactBlockMessage, peerID p2p.ID) error
 
 	blockHash := cs.Proposal.BlockID.Hash
 	timeout := cs.config.Propose(cs.Round)
+	cs.jsonMetrics.ReceivedCompactBlocks++
 
 	// Yield the lock while we fetch the transactions from the mempool so that votes
 	// and other operations can be processed.
@@ -2098,6 +2103,7 @@ func (cs *State) addProposalBlockPart(msg *BlockPartMessage, peerID p2p.ID) (add
 	}
 
 	cs.metrics.BlockGossipPartsReceived.With("matches_current", "true").Add(1)
+	cs.jsonMetrics.ReceivedBlockParts++
 
 	if cs.ProposalBlockParts.ByteSize() > cs.state.ConsensusParams.Block.MaxBytes {
 		return added, fmt.Errorf("total size of proposal block parts exceeds maximum block bytes (%d > %d)",

mempool/cat/pool.go

@@ -559,7 +559,10 @@ func (txmp *TxPool) Update(
 			txmp.notifyTxsAvailable()
 		}
 	}
-	txmp.jsonMetrics.Save()
+	// save every 20 blocks
+	if blockHeight%20 == 0 {
+		txmp.jsonMetrics.Save()
+	}
 	return nil
 }