diff --git a/blockchain/pool.go b/blockchain/pool.go index a4cbe6d24..e748252ae 100644 --- a/blockchain/pool.go +++ b/blockchain/pool.go @@ -108,7 +108,7 @@ RUN_LOOP: } } -func (pool *BlockPool) GetStatus() (int, int32, int32) { +func (pool *BlockPool) GetStatus() (height int, numPending int32, numUnssigned int32) { pool.requestsMtx.Lock() // Lock defer pool.requestsMtx.Unlock() diff --git a/blockchain/reactor.go b/blockchain/reactor.go index 754f4644a..8ed185af8 100644 --- a/blockchain/reactor.go +++ b/blockchain/reactor.go @@ -199,7 +199,7 @@ FOR_LOOP: // ask for status updates go bcR.BroadcastStatusRequest() case _ = <-switchToConsensusTicker.C: - height, numUnassigned, numPending := bcR.pool.GetStatus() + height, numPending, numUnassigned := bcR.pool.GetStatus() outbound, inbound, _ := bcR.sw.NumPeers() log.Debug("Consensus ticker", "numUnassigned", numUnassigned, "numPending", numPending, "total", len(bcR.pool.requests), "outbound", outbound, "inbound", inbound)