У меня есть чат-сервер в 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_callback создает наблюдателя ev_io для данных записи только тогда, когда есть данные, готовые к записи, а затем write_callback удаляет наблюдателя после того, как он отправил свое сообщение.
Это означает, что я выделяю, инициализирую, устанавливаю, наблюдаю, снимаю отслеживание и освобождаю наблюдателя записи каждый раз, когда мне нужно обработать сообщение. Боюсь, что могу с этим справиться неправильно и неэффективно.
Как лучше всего обрабатывать события write_callback в libev?
Заранее спасибо.
