std::unique_ptr<uv_thread_t> Start() {

auto start_thread = [](void* data) {

uv_thread_setname("DelayedTaskSchedulerWorker");

static_cast<DelayedTaskScheduler*>(data)->Run();

};

std::unique_ptr<uv_thread_t> t { new uv_thread_t() };

void Watchdog::Run(void* arg) {

uv_thread_setname("Watchdog");

Watchdog* wd = static_cast<Watchdog*>(arg);

// UV_RUN_DEFAULT the loop will be stopped either by the async or the

#ifdef __POSIX__

void* SigintWatchdogHelper::RunSigintWatchdog(void* arg) {

uv_thread_setname("SigintWatchdog");

// Inside the helper thread.

bool is_stopping;

do {

uv_sem_wait(&instance.sem_);

is_stopping = InformWatchdogsAboutSignal();

// This thread should be created *after* async handles are created

// (within NodeTraceWriter and NodeTraceBuffer constructors).

// Otherwise the thread could shut down prematurely.

CHECK_EQ(0, uv_thread_create(&thread_, [](void* arg) {

Agent* agent = static_cast<Agent*>(arg);

uv_run(&agent->tracing_loop_, UV_RUN_DEFAULT);

}, this));

CHECK_EQ(0,

uv_thread_create(

&thread_,

[](void* arg) {

uv_thread_setname("TraceEventWorker");

Agent* agent = static_cast<Agent*>(arg);

uv_run(&agent->tracing_loop_, UV_RUN_DEFAULT);

},

this));

started_ = true;

}