Method onANR

valdi/src/valdi/runtime/JavaScript/JavaScriptANRDetector.cpp:131–199

}

bool JavaScriptANRDetector::onANR(JavaScriptTaskScheduler& taskScheduler,
                                  std::chrono::steady_clock::duration detectionThreshold,
                                  const std::atomic<bool>& ack) {
    auto stacktraces = taskScheduler.captureStackTraces(std::chrono::seconds(kCaptureStacktraceTimeoutSeconds));
    StringBox moduleName;
    std::string message;

    if (!stacktraces.empty() && stacktraces[0].getContext() != nullptr) {
        moduleName = stacktraces[0].getContext()->getPath().getResourceId().bundleName;
    }

    if (!hasRunningStacktrace(stacktraces) && ack.load()) {
        // The ack was submitted while waiting to capture stacktraces.
        // We consider that task scheduler has recovered
        return true;
    }

    auto detectionThresholdString =
        snap::utils::time::Duration<std::chrono::steady_clock>(detectionThreshold).toString();
    if (moduleName.isEmpty()) {
        message = fmt::format("Detected unattributed ANR after {}", detectionThresholdString);
    } else {
        message = fmt::format("Detected ANR in '{}' after {}", moduleName, detectionThresholdString);
    }

    if (stacktraces.empty()) {
        message += " but unable to capture stack traces.";
    }

    // getCurrentModuleLoadInfo() reads saved native state, not JS, so it is safe to call while the
    // ANR has the JS thread stuck.
    auto moduleLoadInfo = taskScheduler.getCurrentModuleLoadInfo();
    if (!moduleLoadInfo.empty()) {
        message += " [module-load: " + moduleLoadInfo + "]";
    }

    VALDI_ERROR(*_logger, "{}", message);
    for (const auto& stacktrace : stacktraces) {
        if (stacktrace.getStatus() == JavaScriptCapturedStacktrace::Status::RUNNING) {
            VALDI_ERROR(*_logger, "ANR Stacktrace:\n{}", stacktrace.getStackTrace());
        }
    }

    Ref<Metrics> metrics;
    Ref<IJavaScriptANRDetectorListener> listener;
    {
        std::lock_guard<Mutex> lock(_mutex);
        metrics = _metrics;
        listener = _listener;
    }

    if (metrics != nullptr) {
        if (moduleName.isEmpty()) {
            metrics->emitANR();
        } else {
            metrics->emitANR(moduleName);
        }
    }