Fixed data race

SChernykh · Dec 17, 2024 · dd2812f · dd2812f
1 parent 92dfde8
commit dd2812f
Showing 1 changed file with 4 additions and 5 deletions.
diff --git a/src/stratum_server.cpp b/src/stratum_server.cpp
@@ -888,7 +888,10 @@ void StratumServer::update_hashrate_data(uint64_t hashes, uint64_t timestamp)
 
 	WriteLock lock(m_hashrateDataLock);
 
-	m_cumulativeHashes += hashes;
+	if (hashes) {
+		m_cumulativeHashes += hashes;
+		++m_totalStratumShares;
+	}
 
 	HashrateData* data = m_hashrateData;
 	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);
 	}
 
-	if (share->m_result == SubmittedShare::Result::OK) {
-		++server->m_totalStratumShares;
-	}
-
 	if (share->m_allocated) {
 		auto it = std::find(server->m_pendingShareChecks.begin(), server->m_pendingShareChecks.end(), share);
 		if (it != server->m_pendingShareChecks.end()) {