Libev - I/O 回调

Question

我在 C/Linux 中有一个使用 TCP 套接字的聊天服务器。使用 libev 时，我能够为套接字创建一次读取事件的 ev_io 观察器。就像是：

ev_io* new_watcher = (ev_io*)malloc(sizeof(ev_io));

//initialize the watcher
ev_init(new_watcher, read_cb);

//set the fd and event to fire on write
ev_io_set(new_watcher, watcher->fd, EV_READ);

//start watching
ev_io_start(loop, new_watcher);

这工作正常，因为 read 事件只会在有数据要读取时触发。但是，我必须以不同的方式对待写入事件，因为即使我没有要写入的数据，它们也会不断触发。为了解决这个问题，我让我的 read_callback 为写数据创建一个 ev_io 观察者，只有当有数据准备好被写入时，然后 write_callback 将在发送它的消息后删除观察者。

这意味着每次我需要处理消息时，我都在分配、初始化、设置、监视、取消监视和释放写入监视程序。我担心我可能会错误地和低效地处理这个问题。

在 libev 中处理 write_callback 事件的最佳方法是什么？

提前致谢。

Answer 1

很简单，还有 ev_io_stop，所以你所做的不是启动写观察器，除非你有任何东西要写，并且在回调中，当你写完整个缓冲区时调用 ev_io_stop。

在写入缓冲区很少溢出的常见情况下（因为您的数据很小并且您不会经常写入），您可以通过尝试直接写入数据（如果观察者不活动）并且仅如果您无法完全写入数据，则缓冲数据并启动写入观察器。

在上述假设下，这意味着您几乎不需要启动写观察器。缺点是代码复杂得多，因此在许多情况下，最好从简单的“将数据附加到写入缓冲区，启动观察者，如果缓冲区已完全写入则在观察者内部停止它”逻辑开始。