Lines Matching refs:iolooper
24 #include "iolooper.h"
34 IoLooper* iolooper;
47 sync_socket->iolooper = iolooper_new();
56 IoLooper* looper;
65 // Connected. Create IoLooper for the helper.
95 sync_socket->iolooper = looper;
105 if (ssocket->iolooper != NULL) {
106 iolooper_reset(ssocket->iolooper);
117 if (ssocket->iolooper != NULL) {
118 iolooper_free(ssocket->iolooper);
127 if (ssocket == NULL || ssocket->fd < 0 || ssocket->iolooper == NULL) {
131 iolooper_add_read(ssocket->iolooper, ssocket->fd);
138 if (ssocket == NULL || ssocket->fd < 0 || ssocket->iolooper == NULL) {
142 iolooper_del_read(ssocket->iolooper, ssocket->fd);
149 if (ssocket == NULL || ssocket->fd < 0 || ssocket->iolooper == NULL) {
153 iolooper_add_write(ssocket->iolooper, ssocket->fd);
160 if (ssocket == NULL || ssocket->fd < 0 || ssocket->iolooper == NULL) {
164 iolooper_del_write(ssocket->iolooper, ssocket->fd);
176 if (ssocket == NULL || ssocket->fd < 0 || ssocket->iolooper == NULL) {
181 ret = iolooper_wait_absolute(ssocket->iolooper, deadline);
183 if (!iolooper_is_read(ssocket->iolooper, ssocket->fd)) {
213 if (ssocket == NULL || ssocket->fd < 0 || ssocket->iolooper == NULL) {
219 ret = iolooper_wait_absolute(ssocket->iolooper, deadline);
227 if (!iolooper_is_write(ssocket->iolooper, ssocket->fd)) {
