mirror of
https://github.com/kaspanet/kaspad.git
synced 2025-05-29 18:26:41 +00:00
9d5d1b02dc
* [NOD-1538] Implement a simple orphan pool. * [NOD-1538] Connect the orphan pool to the appropriate flows. * [NOD-1538] Make UnorphanBlocks actually unorphan blocks. * [NOD-1538] Fix logs. * [NOD-1538] Make unorphaned blocks call LogBlock. * [NOD-1538] Fix a log and some bad names. * [NOD-1538] Don't return an error from LogBlock. * [NOD-1538] Pass a pointer to hash in findChildOrphansOfBlock. * [NOD-1538] Extract addChildOrphansToProcessQueue to a separate function.
59 lines
1.4 KiB
Go
59 lines
1.4 KiB
Go
// Copyright (c) 2015-2017 The btcsuite developers
|
|
// Use of this source code is governed by an ISC
|
|
// license that can be found in the LICENSE file.
|
|
|
|
package blocklogger
|
|
|
|
import (
|
|
"sync"
|
|
"time"
|
|
|
|
"github.com/kaspanet/kaspad/domain/consensus/model/externalapi"
|
|
"github.com/kaspanet/kaspad/util/mstime"
|
|
)
|
|
|
|
var (
|
|
receivedLogBlocks int64
|
|
receivedLogTx int64
|
|
lastBlockLogTime = mstime.Now()
|
|
mtx sync.Mutex
|
|
)
|
|
|
|
// LogBlock logs a new block blue score as an information message
|
|
// to show progress to the user. In order to prevent spam, it limits logging to
|
|
// one message every 10 seconds with duration and totals included.
|
|
func LogBlock(block *externalapi.DomainBlock) {
|
|
mtx.Lock()
|
|
defer mtx.Unlock()
|
|
|
|
receivedLogBlocks++
|
|
receivedLogTx += int64(len(block.Transactions))
|
|
|
|
now := mstime.Now()
|
|
duration := now.Sub(lastBlockLogTime)
|
|
if duration < time.Second*10 {
|
|
return
|
|
}
|
|
|
|
// Truncate the duration to 10s of milliseconds.
|
|
tDuration := duration.Round(10 * time.Millisecond)
|
|
|
|
// Log information about new block blue score.
|
|
blockStr := "blocks"
|
|
if receivedLogBlocks == 1 {
|
|
blockStr = "block"
|
|
}
|
|
txStr := "transactions"
|
|
if receivedLogTx == 1 {
|
|
txStr = "transaction"
|
|
}
|
|
|
|
log.Infof("Processed %d %s in the last %s (%d %s, %s)",
|
|
receivedLogBlocks, blockStr, tDuration, receivedLogTx,
|
|
txStr, mstime.UnixMilliseconds(block.Header.TimeInMilliseconds))
|
|
|
|
receivedLogBlocks = 0
|
|
receivedLogTx = 0
|
|
lastBlockLogTime = now
|
|
}
|