tiamak/p2pool-salvium
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Fixed data race

Browse Source
This commit is contained in:
SChernykh
2024-12-17 16:19:10 +01:00
parent 92dfde8a3e
commit dd2812f1e5
1 changed files with 4 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/stratum_server.cpp
+4 -5
View File
@@ -888,7 +888,10 @@ void StratumServer::update_hashrate_data(uint64_t hashes, uint64_t timestamp)
WriteLock lock(m_hashrateDataLock); WriteLock lock(m_hashrateDataLock);
m_cumulativeHashes += hashes; if (hashes) {
m_cumulativeHashes += hashes;
++m_totalStratumShares;
}
HashrateData* data = m_hashrateData; HashrateData* data = m_hashrateData;
HashrateData& head = data[m_hashrateDataHead]; HashrateData& head = data[m_hashrateDataHead];
@@ -1094,10 +1097,6 @@ void StratumServer::on_after_share_found(uv_work_t* req, int /*status*/)
server->ban(share->m_clientIPv6, share->m_clientAddr, DEFAULT_BAN_TIME); server->ban(share->m_clientIPv6, share->m_clientAddr, DEFAULT_BAN_TIME);
} }
if (share->m_result == SubmittedShare::Result::OK) {
++server->m_totalStratumShares;
}
if (share->m_allocated) { if (share->m_allocated) {
auto it = std::find(server->m_pendingShareChecks.begin(), server->m_pendingShareChecks.end(), share); auto it = std::find(server->m_pendingShareChecks.begin(), server->m_pendingShareChecks.end(), share);
if (it != server->m_pendingShareChecks.end()) { if (it != server->m_pendingShareChecks.end()) {