Lines Matching refs:readers_head
371 AsyncSocketIO* readers_head; member
436 return _async_socket_pull_first_io(as, &as->readers_head, &as->readers_tail); in _async_socket_pull_first_reader()
525 _async_socket_advance_io(as, &as->readers_head, &as->readers_tail); in _async_socket_advance_reader()
578 _async_socket_remove_io(as, &as->readers_head, &as->readers_tail, asio); in _async_socket_io_timed_out()
635 while (as->readers_head != NULL) { in _async_socket_cancel_readers()
797 AsyncSocketIO* const asr = as->readers_head; in _on_async_socket_recv()
820 if (as->readers_head != NULL) { in _on_async_socket_recv()
861 if (as->readers_head != NULL) { in _on_async_socket_recv()
883 if (as->readers_head != NULL) { in _on_async_socket_recv()
1119 as->readers_head = as->readers_tail = NULL; in async_socket_new()
1221 if (as->readers_head == NULL) { in async_socket_read_abs()
1222 as->readers_head = as->readers_tail = asr; in async_socket_read_abs()