mirror of
https://github.com/xmrig/xmrig.git
synced 2025-02-02 11:16:37 +00:00
Pass all options to network strategies in constructor.
This commit is contained in:
parent
2e503f7f8c
commit
a2f747fb0c
7 changed files with 28 additions and 28 deletions
|
@ -55,14 +55,14 @@ Network::Network(const Options *options) :
|
||||||
const std::vector<Url*> &pools = options->pools();
|
const std::vector<Url*> &pools = options->pools();
|
||||||
|
|
||||||
if (pools.size() > 1) {
|
if (pools.size() > 1) {
|
||||||
m_strategy = new FailoverStrategy(pools, Platform::userAgent(), this);
|
m_strategy = new FailoverStrategy(pools, options->retryPause(), options->retries(), Platform::userAgent(), this);
|
||||||
}
|
}
|
||||||
else {
|
else {
|
||||||
m_strategy = new SinglePoolStrategy(pools.front(), Platform::userAgent(), this);
|
m_strategy = new SinglePoolStrategy(pools.front(), options->retryPause(), Platform::userAgent(), this);
|
||||||
}
|
}
|
||||||
|
|
||||||
if (m_options->donateLevel() > 0) {
|
if (m_options->donateLevel() > 0) {
|
||||||
m_donate = new DonateStrategy(Platform::userAgent(), this);
|
m_donate = new DonateStrategy(options->donateLevel(), options->pools().front()->user(), options->algo(), Platform::userAgent(), this);
|
||||||
}
|
}
|
||||||
|
|
||||||
m_timer.data = this;
|
m_timer.data = this;
|
||||||
|
|
|
@ -26,7 +26,6 @@
|
||||||
#include "net/Client.h"
|
#include "net/Client.h"
|
||||||
#include "net/Job.h"
|
#include "net/Job.h"
|
||||||
#include "net/strategies/DonateStrategy.h"
|
#include "net/strategies/DonateStrategy.h"
|
||||||
#include "Options.h"
|
|
||||||
#include "xmrig.h"
|
#include "xmrig.h"
|
||||||
|
|
||||||
|
|
||||||
|
@ -36,24 +35,23 @@ extern "C"
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
DonateStrategy::DonateStrategy(const char *agent, IStrategyListener *listener) :
|
DonateStrategy::DonateStrategy(int level, const char *user, int algo, const char *agent, IStrategyListener *listener) :
|
||||||
m_active(false),
|
m_active(false),
|
||||||
m_donateTime(Options::i()->donateLevel() * 60 * 1000),
|
m_donateTime(level * 60 * 1000),
|
||||||
m_idleTime((100 - Options::i()->donateLevel()) * 60 * 1000),
|
m_idleTime((100 - level) * 60 * 1000),
|
||||||
m_listener(listener)
|
m_listener(listener)
|
||||||
{
|
{
|
||||||
uint8_t hash[200];
|
uint8_t hash[200];
|
||||||
char userId[65] = { 0 };
|
char userId[65] = { 0 };
|
||||||
const char *user = Options::i()->pools().front()->user();
|
|
||||||
|
|
||||||
keccak(reinterpret_cast<const uint8_t *>(user), static_cast<int>(strlen(user)), hash, sizeof(hash));
|
keccak(reinterpret_cast<const uint8_t *>(user), static_cast<int>(strlen(user)), hash, sizeof(hash));
|
||||||
Job::toHex(hash, 32, userId);
|
Job::toHex(hash, 32, userId);
|
||||||
|
|
||||||
Url *url = new Url("thanks.xmrig.com", Options::i()->algo() == xmrig::ALGO_CRYPTONIGHT_LITE ? 5555 : 80, userId, nullptr, false, true);
|
Url *url = new Url("thanks.xmrig.com", algo == xmrig::ALGO_CRYPTONIGHT_LITE ? 5555 : 80, userId, nullptr, false, true);
|
||||||
|
|
||||||
m_client = new Client(-1, agent, this);
|
m_client = new Client(-1, agent, this);
|
||||||
m_client->setUrl(url);
|
m_client->setUrl(url);
|
||||||
m_client->setRetryPause(Options::i()->retryPause() * 1000);
|
m_client->setRetryPause(1000);
|
||||||
m_client->setQuiet(true);
|
m_client->setQuiet(true);
|
||||||
|
|
||||||
delete url;
|
delete url;
|
||||||
|
|
|
@ -40,7 +40,7 @@ class Url;
|
||||||
class DonateStrategy : public IStrategy, public IClientListener
|
class DonateStrategy : public IStrategy, public IClientListener
|
||||||
{
|
{
|
||||||
public:
|
public:
|
||||||
DonateStrategy(const char *agent, IStrategyListener *listener);
|
DonateStrategy(int level, const char *user, int algo, const char *agent, IStrategyListener *listener);
|
||||||
|
|
||||||
public:
|
public:
|
||||||
inline bool isActive() const override { return m_active; }
|
inline bool isActive() const override { return m_active; }
|
||||||
|
|
|
@ -4,8 +4,8 @@
|
||||||
* Copyright 2014 Lucas Jones <https://github.com/lucasjones>
|
* Copyright 2014 Lucas Jones <https://github.com/lucasjones>
|
||||||
* Copyright 2014-2016 Wolf9466 <https://github.com/OhGodAPet>
|
* Copyright 2014-2016 Wolf9466 <https://github.com/OhGodAPet>
|
||||||
* Copyright 2016 Jay D Dee <jayddee246@gmail.com>
|
* Copyright 2016 Jay D Dee <jayddee246@gmail.com>
|
||||||
* Copyright 2016-2017 XMRig <support@xmrig.com>
|
* Copyright 2017-2018 XMR-Stak <https://github.com/fireice-uk>, <https://github.com/psychocrypt>
|
||||||
*
|
* Copyright 2016-2018 XMRig <https://github.com/xmrig>, <support@xmrig.com>
|
||||||
*
|
*
|
||||||
* This program is free software: you can redistribute it and/or modify
|
* This program is free software: you can redistribute it and/or modify
|
||||||
* it under the terms of the GNU General Public License as published by
|
* it under the terms of the GNU General Public License as published by
|
||||||
|
@ -25,10 +25,11 @@
|
||||||
#include "interfaces/IStrategyListener.h"
|
#include "interfaces/IStrategyListener.h"
|
||||||
#include "net/Client.h"
|
#include "net/Client.h"
|
||||||
#include "net/strategies/FailoverStrategy.h"
|
#include "net/strategies/FailoverStrategy.h"
|
||||||
#include "Options.h"
|
|
||||||
|
|
||||||
|
|
||||||
FailoverStrategy::FailoverStrategy(const std::vector<Url*> &urls, const char *agent, IStrategyListener *listener) :
|
FailoverStrategy::FailoverStrategy(const std::vector<Url*> &urls, int retryPause, int retries, const char *agent, IStrategyListener *listener) :
|
||||||
|
m_retries(retries),
|
||||||
|
m_retryPause(retryPause),
|
||||||
m_active(-1),
|
m_active(-1),
|
||||||
m_index(0),
|
m_index(0),
|
||||||
m_listener(listener)
|
m_listener(listener)
|
||||||
|
@ -93,7 +94,7 @@ void FailoverStrategy::onClose(Client *client, int failures)
|
||||||
m_listener->onPause(this);
|
m_listener->onPause(this);
|
||||||
}
|
}
|
||||||
|
|
||||||
if (m_index == 0 && failures < Options::i()->retries()) {
|
if (m_index == 0 && failures < m_retries) {
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -142,7 +143,7 @@ void FailoverStrategy::add(const Url *url, const char *agent)
|
||||||
{
|
{
|
||||||
Client *client = new Client((int) m_pools.size(), agent, this);
|
Client *client = new Client((int) m_pools.size(), agent, this);
|
||||||
client->setUrl(url);
|
client->setUrl(url);
|
||||||
client->setRetryPause(Options::i()->retryPause() * 1000);
|
client->setRetryPause(m_retryPause * 1000);
|
||||||
|
|
||||||
m_pools.push_back(client);
|
m_pools.push_back(client);
|
||||||
}
|
}
|
||||||
|
|
|
@ -4,8 +4,8 @@
|
||||||
* Copyright 2014 Lucas Jones <https://github.com/lucasjones>
|
* Copyright 2014 Lucas Jones <https://github.com/lucasjones>
|
||||||
* Copyright 2014-2016 Wolf9466 <https://github.com/OhGodAPet>
|
* Copyright 2014-2016 Wolf9466 <https://github.com/OhGodAPet>
|
||||||
* Copyright 2016 Jay D Dee <jayddee246@gmail.com>
|
* Copyright 2016 Jay D Dee <jayddee246@gmail.com>
|
||||||
* Copyright 2016-2017 XMRig <support@xmrig.com>
|
* Copyright 2017-2018 XMR-Stak <https://github.com/fireice-uk>, <https://github.com/psychocrypt>
|
||||||
*
|
* Copyright 2016-2018 XMRig <https://github.com/xmrig>, <support@xmrig.com>
|
||||||
*
|
*
|
||||||
* This program is free software: you can redistribute it and/or modify
|
* This program is free software: you can redistribute it and/or modify
|
||||||
* it under the terms of the GNU General Public License as published by
|
* it under the terms of the GNU General Public License as published by
|
||||||
|
@ -40,7 +40,7 @@ class Url;
|
||||||
class FailoverStrategy : public IStrategy, public IClientListener
|
class FailoverStrategy : public IStrategy, public IClientListener
|
||||||
{
|
{
|
||||||
public:
|
public:
|
||||||
FailoverStrategy(const std::vector<Url*> &urls, const char *agent, IStrategyListener *listener);
|
FailoverStrategy(const std::vector<Url*> &urls, int retryPause, int retries, const char *agent, IStrategyListener *listener);
|
||||||
|
|
||||||
public:
|
public:
|
||||||
inline bool isActive() const override { return m_active >= 0; }
|
inline bool isActive() const override { return m_active >= 0; }
|
||||||
|
@ -60,6 +60,8 @@ protected:
|
||||||
private:
|
private:
|
||||||
void add(const Url *url, const char *agent);
|
void add(const Url *url, const char *agent);
|
||||||
|
|
||||||
|
const int m_retries;
|
||||||
|
const int m_retryPause;
|
||||||
int m_active;
|
int m_active;
|
||||||
int m_index;
|
int m_index;
|
||||||
IStrategyListener *m_listener;
|
IStrategyListener *m_listener;
|
||||||
|
|
|
@ -4,8 +4,8 @@
|
||||||
* Copyright 2014 Lucas Jones <https://github.com/lucasjones>
|
* Copyright 2014 Lucas Jones <https://github.com/lucasjones>
|
||||||
* Copyright 2014-2016 Wolf9466 <https://github.com/OhGodAPet>
|
* Copyright 2014-2016 Wolf9466 <https://github.com/OhGodAPet>
|
||||||
* Copyright 2016 Jay D Dee <jayddee246@gmail.com>
|
* Copyright 2016 Jay D Dee <jayddee246@gmail.com>
|
||||||
* Copyright 2016-2017 XMRig <support@xmrig.com>
|
* Copyright 2017-2018 XMR-Stak <https://github.com/fireice-uk>, <https://github.com/psychocrypt>
|
||||||
*
|
* Copyright 2016-2018 XMRig <https://github.com/xmrig>, <support@xmrig.com>
|
||||||
*
|
*
|
||||||
* This program is free software: you can redistribute it and/or modify
|
* This program is free software: you can redistribute it and/or modify
|
||||||
* it under the terms of the GNU General Public License as published by
|
* it under the terms of the GNU General Public License as published by
|
||||||
|
@ -25,16 +25,15 @@
|
||||||
#include "interfaces/IStrategyListener.h"
|
#include "interfaces/IStrategyListener.h"
|
||||||
#include "net/Client.h"
|
#include "net/Client.h"
|
||||||
#include "net/strategies/SinglePoolStrategy.h"
|
#include "net/strategies/SinglePoolStrategy.h"
|
||||||
#include "Options.h"
|
|
||||||
|
|
||||||
|
|
||||||
SinglePoolStrategy::SinglePoolStrategy(const Url *url, const char *agent, IStrategyListener *listener) :
|
SinglePoolStrategy::SinglePoolStrategy(const Url *url, int retryPause, const char *agent, IStrategyListener *listener) :
|
||||||
m_active(false),
|
m_active(false),
|
||||||
m_listener(listener)
|
m_listener(listener)
|
||||||
{
|
{
|
||||||
m_client = new Client(0, agent, this);
|
m_client = new Client(0, agent, this);
|
||||||
m_client->setUrl(url);
|
m_client->setUrl(url);
|
||||||
m_client->setRetryPause(Options::i()->retryPause() * 1000);
|
m_client->setRetryPause(retryPause * 1000);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
|
|
|
@ -4,8 +4,8 @@
|
||||||
* Copyright 2014 Lucas Jones <https://github.com/lucasjones>
|
* Copyright 2014 Lucas Jones <https://github.com/lucasjones>
|
||||||
* Copyright 2014-2016 Wolf9466 <https://github.com/OhGodAPet>
|
* Copyright 2014-2016 Wolf9466 <https://github.com/OhGodAPet>
|
||||||
* Copyright 2016 Jay D Dee <jayddee246@gmail.com>
|
* Copyright 2016 Jay D Dee <jayddee246@gmail.com>
|
||||||
* Copyright 2016-2017 XMRig <support@xmrig.com>
|
* Copyright 2017-2018 XMR-Stak <https://github.com/fireice-uk>, <https://github.com/psychocrypt>
|
||||||
*
|
* Copyright 2016-2018 XMRig <https://github.com/xmrig>, <support@xmrig.com>
|
||||||
*
|
*
|
||||||
* This program is free software: you can redistribute it and/or modify
|
* This program is free software: you can redistribute it and/or modify
|
||||||
* it under the terms of the GNU General Public License as published by
|
* it under the terms of the GNU General Public License as published by
|
||||||
|
@ -37,7 +37,7 @@ class Url;
|
||||||
class SinglePoolStrategy : public IStrategy, public IClientListener
|
class SinglePoolStrategy : public IStrategy, public IClientListener
|
||||||
{
|
{
|
||||||
public:
|
public:
|
||||||
SinglePoolStrategy(const Url *url, const char *agent, IStrategyListener *listener);
|
SinglePoolStrategy(const Url *url, int retryPause, const char *agent, IStrategyListener *listener);
|
||||||
|
|
||||||
public:
|
public:
|
||||||
inline bool isActive() const override { return m_active; }
|
inline bool isActive() const override { return m_active; }
|
||||||
|
|
Loading…
Reference in a new issue