const some stuff
This commit is contained in:
@@ -1163,10 +1163,10 @@ void static RandomXMiner()
|
|||||||
rxdebug("%s: initializing dataset with %d threads\n", initThreadCount);
|
rxdebug("%s: initializing dataset with %d threads\n", initThreadCount);
|
||||||
std::vector<std::thread> threads;
|
std::vector<std::thread> threads;
|
||||||
uint32_t startItem = 0;
|
uint32_t startItem = 0;
|
||||||
auto perThread = datasetItemCount / initThreadCount;
|
const auto perThread = datasetItemCount / initThreadCount;
|
||||||
auto remainder = datasetItemCount % initThreadCount;
|
const auto remainder = datasetItemCount % initThreadCount;
|
||||||
for (int i = 0; i < initThreadCount; ++i) {
|
for (int i = 0; i < initThreadCount; ++i) {
|
||||||
auto count = perThread + (i == initThreadCount - 1 ? remainder : 0);
|
const auto count = perThread + (i == initThreadCount - 1 ? remainder : 0);
|
||||||
threads.push_back(std::thread(&randomx_init_dataset, randomxDataset, randomxCache, startItem, count));
|
threads.push_back(std::thread(&randomx_init_dataset, randomxDataset, randomxCache, startItem, count));
|
||||||
startItem += count;
|
startItem += count;
|
||||||
}
|
}
|
||||||
@@ -1399,10 +1399,8 @@ void static RandomXMiner()
|
|||||||
rxdebug("%s: going to destroy rx VM\n");
|
rxdebug("%s: going to destroy rx VM\n");
|
||||||
randomx_destroy_vm(myVM);
|
randomx_destroy_vm(myVM);
|
||||||
rxdebug("%s: destroyed VM\n");
|
rxdebug("%s: destroyed VM\n");
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
} catch (const boost::thread_interrupted&) {
|
} catch (const boost::thread_interrupted&) {
|
||||||
miningTimer.stop();
|
miningTimer.stop();
|
||||||
c.disconnect();
|
c.disconnect();
|
||||||
|
|||||||
Reference in New Issue
Block a user