Added SetMinerPreference private miner API

core/core.go

@@ -1165,6 +1165,10 @@ func (c *Core) SetLockupByte(lockupByte uint8) {
 	c.sl.miner.worker.SetLockupByte(lockupByte)
 }
 
+func (c *Core) SetMinerPreference(minerPreference float64) {
+	c.sl.miner.worker.SetMinerPreference(minerPreference)
+}
+
 // SubscribePendingLogs starts delivering logs from pending transactions
 // to the given channel.
 func (c *Core) SubscribePendingLogs(ch chan<- []*types.Log) event.Subscription {

core/worker.go

@@ -161,6 +161,7 @@ type worker struct {
 	primaryCoinbase   common.Address
 	secondaryCoinbase common.Address
 	coinbaseLockup    uint8
+	minerPreference   float64
 	extra             []byte
 
 	workerDb ethdb.Database
@@ -236,6 +237,7 @@ func newWorker(config *Config, chainConfig *params.ChainConfig, db ethdb.Databas
 		fillTransactionsRollingAverage: &RollingAverage{windowSize: 100},
 		logger:                         logger,
 		coinbaseLockup:                 config.CoinbaseLockup,
+		minerPreference:                config.MinerPreference,
 	}
 	if worker.coinbaseLockup > uint8(len(params.LockupByteToBlockDepth))-1 {
 		logger.Errorf("Invalid coinbase lockup value %d, using default value %d", worker.coinbaseLockup, params.DefaultCoinbaseLockup)
@@ -286,7 +288,7 @@ func (w *worker) pickCoinbases() {
 	defer w.mu.Unlock()
 
 	// Use the MinerPreference to bias the decision
-	if rand.Float64() > w.config.MinerPreference {
+	if rand.Float64() > w.minerPreference {
 		// if MinerPreference < 0.5, bias is towards Quai
 		w.primaryCoinbase = w.quaiCoinbase
 		w.secondaryCoinbase = w.qiCoinbase
@@ -325,6 +327,18 @@ func (w *worker) GetSecondaryCoinbase() common.Address {
 	return w.secondaryCoinbase
 }
 
+func (w *worker) SetMinerPreference(preference float64) {
+	w.mu.Lock()
+	defer w.mu.Unlock()
+	w.minerPreference = preference
+}
+
+func (w *worker) GetMinerPreference() float64 {
+	w.mu.RLock()
+	defer w.mu.RUnlock()
+	return w.minerPreference
+}
+
 func (w *worker) GetLockupByte() uint8 {
 	w.mu.RLock()
 	defer w.mu.RUnlock()

quai/api.go

@@ -24,6 +24,7 @@ import (
 	"io"
 	"math/big"
 	"os"
+	"strconv"
 	"strings"
 	"time"
 
@@ -126,6 +127,18 @@ func (api *PrivateMinerAPI) SetLockupByte(lockupByte hexutil.Uint64) (bool, erro
 	return true, nil
 }
 
+func (api *PrivateMinerAPI) SetMinerPreference(minerPreference string) (bool, error) {
+	preferenceFloat, err := strconv.ParseFloat(minerPreference, 64)
+	if err != nil {
+		return false, err
+	}
+	if preferenceFloat < 0 || preferenceFloat > 1 {
+		return false, errors.New("miner preference must be between 0 and 1")
+	}
+	api.e.Core().SetMinerPreference(preferenceFloat)
+	return true, nil
+}
+
 // SetRecommitInterval updates the interval for miner sealing work recommitting.
 func (api *PrivateMinerAPI) SetRecommitInterval(interval int) {
 	api.e.Core().SetRecommitInterval(time.Duration(interval) * time.Millisecond)