Lines Matching refs:flush_tasks_
77 uv_async_send(&flush_tasks_);
82 uv_async_send(&flush_tasks_);
91 flush_tasks_.data = this;
92 CHECK_EQ(0, uv_async_init(&loop_, &flush_tasks_, FlushTasks));
116 uv_close(reinterpret_cast<uv_handle_t*>(&scheduler_->flush_tasks_),
169 uv_async_t flush_tasks_;
232 flush_tasks_ = new uv_async_t();
233 CHECK_EQ(0, uv_async_init(loop, flush_tasks_, FlushTasks));
234 flush_tasks_->data = static_cast<void*>(this);
235 uv_unref(reinterpret_cast<uv_handle_t*>(flush_tasks_));
253 if (flush_tasks_ == nullptr) {
259 uv_async_send(flush_tasks_);
264 if (flush_tasks_ == nullptr) {
274 uv_async_send(flush_tasks_);
288 CHECK(!flush_tasks_);
297 if (flush_tasks_ == nullptr)
309 // flush_tasks_ handle add tasks to the event loop. We keep a count of all
313 uv_close(reinterpret_cast<uv_handle_t*>(flush_tasks_),
322 flush_tasks_ = nullptr;