mirror of
https://github.com/nodejs/node.git
synced 2025-05-07 23:52:40 +00:00
c0f3bc24de
Add a utility functions for addons to use when they need a reference to the current event loop. Currently, `uv_default_loop()` works if the embedder is the single-threaded default node executable, but even without the presence of e.g. workers that might not really an API guarantee for when Node is embedded. PR-URL: https://github.com/nodejs/node/pull/17109 Reviewed-By: Ben Noordhuis <info@bnoordhuis.nl> Reviewed-By: Colin Ihrig <cjihrig@gmail.com>
92 lines
2.1 KiB
C++
92 lines
2.1 KiB
C++
#include <node.h>
|
|
#include <v8.h>
|
|
#include <uv.h>
|
|
|
|
#if defined _WIN32
|
|
#include <windows.h>
|
|
#else
|
|
#include <unistd.h>
|
|
#endif
|
|
|
|
|
|
struct async_req {
|
|
uv_work_t req;
|
|
int input;
|
|
int output;
|
|
v8::Isolate* isolate;
|
|
v8::Persistent<v8::Function> callback;
|
|
};
|
|
|
|
void DoAsync(uv_work_t* r) {
|
|
async_req* req = reinterpret_cast<async_req*>(r->data);
|
|
// Simulate CPU intensive process...
|
|
#if defined _WIN32
|
|
Sleep(1000);
|
|
#else
|
|
sleep(1);
|
|
#endif
|
|
req->output = req->input * 2;
|
|
}
|
|
|
|
template <bool use_makecallback>
|
|
void AfterAsync(uv_work_t* r) {
|
|
async_req* req = reinterpret_cast<async_req*>(r->data);
|
|
v8::Isolate* isolate = req->isolate;
|
|
v8::HandleScope scope(isolate);
|
|
|
|
v8::Local<v8::Value> argv[2] = {
|
|
v8::Null(isolate),
|
|
v8::Integer::New(isolate, req->output)
|
|
};
|
|
|
|
v8::TryCatch try_catch(isolate);
|
|
|
|
v8::Local<v8::Object> global = isolate->GetCurrentContext()->Global();
|
|
v8::Local<v8::Function> callback =
|
|
v8::Local<v8::Function>::New(isolate, req->callback);
|
|
|
|
if (use_makecallback) {
|
|
v8::Local<v8::Value> ret =
|
|
node::MakeCallback(isolate, global, callback, 2, argv);
|
|
// This should be changed to an empty handle.
|
|
assert(!ret.IsEmpty());
|
|
} else {
|
|
callback->Call(global, 2, argv);
|
|
}
|
|
|
|
// cleanup
|
|
req->callback.Reset();
|
|
delete req;
|
|
|
|
if (try_catch.HasCaught()) {
|
|
node::FatalException(isolate, try_catch);
|
|
}
|
|
}
|
|
|
|
template <bool use_makecallback>
|
|
void Method(const v8::FunctionCallbackInfo<v8::Value>& args) {
|
|
v8::Isolate* isolate = args.GetIsolate();
|
|
|
|
async_req* req = new async_req;
|
|
req->req.data = req;
|
|
|
|
req->input = args[0]->IntegerValue();
|
|
req->output = 0;
|
|
req->isolate = isolate;
|
|
|
|
v8::Local<v8::Function> callback = v8::Local<v8::Function>::Cast(args[1]);
|
|
req->callback.Reset(isolate, callback);
|
|
|
|
uv_queue_work(node::GetCurrentEventLoop(isolate),
|
|
&req->req,
|
|
DoAsync,
|
|
(uv_after_work_cb)AfterAsync<use_makecallback>);
|
|
}
|
|
|
|
void init(v8::Local<v8::Object> exports, v8::Local<v8::Object> module) {
|
|
NODE_SET_METHOD(exports, "runCall", Method<false>);
|
|
NODE_SET_METHOD(exports, "runMakeCallback", Method<true>);
|
|
}
|
|
|
|
NODE_MODULE(NODE_GYP_MODULE_NAME, init)
|