使用libev的套接字

Question

我想写一个基于libev的套接字程序。我注意到在https://github.com/coolaj86/libev-examples/blob/master/src/unix-echo-server.c中有几个例子使用了基于初始化的回调。例如,

main() {

......
ev_io_init(&client.io, client_cb, client.fd, EV_READ|EV_WRITE);
ev_io_start(EV_A_ &server.io);

}

static void client_cb (EV_P_ ev_io *w, int revents)
{
  if (revents & EV_READ)
  {
      ....
  } else if (revents & EV_WRITE) {

     ......
  }
}

我的问题来自预期行为，例如，我在EV_READ中读取的所有内容都存储在一个链表中。比方说，我一直在自由地获取要读取的数据包，我还会有机会进入EV_WRITE吗？我必须将我接收到的所有读数据发送到另一个套接字。那么，它会是一次EV_READ和第二次EV_WRITE吗？换句话说，EV_WRITE什么时候会被解锁？或者我需要阻止EV_READ才能调用EV_WRITE。有人能帮我理解一下吗？

Answer 1

简而言之:如果您总是先检查一种类型的事件，然后再为另一种事件创建else if，那么您就会面临饥饿的风险。一般情况下，我会检查两者，除非指定的协议不可能同时激活这两个。

这里有一个更可疑的答案:你的问题中的链接不包含你的问题这样的代码结构。客户端https://github.com/coolaj86/libev-examples/blob/master/src/unix-echo-client.c也有类似的回调。您将注意到，当它只写入一次时，它会禁用写入事件。

// once the data is sent, stop notifications that
// data can be sent until there is actually more
// data to send
ev_io_stop(EV_A_ &send_w);
ev_io_set(&send_w, remote_fd, EV_READ);
ev_io_start(EV_A_ &send_w);

这看起来像是为了避免管道读取事件分支的匮乏。尽管我对libev不是很熟悉，但是你链接的github示例看起来并不是很健壮。例如，static void stdin_cb (EV_P_ ev_io *w, int revents)不使用getline()的返回值来检测EOF。此外，不会检查send()和recv()套接字操作返回值的读取或写入数量(尽管在本地命名管道流上，数量很可能与请求的数量匹配)。如果后来将其更改为基于TCP的连接，则检查数量将至关重要。

Answer 2

我认为你应该把write回调和read回调分开：

main() {
    ev_io_init(&read.io, read_cb, client.fd, EV_READ);
    ev_io_init(&write.io, writead_cb, client.fd, EV_WRITE);
    ev_io_start(EV_A_ &read.io);
    ev_io_start(EV_A_ &write.io);
}

这是我的解决方案。