Lines Matching refs:flush_tasks_
70 uv_async_send(&flush_tasks_); in PostDelayedTask()
75 uv_async_send(&flush_tasks_); in Stop()
84 flush_tasks_.data = this; in Run()
85 CHECK_EQ(0, uv_async_init(&loop_, &flush_tasks_, FlushTasks)); in Run()
109 uv_close(reinterpret_cast<uv_handle_t*>(&scheduler_->flush_tasks_), in Run()
162 uv_async_t flush_tasks_; member in node::WorkerThreadsTaskRunner::DelayedTaskScheduler
225 flush_tasks_ = new uv_async_t(); in PerIsolatePlatformData()
226 CHECK_EQ(0, uv_async_init(loop, flush_tasks_, FlushTasks)); in PerIsolatePlatformData()
227 flush_tasks_->data = static_cast<void*>(this); in PerIsolatePlatformData()
228 uv_unref(reinterpret_cast<uv_handle_t*>(flush_tasks_)); in PerIsolatePlatformData()
246 if (flush_tasks_ == nullptr) { in PostTask()
252 uv_async_send(flush_tasks_); in PostTask()
257 if (flush_tasks_ == nullptr) { in PostDelayedTask()
267 uv_async_send(flush_tasks_); in PostDelayedTask()
281 CHECK(!flush_tasks_); in ~PerIsolatePlatformData()
290 if (flush_tasks_ == nullptr) in Shutdown()
306 uv_close(reinterpret_cast<uv_handle_t*>(flush_tasks_), in Shutdown()
315 flush_tasks_ = nullptr; in Shutdown()