|
15 | 15 |
|
16 | 16 | namespace node { |
17 | 17 |
|
18 | | -inline AsyncWrap::AsyncWrap(Environment* env, |
19 | | - v8::Local<v8::Object> object, |
20 | | - ProviderType provider, |
21 | | - AsyncWrap* parent) |
22 | | - : BaseObject(env, object), bits_(static_cast<uint32_t>(provider) << 1), |
23 | | - uid_(env->get_async_wrap_uid()) { |
24 | | - CHECK_NE(provider, PROVIDER_NONE); |
25 | | - CHECK_GE(object->InternalFieldCount(), 1); |
26 | | - |
27 | | - // Shift provider value over to prevent id collision. |
28 | | - persistent().SetWrapperClassId(NODE_ASYNC_ID_OFFSET + provider); |
29 | | - |
30 | | - v8::Local<v8::Function> init_fn = env->async_hooks_init_function(); |
31 | | - |
32 | | - // No init callback exists, no reason to go on. |
33 | | - if (init_fn.IsEmpty()) |
34 | | - return; |
35 | | - |
36 | | - // If async wrap callbacks are disabled and no parent was passed that has |
37 | | - // run the init callback then return. |
38 | | - if (!env->async_wrap_callbacks_enabled() && |
39 | | - (parent == nullptr || !parent->ran_init_callback())) |
40 | | - return; |
41 | | - |
42 | | - v8::HandleScope scope(env->isolate()); |
43 | | - |
44 | | - v8::Local<v8::Value> argv[] = { |
45 | | - v8::Number::New(env->isolate(), get_uid()), |
46 | | - v8::Int32::New(env->isolate(), provider), |
47 | | - Null(env->isolate()), |
48 | | - Null(env->isolate()) |
49 | | - }; |
50 | | - |
51 | | - if (parent != nullptr) { |
52 | | - argv[2] = v8::Number::New(env->isolate(), parent->get_uid()); |
53 | | - argv[3] = parent->object(); |
54 | | - } |
55 | | - |
56 | | - v8::TryCatch try_catch(env->isolate()); |
57 | | - |
58 | | - v8::MaybeLocal<v8::Value> ret = |
59 | | - init_fn->Call(env->context(), object, arraysize(argv), argv); |
60 | | - |
61 | | - if (ret.IsEmpty()) { |
62 | | - ClearFatalExceptionHandlers(env); |
63 | | - FatalException(env->isolate(), try_catch); |
64 | | - } |
65 | | - |
66 | | - bits_ |= 1; // ran_init_callback() is true now. |
67 | | -} |
68 | | - |
69 | | - |
70 | | -inline AsyncWrap::~AsyncWrap() { |
71 | | - if (!ran_init_callback()) |
72 | | - return; |
73 | | - |
74 | | - v8::Local<v8::Function> fn = env()->async_hooks_destroy_function(); |
75 | | - if (!fn.IsEmpty()) { |
76 | | - v8::HandleScope scope(env()->isolate()); |
77 | | - v8::Local<v8::Value> uid = v8::Number::New(env()->isolate(), get_uid()); |
78 | | - v8::TryCatch try_catch(env()->isolate()); |
79 | | - v8::MaybeLocal<v8::Value> ret = |
80 | | - fn->Call(env()->context(), v8::Null(env()->isolate()), 1, &uid); |
81 | | - if (ret.IsEmpty()) { |
82 | | - ClearFatalExceptionHandlers(env()); |
83 | | - FatalException(env()->isolate(), try_catch); |
84 | | - } |
85 | | - } |
86 | | -} |
87 | | - |
88 | | - |
89 | 18 | inline bool AsyncWrap::ran_init_callback() const { |
90 | 19 | return static_cast<bool>(bits_ & 1); |
91 | 20 | } |
|
0 commit comments