7.5.2 操作回调、水位和启用/禁用

  1. typedef void (*bufferevent_data_cb)(struct bufferevent *bev, void *ctx);
  2. typedef void (*bufferevent_event_cb)(struct bufferevent *bev,
  3.     short events, void *ctx);
  5. void bufferevent_setcb(struct bufferevent *bufev,
  6.     bufferevent_data_cb readcb, bufferevent_data_cb writecb,
  7.     bufferevent_event_cb eventcb, void *cbarg);
  9. void bufferevent_getcb(struct bufferevent *bufev,
  10.     bufferevent_data_cb *readcb_ptr,
  11.     bufferevent_data_cb *writecb_ptr,
  12.     bufferevent_event_cb *eventcb_ptr,
  13.     void **cbarg_ptr);

bufferevent_setcb()函数修改 bufferevent 的一个或者多个回调 。readcb、writecb和eventcb函数将分别在已经读取足够的数据 、已经写入足够的数据 ,或者发生错误时被调用 。

每个回调函数的第一个参数都是发生了事件的bufferevent ,最后一个参数都是调用bufferevent_setcb()时用户提供的 cbarg 参数:可以通过它向回调传递数据。事件回调 的 events 参数是一个表示事件标志的位掩码:请看前面的 “回调和水位”节。

要禁用回调,传递 NULL 而不是回调函数 。注意:bufferevent 的所有回调函数共享单 个 cbarg, 所以修改它将影响所有回调函数。

接口

  1. void bufferevent_enable(struct bufferevent *bufev, short events);
  2. void bufferevent_disable(struct bufferevent *bufev, short events);
  4. short bufferevent_get_enabled(struct bufferevent *bufev);

可以启用或者禁用 bufferevent 上的 EV_READ、EV_WRITE 或者 EV_READ | EV_WRITE 事件。没有启用读取或者写入事件时, bufferevent 将不会试图进行数据读取或者写入。

没有必要在输出缓冲区空时禁用写入事件: bufferevent 将自动停止写入,然后在有数据等 待写入时重新开始。

类似地,没有必要在输入缓冲区高于高水位时禁用读取事件 :bufferevent 将自动停止读取, 然后在有空间用于读取时重新开始读取。

默认情况下,新创建的 bufferevent 的写入是启用的,但是读取没有启用。可以调用 bufferevent_get_enabled()确定 bufferevent 上当前启用的事件。

接口

  1. void bufferevent_setwatermark(struct bufferevent *bufev, short events,
  2.     size_t lowmark, size_t highmark);

bufferevent_setwatermark()函数调整单个 bufferevent 的读取水位、写入水位,或者同时调 整二者。(如果 events 参数设置了 EV_READ,调整读取水位。如果 events 设置了 EV_WRITE 标志,调整写入水位)

对于高水位,0表示“无限”。

示例

  1. #include <event2/event.h>
  2. #include <event2/bufferevent.h>
  3. #include <event2/buffer.h>
  4. #include <event2/util.h>
  6. #include <stdlib.h>
  7. #include <errno.h>
  8. #include <string.h>
  10. struct info {
  11.     const char *name;
  12.     size_t total_drained;
  13. };
  15. void read_callback(struct bufferevent *bev, void *ctx)
  16. {
  17.     struct info *inf = ctx;
  18.     struct evbuffer *input = bufferevent_get_input(bev);
  19.     size_t len = evbuffer_get_length(input);
  20.     if (len) {
  21.         inf->total_drained += len;
  22.         evbuffer_drain(input, len);
  23.         printf("Drained %lu bytes from %s\n",
  24.              (unsigned long) len, inf->name);
  25.     }
  26. }
  28. void event_callback(struct bufferevent *bev, short events, void *ctx)
  29. {
  30.     struct info *inf = ctx;
  31.     struct evbuffer *input = bufferevent_get_input(bev);
  32.     int finished = 0;
  34.     if (events & BEV_EVENT_EOF) {
  35.         size_t len = evbuffer_get_length(input);
  36.         printf("Got a close from %s.  We drained %lu bytes from it, "
  37.             "and have %lu left.\n", inf->name,
  38.             (unsigned long)inf->total_drained, (unsigned long)len);
  39.         finished = 1;
  40.     }
  41.     if (events & BEV_EVENT_ERROR) {
  42.         printf("Got an error from %s: %s\n",
  43.             inf->name, evutil_socket_error_to_string(EVUTIL_SOCKET_ERROR()));
  44.         finished = 1;
  45.     }
  46.     if (finished) {
  47.         free(ctx);
  48.         bufferevent_free(bev);
  49.     }
  50. }
  52. struct bufferevent *setup_bufferevent(void)
  53. {
  54.     struct bufferevent *b1 = NULL;
  55.     struct info *info1;
  57.     info1 = malloc(sizeof(struct info));
  58.     info1->name = "buffer 1";
  59.     info1->total_drained = 0;
  61.     /* ... Here we should set up the bufferevent and make sure it gets
  62.        connected... */
  64.     /* Trigger the read callback only whenever there is at least 128 bytes
  65.        of data in the buffer. */
  66.     bufferevent_setwatermark(b1, EV_READ, 128, 0);
  68.     bufferevent_setcb(b1, read_callback, NULL, event_callback, info1);
  70.     bufferevent_enable(b1, EV_READ); /* Start reading. */
  71.     return b1;
  72. }