Mirroristas/kaspad
2
0
Fork 0
mirror of https://github.com/kaspanet/kaspad.git synced 2025-11-24 06:25:55 +00:00
Code Issues Packages Projects Releases Wiki Activity

Parallel miner

Browse Source
This commit is contained in:
Kaspa Profiler 2021-04-13 12:48:22 +03:00
parent 635b793e14
commit 28c5e50a87
1 changed files with 37 additions and 31 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
cmd/kaspaminer/mineloop.go
View File

@ -2,7 +2,9 @@ package main
import ( import (
nativeerrors "errors" nativeerrors "errors"
"fmt"
"math/rand" "math/rand"
"runtime"
"sync/atomic" "sync/atomic"
"time" "time"
@ -42,7 +44,9 @@ func mineLoop(client *minerClient, numberOfBlocks uint64, targetBlocksPerSecond
templatesLoop(client, miningAddr, errChan) templatesLoop(client, miningAddr, errChan)
}) })
spawn("blocksLoop", func() { for c := 0; c < (runtime.NumCPU()/2)+1; c++ {
c := c
spawn(fmt.Sprintf("blocksLoop %d", c), func() {
const windowSize = 10 const windowSize = 10
var expectedDurationForWindow time.Duration var expectedDurationForWindow time.Duration
var windowExpectedEndTime time.Time var windowExpectedEndTime time.Time
@ -64,9 +68,9 @@ func mineLoop(client *minerClient, numberOfBlocks uint64, targetBlocksPerSecond
deviation := windowExpectedEndTime.Sub(time.Now()) deviation := windowExpectedEndTime.Sub(time.Now())
if deviation > 0 { if deviation > 0 {
sleepTime = deviation / windowSize sleepTime = deviation / windowSize
log.Infof("Finished to mine %d blocks %s earlier than expected. Setting the miner "+ log.Infof("cpu: %d Finished to mine %d blocks %s earlier than expected. Setting the miner "+
"to sleep %s between blocks to compensate", "to sleep %s between blocks to compensate",
windowSize, deviation, sleepTime) c, windowSize, deviation, sleepTime)
} }
blockInWindowIndex = 0 blockInWindowIndex = 0
windowExpectedEndTime = time.Now().Add(expectedDurationForWindow) windowExpectedEndTime = time.Now().Add(expectedDurationForWindow)
@ -76,6 +80,8 @@ func mineLoop(client *minerClient, numberOfBlocks uint64, targetBlocksPerSecond
} }
}) })
}
spawn("handleFoundBlock", func() { spawn("handleFoundBlock", func() {
for i := uint64(0); numberOfBlocks == 0 || i < numberOfBlocks; i++ { for i := uint64(0); numberOfBlocks == 0 || i < numberOfBlocks; i++ {
block := <-foundBlockChan block := <-foundBlockChan