6.1 創建事件 · libevent深入淺出

# 6.1 創建事件 ##6.1.1 生成新事件使用 event_new()接口創建事件。 ```cpp #define EV_TIMEOUT 0x01 #define EV_READ 0x02 #define EV_WRITE 0x04 #define EV_SIGNAL 0x08 #define EV_PERSIST 0x10 #define EV_ET 0x20 typedef void (*event_callback_fn)(evutil_socket_t, short, void *); struct event *event_new(struct event_base *base, evutil_socket_t fd, short what, event_callback_fn cb, void *arg); void event_free(struct event *event); ``` event_new()試圖分配和構造一個用于 base 的新的事件。 what 參數是上述標志的集合。如果 fd 非負,則它是將被觀察其讀寫事件的文件。事件被激活時, libevent 將調用 cb 函數, 傳遞這些參數:文件描述符 fd,表示所有被觸發事件的位字段 ,以及構造事件時的 arg 參數。發生內部錯誤,或者傳入無效參數時, event_new()將返回 NULL。 >所有新創建的事件都處于已初始化和非未決狀態 ,調用 event_add()可以使其成為未決的。要釋放事件,調用 event_free()。對未決或者激活狀態的事件調用 event_free()是安全的:在釋放事件之前,函數將會使事件成為非激活和非未決的。 ###實例： ```cpp #include <event2/event.h> void cb_func(evutil_socket_t fd, short what, void *arg) { const char *data = arg; printf("Got an event on socket %d:%s%s%s%s [%s]", (int) fd, (what&EV_TIMEOUT) ? " timeout" : "", (what&EV_READ) ? " read" : "", (what&EV_WRITE) ? " write" : "", (what&EV_SIGNAL) ? " signal" : "", data); } void main_loop(evutil_socket_t fd1, evutil_socket_t fd2) { struct event *ev1, *ev2; struct timeval five_seconds = {5,0}; struct event_base *base = event_base_new(); /* The caller has already set up fd1, fd2 somehow, and make them nonblocking. */ ev1 = event_new(base, fd1, EV_TIMEOUT|EV_READ|EV_PERSIST, cb_func, (char*)"Reading event"); ev2 = event_new(base, fd2, EV_WRITE|EV_PERSIST, cb_func, (char*)"Writing event"); event_add(ev1, &five_seconds); event_add(ev2, NULL); event_base_dispatch(base); } ``` 上述函數定義在 <event2/event.h> 中,首次出現在 libevent 2.0.1-alpha 版本中。 event_callback_fn 類型首次在2.0.4-alpha 版本中作為 typedef 出現。 ## 6.1.2 事件標志 * EV_TIMEOUT 這個標志表示某超時時間流逝后事件成為激活的。構造事件的時候,EV_TIMEOUT 標志是被忽略的:可以在添加事件的時候設置超時 ,也可以不設置。超時發生時,回調函數的 what 參數將帶有這個標志。 * EV_READ 表示指定的文件描述符已經就緒,可以讀取的時候,事件將成為激活的。 * EV_WRITE 表示指定的文件描述符已經就緒,可以寫入的時候,事件將成為激活的。 * EV_SIGNAL 用于實現信號檢測,請看下面的 “構造信號事件”節。 * EV_PERSIST 表示事件是“持久的”,請看下面的“關于事件持久性”節。 * EV_ET 表示如果底層的 event_base 后端支持邊沿觸發事件,則事件應該是邊沿觸發的。這個標志影響 EV_READ 和 EV_WRITE 的語義。從2.0.1-alpha 版本開始,可以有任意多個事件因為同樣的條件而未決。比如說,可以有兩個事件因為某個給定的 fd 已經就緒,可以讀取而成為激活的。這種情況下,多個事件回調被執行的次序是不確定的。 >這些標志定義在<event2/event.h>中。除了 EV_ET 在2.0.1-alpha 版本中引入外,所有標志從1.0版本開始就存在了。 ## 6.1.3 關于事件持久性默認情況下,每當未決事件成為激活的(因為 fd 已經準備好讀取或者寫入,或者因為超時), 事件將在其回調被執行前成為非未決的。如果想讓事件再次成為未決的 ,可以在回調函數中再次對其調用 event_add()。然而,如果設置了 EV_PERSIST 標志,事件就是持久的。這意味著即使其回調被激活 ,事件還是會保持為未決狀態。如果想在回調中讓事件成為非未決的 ,可以對其調用 event_del ()。每次執行事件回調的時候,持久事件的超時值會被復位。因此,如果具有 EV_READ|EV_PERSIST 標志,以及5秒的超時值,則事件將在以下情況下成為激活的: * 套接字已經準備好被讀取的時候 * 從最后一次成為激活的開始,已經逝去 5秒 ## 6.1.4 信號事件 libevent 也可以監測 POSIX 風格的信號。要構造信號處理器,使用: ```cpp #define evsignal_new(base, signum, cb, arg) \ event_new(base, signum, EV_SIGNAL|EV_PERSIST, cb, arg) ``` 除了提供一個信號編號代替文件描述符之外,各個參數與 event_new()相同。 ###實例 ```cpp struct event *hup_event; struct event_base *base = event_base_new(); /* call sighup_function on a HUP signal */ hup_event = evsignal_new(base, SIGHUP, sighup_function, NULL); ``` >注意 :信號回調是信號發生后在事件循環中被執行的,所以可以安全地調用通常不能在 POSIX 風格信號處理器中使用的函數。 **`警告`:不要在信號事件上設置超時,這可能是不被支持的。 [待修正:真是這樣的嗎?]** libevent 也提供了一組方便使用的宏用于處理信號事件: ```cpp #define evsignal_add(ev, tv) \ event_add((ev),(tv)) #define evsignal_del(ev) \ event_del(ev) #define evsignal_pending(ev, what, tv_out) \ event_pending((ev), (what), (tv_out)) ``` evsignal_*宏從2.0.1-alpha 版本開始存在。先前版本中這些宏叫做 signal_add()、signal_del ()等等。 ### 關于信號的警告在當前版本的 libevent 和大多數后端中,每個進程任何時刻只能有一個 event_base 可以監聽信號。如果同時向兩個 event_base 添加信號事件,即使是不同的信號,也只有一個 event_base 可以取得信號。 kqueue 后端沒有這個限制。