Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
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
17 changes: 9 additions & 8 deletions main/http_server/handler_system.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -92,6 +92,10 @@ esp_err_t GET_system_info(httpd_req_t *req)
char *fallbackStratumURL = Config::getStratumFallbackURL();
char *fallbackStratumUser= Config::getStratumFallbackUser();

char *sv2_auth = Config::getSV2AuthorityPubkey();
char *fb_sv2_auth = Config::getFallbackSV2AuthorityPubkey();


// static
doc["asicCount"] = board->getAsicCount();
doc["smallCoreCount"] = (board->getAsics()) ? board->getAsics()->getSmallCoreCount() : 0;
Expand Down Expand Up @@ -210,14 +214,8 @@ esp_err_t GET_system_info(httpd_req_t *req)
doc["fallbackStratumTLS"] = Config::isStratumFallbackTLS();
doc["stratumProtocol"] = Config::getStratumProtocol();
doc["fallbackStratumProtocol"] = Config::getFallbackStratumProtocol();
{
char *sv2_auth = Config::getSV2AuthorityPubkey();
doc["sv2AuthorityPubkey"] = sv2_auth ? sv2_auth : "";
safe_free(sv2_auth);
char *fb_sv2_auth = Config::getFallbackSV2AuthorityPubkey();
doc["fallbackSv2AuthorityPubkey"] = fb_sv2_auth ? fb_sv2_auth : "";
safe_free(fb_sv2_auth);
}
doc["sv2AuthorityPubkey"] = sv2_auth;
doc["fallbackSv2AuthorityPubkey"] = fb_sv2_auth;
doc["sv2ChannelType"] = Config::getSV2ChannelType();
doc["fallbackSv2ChannelType"] = Config::getFallbackSV2ChannelType();
doc["voltage"] = POWER_MANAGEMENT_MODULE.getVoltage();
Expand Down Expand Up @@ -264,6 +262,9 @@ esp_err_t GET_system_info(httpd_req_t *req)
free(fallbackStratumURL);
free(fallbackStratumUser);

free(sv2_auth);
free(fb_sv2_auth);

return ret;
}

Expand Down
3 changes: 3 additions & 0 deletions main/stratum/stratum_manager.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -302,6 +302,9 @@ void StratumManager::loadSettings(bool reconnect)
m_stratumTasks[i]->triggerReconnect();
}

// reset session stats for this pool
resetPoolSessionStats(i);

// reset ping stats
if (m_pingTasks[i]) {
m_pingTasks[i]->reset();
Expand Down
4 changes: 4 additions & 0 deletions main/stratum/stratum_manager.h
Original file line number Diff line number Diff line change
Expand Up @@ -98,6 +98,10 @@ class StratumManager {

virtual int getPoolMode() = 0;

// reset stats for a single pool (called from loadSettings with mutex held)
virtual void resetPoolSessionStats(int pool) {
}

public:
virtual void resetSessionStats() {
PThreadGuard lock(m_mutex);
Expand Down
16 changes: 10 additions & 6 deletions main/stratum/stratum_manager_dual_pool.h
Original file line number Diff line number Diff line change
Expand Up @@ -97,15 +97,19 @@ class StratumManagerDualPool : public StratumManager {
return (m_balance >= 50) ? m_networkDifficulty[0] : m_networkDifficulty[1];
}

virtual void resetPoolSessionStats(int pool) override {
StratumManager::resetPoolSessionStats(pool);
m_accepted[pool] = 0;
m_rejected[pool] = 0;
m_bestSessionDiff[pool] = 0;
suffixString(std::max(m_bestSessionDiff[0], m_bestSessionDiff[1]), m_bestSessionDiffString, DIFF_STRING_SIZE, 0);
if (m_stratumTasks[pool]) m_stratumTasks[pool]->m_poolErrors = 0;
}

virtual void resetSessionStats() override {
PThreadGuard lock(m_mutex);
m_foundBlocks = 0;
for (int i = 0; i < 2; i++) {
m_accepted[i] = 0;
m_rejected[i] = 0;
m_bestSessionDiff[i] = 0;
suffixString(0, m_bestSessionDiffString, DIFF_STRING_SIZE, 0);
if (m_stratumTasks[i]) m_stratumTasks[i]->m_poolErrors = 0;
resetPoolSessionStats(i);
}
}

Expand Down
13 changes: 9 additions & 4 deletions main/stratum/stratum_manager_fallback.h
Original file line number Diff line number Diff line change
Expand Up @@ -80,15 +80,20 @@ class StratumManagerFallback : public StratumManager {
return m_networkDifficulty;
}

virtual void resetSessionStats() override {
PThreadGuard lock(m_mutex);
m_foundBlocks = 0;
virtual void resetPoolSessionStats(int pool) override {
StratumManager::resetPoolSessionStats(pool);
// fallback mode shares a single counter for both pools
m_accepted = 0;
m_rejected = 0;
m_bestSessionDiff = 0;
suffixString(0, m_bestSessionDiffString, DIFF_STRING_SIZE, 0);
if (m_stratumTasks[pool]) m_stratumTasks[pool]->m_poolErrors = 0;
}

virtual void resetSessionStats() override {
PThreadGuard lock(m_mutex);
for (int i = 0; i < 2; i++) {
if (m_stratumTasks[i]) m_stratumTasks[i]->m_poolErrors = 0;
resetPoolSessionStats(i);
}
}

Expand Down
2 changes: 1 addition & 1 deletion main/system.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -290,7 +290,7 @@ void System::task() {
uint32_t foundBlocks = STRATUM_MANAGER->getFoundBlocks();

// trigger the overlay only once when block is found
if (foundBlocks != lastFoundBlocks && foundBlocks) {
if (foundBlocks > lastFoundBlocks) {
m_display->showFoundBlockOverlay();
}
lastFoundBlocks = foundBlocks;
Expand Down
Loading