DCHECK(g_instance == nullptr);

g_instance = new CallbacksMonitor(max_interval_ms);

struct timespec tp;

clock_gettime(CLOCK_MONOTONIC, &tp);

return tp.tv_sec * 1000L + tp.tv_nsec / 1000000L;

OngoingCall ongoing_call { GetCurrentTimeMillis(), tag };

std::lock_guard<std::mutex> lock(mu_);

return ongoing_calls_.insert(ongoing_calls_.begin(), ongoing_call);

int64 current_time_ms = GetCurrentTimeMillis();

std::lock_guard<std::mutex> lock(mu_);

if (current_time_ms - id->start_time_ms > max_call_duration_ms_) {

LOG(INFO) << "Cloud Debugger call \"" << id->tag

<< "\" completed after " << current_time_ms - id->start_time_ms

<< " ms";

last_unhealthy_time_ms_ = current_time_ms;

}

ongoing_calls_.erase(id);

bool rc = true;

int64 current_time_ms = GetCurrentTimeMillis();

std::lock_guard<std::mutex> lock(mu_);

if (last_unhealthy_time_ms_ >= timestamp) {

LOG(WARNING) << "Unhealthy callback completed "

<< current_time_ms - last_unhealthy_time_ms_ << " ms ago";

return false;

}

for (auto it = ongoing_calls_.begin(); it != ongoing_calls_.end(); ++it) {

int64 duration_ms = current_time_ms - it->start_time_ms;

if (duration_ms > max_call_duration_ms_) {

LOG(WARNING) << "Cloud Debugger call \"" << it->tag

<< "\" hasn't completed in " << duration_ms

<< " ms, possibly stuck";

rc = false;

}

}

return rc;