• Home
  • Raw
  • Download

Lines Matching refs:iol

25     IoLooper*  iol = malloc(sizeof(*iol));  in iolooper_new()  local
26 iolooper_reset(iol); in iolooper_new()
27 return iol; in iolooper_new()
31 iolooper_free( IoLooper* iol ) in iolooper_free() argument
33 free(iol); in iolooper_free()
37 iolooper_reset( IoLooper* iol ) in iolooper_reset() argument
39 FD_ZERO(iol->reads); in iolooper_reset()
40 FD_ZERO(iol->writes); in iolooper_reset()
41 iol->max_fd = -1; in iolooper_reset()
42 iol->max_fd_valid = 1; in iolooper_reset()
46 iolooper_add_fd( IoLooper* iol, int fd ) in iolooper_add_fd() argument
48 if (iol->max_fd_valid && fd > iol->max_fd) { in iolooper_add_fd()
49 iol->max_fd = fd; in iolooper_add_fd()
54 iolooper_del_fd( IoLooper* iol, int fd ) in iolooper_del_fd() argument
56 if (iol->max_fd_valid && fd == iol->max_fd) in iolooper_del_fd()
57 iol->max_fd_valid = 0; in iolooper_del_fd()
61 iolooper_modify( IoLooper* iol, int fd, int oldflags, int newflags ) in iolooper_modify() argument
70 iolooper_add_read(iol, fd); in iolooper_modify()
72 iolooper_del_read(iol, fd); in iolooper_modify()
76 iolooper_add_write(iol, fd); in iolooper_modify()
78 iolooper_del_write(iol, fd); in iolooper_modify()
84 iolooper_fd_count( IoLooper* iol ) in iolooper_fd_count() argument
86 int max_fd = iol->max_fd; in iolooper_fd_count()
89 if (iol->max_fd_valid) in iolooper_fd_count()
94 if (!FD_ISSET(fd, iol->reads) && !FD_ISSET(fd, iol->writes)) in iolooper_fd_count()
99 iol->max_fd = max_fd; in iolooper_fd_count()
100 iol->max_fd_valid = 1; in iolooper_fd_count()
106 iolooper_add_read( IoLooper* iol, int fd ) in iolooper_add_read() argument
109 iolooper_add_fd(iol, fd); in iolooper_add_read()
110 FD_SET(fd, iol->reads); in iolooper_add_read()
115 iolooper_add_write( IoLooper* iol, int fd ) in iolooper_add_write() argument
118 iolooper_add_fd(iol, fd); in iolooper_add_write()
119 FD_SET(fd, iol->writes); in iolooper_add_write()
124 iolooper_del_read( IoLooper* iol, int fd ) in iolooper_del_read() argument
127 iolooper_del_fd(iol, fd); in iolooper_del_read()
128 FD_CLR(fd, iol->reads); in iolooper_del_read()
133 iolooper_del_write( IoLooper* iol, int fd ) in iolooper_del_write() argument
136 iolooper_del_fd(iol, fd); in iolooper_del_write()
137 FD_CLR(fd, iol->writes); in iolooper_del_write()
142 iolooper_poll( IoLooper* iol ) in iolooper_poll() argument
144 int count = iolooper_fd_count(iol); in iolooper_poll()
158 iol->reads_result[0] = iol->reads[0]; in iolooper_poll()
159 iol->writes_result[0] = iol->writes[0]; in iolooper_poll()
161 ret = select( count, iol->reads_result, iol->writes_result, &errs, &tv); in iolooper_poll()
168 iolooper_wait( IoLooper* iol, int64_t duration ) in iolooper_wait() argument
170 int count = iolooper_fd_count(iol); in iolooper_wait()
191 iol->reads_result[0] = iol->reads[0]; in iolooper_wait()
192 iol->writes_result[0] = iol->writes[0]; in iolooper_wait()
194 ret = select( count, iol->reads_result, iol->writes_result, &errs, tm); in iolooper_wait()
206 iolooper_is_read( IoLooper* iol, int fd ) in iolooper_is_read() argument
208 return FD_ISSET(fd, iol->reads_result); in iolooper_is_read()
212 iolooper_is_write( IoLooper* iol, int fd ) in iolooper_is_write() argument
214 return FD_ISSET(fd, iol->writes_result); in iolooper_is_write()
218 iolooper_has_operations( IoLooper* iol ) in iolooper_has_operations() argument
220 return iolooper_fd_count(iol) > 0; in iolooper_has_operations()
232 iolooper_wait_absolute(IoLooper* iol, int64_t deadline) in iolooper_wait_absolute() argument
241 return iolooper_wait(iol, timeout); in iolooper_wait_absolute()