Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Add connection retry time option #30

Open
wants to merge 2 commits into
base: main
Choose a base branch
from
Open

Add connection retry time option #30

Changes from all commits
Commits
Show all changes
2 commits
Select commit Hold shift + click to select a range
0d16f95
Add connection retry pause option
51FuR4nk Mar 2, 2022
3d1ceef
fix-type-conversion
51FuR4nk Mar 2, 2022
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
20 changes: 15 additions & 5 deletions cmd/dero-miner/miner.go
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -59,6 +59,7 @@ var iterations int = 100
var max_pow_size int = 819200 //astrobwt.MAX_LENGTH
var wallet_address string
var daemon_rpc_address string
var connection_retry_pause int = 10

var counter uint64
var hash_rate uint64
Expand All @@ -75,7 +76,7 @@ ONE CPU, ONE VOTE.
http://wiki.dero.io

Usage:
dero-miner --wallet-address=<wallet_address> [--daemon-rpc-address=<127.0.0.1:10102>] [--mining-threads=<threads>] [--testnet] [--debug]
dero-miner --wallet-address=<wallet_address> [--daemon-rpc-address=<127.0.0.1:10102>] [--mining-threads=<threads>] [--retry-pause=<10>] [--testnet] [--debug]
dero-miner --bench [--max-pow-size=1120]
dero-miner -h | --help
dero-miner --version
Expand All @@ -85,8 +86,9 @@ Options:
--version Show version.
--bench Run benchmark mode.
--daemon-rpc-address=<127.0.0.1:10102> Miner will connect to daemon RPC on this port.
--wallet-address=<wallet_address> This address is rewarded when a block is mined sucessfully.
--mining-threads=<threads> Number of CPU threads for mining [default: ` + fmt.Sprintf("%d", runtime.GOMAXPROCS(0)) + `]
--wallet-address=<wallet_address> This address is rewarded when a block is mined sucessfully.
--mining-threads=<threads> Number of CPU threads for mining [default: ` + fmt.Sprintf("%d", runtime.GOMAXPROCS(0)) + `]
--retry-pause=10 Seconds to pause between connection retries.

Example Mainnet: ./dero-miner-linux-amd64 --wallet-address dero1qy0ehnqjpr0wxqnknyc66du2fsxyktppkr8m8e6jvplp954klfjz2qqhmy4zf --daemon-rpc-address=http://explorer.dero.io:10102
Example Testnet: ./dero-miner-linux-amd64 --wallet-address deto1qy0ehnqjpr0wxqnknyc66du2fsxyktppkr8m8e6jvplp954klfjz2qqdzcd8p --daemon-rpc-address=http://127.0.0.1:40402
Expand Down Expand Up @@ -176,6 +178,14 @@ func main() {
}
}

if globals.Arguments["--retry-pause"] != nil {
if s, err := strconv.Atoi(globals.Arguments["--retry-pause"].(string)); err == nil {
connection_retry_pause = s
} else {
logger.Error(err, "Retry pause argument cannot be parsed.")
}
}

if globals.Arguments["--bench"].(bool) {

var wg sync.WaitGroup
Expand Down Expand Up @@ -408,8 +418,8 @@ func getwork(wallet_address string) {
connection, _, err = websocket.DefaultDialer.Dial(u.String(), nil)
if err != nil {
logger.Error(err, "Error connecting to server", "server adress", daemon_rpc_address)
logger.Info("Will try in 10 secs", "server adress", daemon_rpc_address)
time.Sleep(10 * time.Second)
logger.Info("Will try in " + strconv.Itoa(connection_retry_pause) + " secs", "server adress", daemon_rpc_address)
time.Sleep(time.Duration(connection_retry_pause) * time.Second)

continue
}
Expand Down