|
|
|
@ -13,13 +13,13 @@ using v8::Number;
|
|
|
|
|
|
|
|
|
|
static const uint64_t MAX_SAFE_INTEGER = 9007199254740991ULL;
|
|
|
|
|
|
|
|
|
|
class PowWorker : public NanAsyncWorker {
|
|
|
|
|
class PowWorker : public Nan::AsyncWorker {
|
|
|
|
|
public:
|
|
|
|
|
PowWorker(NanCallback* callback,
|
|
|
|
|
PowWorker(Nan::Callback* callback,
|
|
|
|
|
size_t pool_size,
|
|
|
|
|
uint64_t target,
|
|
|
|
|
uint8_t* initial_hash)
|
|
|
|
|
: NanAsyncWorker(callback),
|
|
|
|
|
: Nan::AsyncWorker(callback),
|
|
|
|
|
pool_size(pool_size),
|
|
|
|
|
target(target),
|
|
|
|
|
initial_hash(initial_hash) {}
|
|
|
|
@ -40,17 +40,16 @@ class PowWorker : public NanAsyncWorker {
|
|
|
|
|
// this function will be run inside the main event loop
|
|
|
|
|
// so it is safe to use V8 again
|
|
|
|
|
void HandleOKCallback () {
|
|
|
|
|
NanScope();
|
|
|
|
|
if (error) {
|
|
|
|
|
Local<Value> argv[1];
|
|
|
|
|
if (error == -1) {
|
|
|
|
|
argv[0] = NanError("Max safe integer overflow");
|
|
|
|
|
argv[0] = Nan::Error("Max safe integer overflow");
|
|
|
|
|
} else {
|
|
|
|
|
argv[0] = NanError("Internal error");
|
|
|
|
|
argv[0] = Nan::Error("Internal error");
|
|
|
|
|
}
|
|
|
|
|
callback->Call(1, argv);
|
|
|
|
|
} else {
|
|
|
|
|
Local<Value> argv[] = {NanNull(), NanNew<Number>(nonce)};
|
|
|
|
|
Local<Value> argv[] = {Nan::Null(), Nan::New<Number>(nonce)};
|
|
|
|
|
callback->Call(2, argv);
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
@ -64,39 +63,35 @@ class PowWorker : public NanAsyncWorker {
|
|
|
|
|
};
|
|
|
|
|
|
|
|
|
|
NAN_METHOD(PowAsync) {
|
|
|
|
|
NanScope();
|
|
|
|
|
|
|
|
|
|
if (args.Length() != 4 ||
|
|
|
|
|
!args[0]->IsNumber() || // pool_size
|
|
|
|
|
!args[1]->IsNumber() || // target
|
|
|
|
|
!node::Buffer::HasInstance(args[2]) || // initial_hash
|
|
|
|
|
!args[3]->IsFunction()) { // cb
|
|
|
|
|
return NanThrowError("Bad input");
|
|
|
|
|
if (info.Length() != 4 ||
|
|
|
|
|
!info[0]->IsNumber() || // pool_size
|
|
|
|
|
!info[1]->IsNumber() || // target
|
|
|
|
|
!node::Buffer::HasInstance(info[2]) || // initial_hash
|
|
|
|
|
!info[3]->IsFunction()) { // cb
|
|
|
|
|
return Nan::ThrowError("Bad input");
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
size_t pool_size = args[0]->Uint32Value();
|
|
|
|
|
uint64_t target = args[1]->IntegerValue();
|
|
|
|
|
char* buf = node::Buffer::Data(args[2]);
|
|
|
|
|
size_t length = node::Buffer::Length(args[2]);
|
|
|
|
|
size_t pool_size = info[0]->Uint32Value();
|
|
|
|
|
uint64_t target = info[1]->IntegerValue();
|
|
|
|
|
char* buf = node::Buffer::Data(info[2]);
|
|
|
|
|
size_t length = node::Buffer::Length(info[2]);
|
|
|
|
|
if (pool_size < 1 ||
|
|
|
|
|
pool_size > MAX_POOL_SIZE ||
|
|
|
|
|
buf == NULL ||
|
|
|
|
|
length != HASH_SIZE) {
|
|
|
|
|
return NanThrowError("Bad input");
|
|
|
|
|
return Nan::ThrowError("Bad input");
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
// TODO(Kagami): Do we need to process `std::bad_alloc`?
|
|
|
|
|
uint8_t* initial_hash = new uint8_t[length];
|
|
|
|
|
memcpy(initial_hash, buf, length);
|
|
|
|
|
NanCallback* callback = new NanCallback(args[3].As<Function>());
|
|
|
|
|
NanAsyncQueueWorker(new PowWorker(callback, pool_size, target, initial_hash));
|
|
|
|
|
NanReturnUndefined();
|
|
|
|
|
Nan::Callback* callback = new Nan::Callback(info[3].As<Function>());
|
|
|
|
|
Nan::AsyncQueueWorker(
|
|
|
|
|
new PowWorker(callback, pool_size, target, initial_hash));
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
void InitAll(Handle<Object> exports) {
|
|
|
|
|
exports->Set(
|
|
|
|
|
NanNew<String>("powAsync"),
|
|
|
|
|
NanNew<FunctionTemplate>(PowAsync)->GetFunction());
|
|
|
|
|
NAN_MODULE_INIT(InitAll) {
|
|
|
|
|
Nan::Set(target, Nan::New<String>("powAsync").ToLocalChecked(),
|
|
|
|
|
Nan::GetFunction(Nan::New<FunctionTemplate>(PowAsync)).ToLocalChecked());
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
NODE_MODULE(worker, InitAll)
|
|
|
|
|