register labels

Author: philipsu522

internal/consensus/metrics.gen.go

@@ -85,9 +85,9 @@ type Metrics struct {
 	// was relevant to the block the node is trying to gather or not.
 	BlockGossipPartsReceived metrics.Counter `metrics_labels:"matches_current"`
 
-	ProposalBlockCreated metrics.Counter `metrics_labels:"success"`
-	ProposalTxsCount     metrics.Gauge
-	MissingTxsCount      metrics.Gauge
+	ProposalBlockCreatedOnPropose metrics.Counter `metrics_labels:"success"`
+	ProposalTxs                   metrics.Gauge
+	ProposalMissingTxs            metrics.Gauge
 
 	// QuroumPrevoteMessageDelay is the interval in seconds between the proposal
 	// timestamp and the timestamp of the earliest prevote that achieved a quorum

internal/consensus/metrics.go

@@ -1196,7 +1196,7 @@ func (r *Reactor) handleDataMessage(ctx context.Context, envelope *p2p.Envelope,
 		}
 	case *tmcons.TxRequest:
 		trMsg := msgI.(*TxRequestMessage)
-		logger.Info("PSULOG: Received request for Txs", "txKeys", trMsg.TxKeys)
+		//logger.Info("PSULOG: Received request for Txs", "txKeys", trMsg.TxKeys)
 		var txKeys []types.TxKey
 		for _, txKey := range trMsg.TxKeys {
 			txKeys = append(txKeys, *txKey)

internal/consensus/reactor.go

@@ -1030,7 +1030,7 @@ func (cs *State) handleMsg(ctx context.Context, mi msgInfo, fsyncUponCompletion
 		err = cs.setProposal(msg.Proposal, mi.ReceiveTime)
 		if cs.config.GossipTransactionHashOnly && !cs.isProposer(cs.privValidatorPubKey.Address()) {
 			created := cs.tryCreateProposalBlock(msg.Proposal.Height, msg.Proposal.Round, msg.Proposal.Header, msg.Proposal.LastCommit, msg.Proposal.Evidence, msg.Proposal.ProposerAddress)
-			cs.metrics.ProposalBlockCreated.With("success", strconv.FormatBool(created)).Add(1)
+			cs.metrics.ProposalBlockCreatedOnPropose.With("success", strconv.FormatBool(created)).Add(1)
 			if created {
 				if fsyncUponCompletion {
 					if err := cs.wal.FlushAndSync(); err != nil { // fsync
@@ -2473,11 +2473,11 @@ func (cs *State) tryCreateProposalBlock(height int64, round int32, header types.
 		return false
 	}
 	txKeys := cs.Proposal.TxKeys
-	cs.metrics.ProposalTxsCount.Set(float64(len(cs.Proposal.TxKeys)))
+	cs.metrics.ProposalTxs.Set(float64(len(cs.Proposal.TxKeys)))
 	missingTxKeys := cs.blockExec.GetMissingTxs(txKeys)
 	if len(missingTxKeys) != 0 {
 		//cs.logger.Info("PSULOG - cannot create block, either proposal is missing or we have missing keys", "proposal", cs.Proposal)
-		cs.metrics.MissingTxsCount.Set(float64(len(cs.blockExec.GetMissingTxs(cs.Proposal.TxKeys))))
+		cs.metrics.ProposalMissingTxs.Set(float64(len(cs.blockExec.GetMissingTxs(cs.Proposal.TxKeys))))
 		return false
 	} else {
 		//block := types.MakeBlock(height, cs.blockExec.GetTxsForKeys(txKeys), lastCommit, evidence, false)