Method processMonitorCycle

src/flightRecorder.cpp:454–472

    }

    void processMonitorCycle(const u64 wall_time) {
        if (!_process_sampler.shouldSample(wall_time)) return;

        const u64 deadline_ns = OS::nanotime() + MAX_TIME_NS;
        const int process_count = _process_sampler.sample(wall_time);
        for (int pid_index = 0; pid_index < process_count; pid_index++) {
            const u64 current_time = OS::nanotime();
            if (current_time > deadline_ns) {
                Log::debug("Sampled %d of %d processes due to time limit", pid_index, process_count);
                break;
            }

            ProcessInfo info;
            if (_process_sampler.getProcessInfo(pid_index, current_time, info)) {
                flushIfNeeded(&_proc_buf, RECORDING_BUFFER_LIMIT - MAX_PROCESS_SAMPLE_JFR_EVENT_LENGTH);
                recordProcessSample(&_proc_buf, &info);
            }
        }
    }

    bool hasMasterRecording() const {
        return _master_recording_file != NULL;