Skip to content

support multiple GPUs #8

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Open
aardvark3 wants to merge 11 commits into
base: master
Choose a base branch
from
Open

support multiple GPUs #8

Changes from all commits
Commits
Show all changes
11 commits
Select commit Hold shift + click to select a range
a8fa0b9
fix multi-GPU
aardvark3 Jan 8, 2022
fd9e327
fix
aardvark3 Jan 8, 2022
96f9545
fix
aardvark3 Jan 9, 2022
ea0a23b
update
aardvark3 Jan 9, 2022
38fe910
update
aardvark3 Jan 9, 2022
5656138
update
aardvark3 Jan 9, 2022
983ede9
update
aardvark3 Jan 9, 2022
499fc83
update
aardvark3 Jan 9, 2022
5691781
update
aardvark3 Jan 9, 2022
929849c
update
aardvark3 Jan 9, 2022
867108f
update
aardvark3 Jan 9, 2022
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
37 changes: 28 additions & 9 deletions src/Cuda/xpmclient.cpp
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -24,6 +24,7 @@
#include "prime.h"
#include <openssl/bn.h>
#include <openssl/sha.h>
#include <thread>

void _blkmk_bin2hex(char *out, void *data, size_t datasz) {
unsigned char *datac = (unsigned char *)data;
Expand Down Expand Up @@ -287,6 +288,7 @@ void PrimeMiner::Mining(GetBlockTemplateContext* gbp, SubmitContext* submit) {
cudaBuffer<uint32_t> primeBuf[maxHashPrimorial];
cudaBuffer<uint32_t> primeBuf2[maxHashPrimorial];

printf("-----+----------------------test print at line 291\n");
CUevent sieveEvent;
CUDA_SAFE_CALL(cuEventCreate(&sieveEvent, CU_EVENT_BLOCKING_SYNC));

Expand Down Expand Up @@ -700,7 +702,6 @@ void PrimeMiner::Mining(GetBlockTemplateContext* gbp, SubmitContext* submit) {
work.multiplier[0] = buffer[3];
std::reverse_copy(buffer+4, buffer+4+buffer[3], work.multiplier+1);
submit->submitBlock(workTemplate, work, dataId);

LOG_F(1, "GPU %d found share: %d-ch type %d", mID, chainlength, candi.type+1);
if(isblock)
LOG_F(1, "GPU %d found BLOCK!", mID);
Expand Down Expand Up @@ -815,6 +816,21 @@ void initCmdLineOptions(option *options)
options[clOptionLast] = {0, 0, 0, 0};
}

struct MineContext {
GetBlockTemplateContext *gbp;
SubmitContext *submit;
PrimeMiner* miner;
CUDADeviceInfo *device;
CUmodule *mod;
};

void* InvokeMining(void *arg)
{
MineContext *ctx = (MineContext*)arg;
ctx->miner->Initialize(ctx->device->context, ctx->device->device, *(ctx->mod));
ctx->miner->Mining(ctx->gbp, ctx->submit);
}

int main(int argc, char **argv) {
srand(time(0));
blkmk_sha256_impl = sha256;
Expand Down Expand Up @@ -885,8 +901,8 @@ int main(int argc, char **argv) {
exit(1);
}
printf("block sum is %d\n", gThreadsNum);
GetBlockTemplateContext* getblock = new GetBlockTemplateContext(0, gUrl, gUserName, gPassword, gWallet, 4, gThreadsNum, extraNonce);
getblock->run();
GetBlockTemplateContext getblock(0, gUrl, gUserName, gPassword, gWallet, 4, gThreadsNum, extraNonce);
getblock.run();
blktemplate_t *workTemplate = 0;
unsigned int dataId;
bool hasChanged;
Expand All @@ -896,8 +912,6 @@ int main(int argc, char **argv) {
//}
//printf("blocktemplate_rwrqwrqw %ld\n", (long int)workTemplate);
//printf("block height %d\n", workTemplate->height);

SubmitContext *submit = new SubmitContext(0, gUrl, gUserName, gPassword);

{
int np = sizeof(gPrimes)/sizeof(unsigned);
Expand All @@ -920,7 +934,7 @@ int main(int argc, char **argv) {
std::map<int,int> mDeviceMap;
std::map<int,int> mDeviceMapRev;

for (unsigned i = 0; i < devicesNum; i++) {
for (unsigned i = 0; i < 1; i++) {
char name[128];
CUDADeviceInfo info;
mDeviceMap[i] = gpus.size();
Expand Down Expand Up @@ -988,10 +1002,15 @@ int main(int argc, char **argv) {
}

unsigned int sievePerRound = 5;
MineContext *mineCtx = new MineContext[gpus.size()];
for(unsigned i = 0; i < gpus.size(); ++i) {
PrimeMiner* miner = new PrimeMiner(i, gpus.size(), sievePerRound, depth, clKernelLSize);
miner->Initialize(gpus[i].context, gpus[i].device, modules[i]);
miner->Mining(getblock, submit);
pthread_t thread;
mineCtx[i].gbp = &getblock;
mineCtx[i].submit = new SubmitContext(0, gUrl, gUserName, gPassword);
mineCtx[i].miner = new PrimeMiner(i, gpus.size(), sievePerRound, depth, clKernelLSize);
mineCtx[i].device = &gpus[i];
mineCtx[i].mod = &modules[i];
pthread_create(&thread, 0, InvokeMining, &mineCtx[i]);
}

return 0;
Expand Down