海思平台水印功能实现之二定时器Timer

定时器可以自己创建或者直接使用POSIX Timer，我们这边水印每隔1秒刷新时间的时候使用的是POSIX Timer。

POSIX timer相关的操作，主要包括创建一个timer(timer_create)、设定timer(timer_settime)、获取timer的状态、获取timer overrun的信息、删除timer，本文将使用Posix Timer的回调函数传递指针以便于在回调处理传递的数据。虽然POSIX timer可以基于各种不同的clock创建，本文主要描述real time clock相关的timer。

1、struct itimerspec介绍

struct itimerspec {
    struct timespec it_interval; //首次超时后，每隔it_interval超时一次（调用回调函数）
    struct timespec it_value; //首次超时时间
}

通常，it_interval 指定连续计时器到期之间的时间段。 零值意味着警报只会触发一次。 如果 it_value 非零，则表示距离下一次定时器到期的剩余时间。 值为零意味着定时器被禁用。

2、Sigevent相关介绍请参考：sigevent(7) — Linux manual pages (courier-mta.org)

sigevent 结构被各种 API 用来描述进程被通知事件的方式（例如，异步请求的完成、计时器到期或消息的到达）。 SYNOPSIS 中显示的定义是近似的：sigevent 结构中的某些字段可能被定义为联合的一部分。 程序应该只使用那些与 sigev_notify 中指定的值相关的字段。 sigev_notify 字段指定如何执行通知。 该字段可以具有以下值之一：

SIGEV_NONE
“空”通知：事件发生时不做任何事情。
 
SIGEV_SIGNAL
通过发送 sigev_signo 中指定的信号通知进程。
 
如果信号被使用 sigaction(2) SA_SIGINFO 标志注册的信号处理程序捕获，则在作为处理程序的第二个参数传递的 siginfo_t 结构中设置以下字段：
 
si_code
此字段设置为取决于传递通知的 API 的值。
 
si_signo
该字段设置为信号编号（即与 sigev_signo 中的值相同）。
 
si_value
该字段设置为 sigev_value 中指定的值。
 
根据 API，还可以在 siginfo_t 结构中设置其他字段。
 
如果使用 sigwaitinfo(2) 接受信号，同样的信息也可用。
 
SIGEV_线程
通过调用 sigev_notify_function 来通知进程，“就好像”它是一个新线程的启动函数。 （这里的实现可能性包括每个计时器通知都可能导致创建一个新线程，或者创建一个线程来接收所有通知。）该函数以 sigev_value 作为其唯一参数调用。如果 sigev_notify_attributes 不为 NULL，它应该指向定义新线程属性的 pthread_attr_t 结构（请参阅 pthread_attr_init(3)）。
 
SIGEV_THREAD_ID（特定于 Linux）
目前仅供 POSIX 计时器使用；请参阅 timer_create(2)。

3、实战例子 posix_timer.cpp

#include 
#include 
#include 
#include 
#include 
 
#define DBG(fmt,...) printf("%s[%d]:" fmt,__FILE__,__LINE__,##__VA_ARGS__)
 
struct posix_timer {
    struct itimerspec ts; //用于配置定时器时间
    timer_t timer;
    int data;
};
 
void timer_callback_handler(union sigval v)
{
    struct posix_timer* ptr = NULL;
    ptr = (struct posix_timer*) v.sival_ptr;
    DBG("sigval_int %p\n", ptr);
    DBG("ptr data=%d\n", ptr->data);
    timer_settime(&ptr->timer, 0, &ptr->ts,NULL);
}
 
int main(void)
{
    int ret;
    struct sigevent evp;
    struct posix_timer pt;
 
    evp.sigev_notify = SIGEV_THREAD;
    evp.sigev_notify_function = timer_callback_handler;
    evp.sigev_value.sival_ptr = &pt;  //传递参数给timeout时的参数
    evp.sigev_notify_attributes = NULL;
 
   
    pt.ts.it_value.tv_sec = 1; //第一次调用后超时时间
    pt.ts.it_value.tv_nsec = 0;
    pt.ts.it_interval.tv_sec = 2; //第一次调用后，每隔2秒调用一次
    pt.ts.it_interval.tv_nsec = 0;
    pt.data = 1987;
 
    DBG("posix_timer ptr address:%p,data=%d\n", &pt, pt.data);
    /* set timerid and evp */
    ret = timer_create(CLOCK_REALTIME, &evp, &pt.timer);
    if (ret < 0)
        DBG("failed to create timer!\n");
 
    ret = timer_settime(pt.timer, 0, &pt.ts, NULL);
    if (ret < 0)
        DBG("failed to set timer!\n");
 
    pause();
 
}
 

编译：

#gcc -o posix_timer posix_timer.cpp -lrt
#./posix_timer

输出：

posix_timer.cpp[41]:posix_timer ptr address:0x7ffdfab5c2e0,data=1987
posix_timer.cpp[19]:sigval_int 0x7ffdfab5c2e0
posix_timer.cpp[20]:ptr data=1987
posix_timer.cpp[19]:sigval_int 0x7ffdfab5c2e0
posix_timer.cpp[20]:ptr data=1987
posix_timer.cpp[19]:sigval_int 0x7ffdfab5c2e0
posix_timer.cpp[20]:ptr data=1987
posix_timer.cpp[19]:sigval_int 0x7ffdfab5c2e0
posix_timer.cpp[20]:ptr data=1987