Welcome to mirror list, hosted at ThFree Co, Russian Federation.

github.com/nodejs/node.git - Unnamed repository; edit this file 'description' to name the repository.
summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
Diffstat (limited to 'src/env-inl.h')
-rw-r--r--src/env-inl.h11
1 files changed, 7 insertions, 4 deletions
diff --git a/src/env-inl.h b/src/env-inl.h
index b0af5bfcbdc..d78ed09d40d 100644
--- a/src/env-inl.h
+++ b/src/env-inl.h
@@ -820,8 +820,9 @@ void Environment::SetImmediateThreadsafe(Fn&& cb) {
{
Mutex::ScopedLock lock(native_immediates_threadsafe_mutex_);
native_immediates_threadsafe_.Push(std::move(callback));
+ if (task_queues_async_initialized_)
+ uv_async_send(&task_queues_async_);
}
- uv_async_send(&task_queues_async_);
}
template <typename Fn>
@@ -831,8 +832,9 @@ void Environment::RequestInterrupt(Fn&& cb) {
{
Mutex::ScopedLock lock(native_immediates_threadsafe_mutex_);
native_immediates_interrupts_.Push(std::move(callback));
+ if (task_queues_async_initialized_)
+ uv_async_send(&task_queues_async_);
}
- uv_async_send(&task_queues_async_);
RequestInterruptFromV8();
}
@@ -893,11 +895,11 @@ inline bool Environment::is_main_thread() const {
}
inline bool Environment::owns_process_state() const {
- return flags_ & kOwnsProcessState;
+ return flags_ & EnvironmentFlags::kOwnsProcessState;
}
inline bool Environment::owns_inspector() const {
- return flags_ & kOwnsInspector;
+ return flags_ & EnvironmentFlags::kOwnsInspector;
}
bool Environment::filehandle_close_warning() const {
@@ -1226,6 +1228,7 @@ void Environment::RemoveCleanupHook(void (*fn)(void*), void* arg) {
inline void Environment::RegisterFinalizationGroupForCleanup(
v8::Local<v8::FinalizationGroup> group) {
cleanup_finalization_groups_.emplace_back(isolate(), group);
+ DCHECK(task_queues_async_initialized_);
uv_async_send(&task_queues_async_);
}