reduce peer state log, do logging in ticker (#1255)

* reduce peer state log, do logging in ticker

* gofmt

consensus/vbft/state_mgmt.go

@@ -19,6 +19,7 @@
 package vbft
 
 import (
+	"fmt"
 	"math"
 	"time"
 
@@ -77,6 +78,10 @@ type PeerState struct {
 	connected         bool
 }
 
+func (peer *PeerState) String() string {
+	return fmt.Sprintf("{%d: (%d, %d)},", peer.peerIdx, peer.chainConfigView, peer.committedBlockNum)
+}
+
 type StateMgr struct {
 	server           *Server
 	syncReadyTimeout time.Duration
@@ -164,6 +169,8 @@ func (self *StateMgr) run() {
 				}
 
 			case LiveTick:
+				log.Infof("server %d peer update, current blk: %d, state: %d. received peer states: %v",
+					self.server.Index, self.server.GetCurrentBlockNo(), self.currentState, self.peers)
 				self.onLiveTick(evt)
 			}
 
@@ -181,8 +188,8 @@ func (self *StateMgr) onPeerUpdate(peerState *PeerState) {
 		newPeer = true
 	}
 
-	log.Infof("server %d peer update, current blk %d, state %d, from peer %d, committed %d",
-		self.server.Index, self.server.GetCurrentBlockNo(), self.currentState, peerState.peerIdx, peerState.committedBlockNum)
+	log.Debugf("server %d peer update, current blk %d, state %d, received peer state: %v",
+		self.server.Index, self.server.GetCurrentBlockNo(), self.currentState, peerState)
 
 	// update peer state
 	self.peers[peerIdx] = peerState

consensus/vbft/state_mgmt_test.go

@@ -232,3 +232,16 @@ func TestStateMgr_getConsensusedCommittedBlockNum(t *testing.T) {
 	maxcomit, flag := statemgr.getConsensusedCommittedBlockNum()
 	t.Logf("TestgetConsensusedCommittedBlockNum maxcommitted:%v, consensused:%v", maxcomit, flag)
 }
+
+func TestPeerState_String(t *testing.T) {
+	peers := make(map[uint32]*PeerState)
+	for i := uint32(0); i < 10; i++ {
+		peers[i] = &PeerState{
+			peerIdx:           i,
+			chainConfigView:   i,
+			committedBlockNum: i,
+		}
+	}
+
+	t.Logf("received peer states: %v", peers)
+}