使用C++ libgpiod计算GPIO事件间隔与RPM的问题排查

问题背景 #

我在C++中使用libgpiod，通过读取GPIO线路的RISING_EDGE事件来计算RPM。设计了包含count、start_timestamp、last_timestamp的counter_t结构体，在事件监听线程中，每次捕获上升沿事件时更新计数器，该线程工作正常，计数器能正确递增。

但在RPM计算环节出现问题：我启动了一个固定100ms间隔的线程，读取计数器数据计算RPM后重置计数器，却得到了不符合预期的结果——计算出的间隔远大于100ms，且速度始终为0。

问题1：如何解读libgpiod的event.timestamp？ #

libgpiod的事件时间戳（gpiod_event.timestamp）是从系统启动开始计算的单调时间，对应Linux内核的CLOCK_MONOTONIC时钟，等价于C++中std::chrono::steady_clock的time_point类型。它既不是纪元时间（Unix时间戳，从1970年1月1日开始），也不是带日期的绝对时间，是一个单调递增的数值，不会受系统时间调整（如NTP同步修改系统时间）的影响，专门用于可靠计算时间间隔。

问题2：如何计算两个libgpiod事件之间的纳秒级间隔？ #

libgpiod的事件时间戳以struct timespec结构存储，包含秒（tv_sec）和纳秒（tv_nsec）两个字段。计算两个事件的纳秒间隔可以按以下方式实现：

原生C方式 #

#include <time.h>

long long calculate_interval_ns(const struct timespec* ts1, const struct timespec* ts2) {
    long long ts1_total = ts1->tv_sec * 1000000000LL + ts1->tv_nsec;
    long long ts2_total = ts2->tv_sec * 1000000000LL + ts2->tv_nsec;
    return ts2_total - ts1_total;
}

C++ chrono库封装方式 #

#include <chrono>
#include <gpiod.hpp>

std::chrono::nanoseconds timespec_to_ns(const timespec& ts) {
    return std::chrono::seconds(ts.tv_sec) + std::chrono::nanoseconds(ts.tv_nsec);
}

// 使用示例
gpiod::line_event evt1 = ...;
gpiod::line_event evt2 = ...;
auto interval = timespec_to_ns(evt2.timestamp) - timespec_to_ns(evt1.timestamp);
long long interval_ns = interval.count();

问题3：如何将间隔转换为正确的RPM数值？ #

RPM是每分钟的转数，计算时需要先明确你的传感器每旋转一圈产生的上升沿脉冲数（记为N），然后分两种场景处理：

场景1：通过连续两个脉冲的间隔计算 #

如果是用相邻两个上升沿的时间间隔计算实时RPM：

1. 计算单个脉冲的时间间隔（单位：秒）：T = 间隔纳秒数 / 1e9
2. 每秒的脉冲频率：f = 1 / T
3. 转换为RPM：RPM = (f / N) * 60

场景2：通过固定时间窗口的脉冲数计算（你当前使用的方式） #

如果用固定时间窗口（比如100ms）内的脉冲计数来计算，正确公式为：
假设窗口内捕获到count个脉冲，窗口实际时长为t秒（需修正定时误差）：
RPM = (count / t) / N * 60

你之前结果异常的核心原因大概率是线程同步缺失：计算线程读取/重置计数器时没有用互斥锁保护counter_t结构体，导致读取到脏数据或丢失事件。另外，sleep_for的定时存在误差，建议计算实际窗口时长来修正。

修正后的代码示例：

#include <mutex>
#include <chrono>
#include <gpiod.hpp>
#include <thread>
#include <cstdio>

struct counter_t {
    int count = 0;
    timespec start_timestamp;
    timespec last_timestamp;
};

std::mutex counter_mutex;
counter_t rpm_counter;
const int PULSES_PER_REV = 1; // 根据你的传感器实际值修改

// 事件监听线程
void event_listener(gpiod::line& gpio_line) {
    while (true) {
        // 等待上升沿事件，超时1秒
        if (gpio_line.event_wait(std::chrono::seconds(1))) {
            auto evt = gpio_line.event_read();
            std::lock_guard<std::mutex> lock(counter_mutex);
            rpm_counter.count++;
            rpm_counter.last_timestamp = evt.timestamp;
        }
    }
}

// RPM计算线程
void rpm_calculator() {
    while (true) {
        auto window_start = std::chrono::steady_clock::now();
        
        // 加锁读取并重置计数器
        std::lock_guard<std::mutex> lock(counter_mutex);
        int current_count = rpm_counter.count;
        rpm_counter.count = 0;
        
        // 计算实际窗口时长（修正sleep误差）
        auto window_end = std::chrono::steady_clock::now();
        auto window_duration = std::chrono::duration_cast<std::chrono::microseconds>(window_end - window_start);
        double window_sec = window_duration.count() / 1e6;
        
        // 计算RPM
        double rpm = 0.0;
        if (current_count > 0 && window_sec > 0) {
            rpm = (current_count / window_sec) / PULSES_PER_REV * 60.0;
        }
        
        printf("当前RPM: %.2f\n", rpm);
        
        // 等待剩余时间，保证总窗口接近100ms
        auto remaining = std::chrono::milliseconds(100) - window_duration;
        if (remaining > std::chrono::microseconds(0)) {
            std::this_thread::sleep_for(remaining);
        }
    }
}

内容的提问来源于stack exchange，提问作者Mendes