Lines Matching defs:asr
797 AsyncSocketIO* const asr = as->readers_head;
798 if (asr == NULL) {
805 async_socket_io_reference(asr);
808 if (asr->state == ASIO_STATE_QUEUED) {
809 asr->state = ASIO_STATE_STARTED;
811 asr->state = ASIO_STATE_CONTINUES;
813 action = asr->on_io(asr->io_opaque, asr, asr->state);
825 async_socket_io_release(asr);
830 int res = socket_recv(as->fd, asr->buffer + asr->transferred,
831 asr->to_transfer - asr->transferred);
833 res = socket_recv(as->fd, asr->buffer + asr->transferred,
834 asr->to_transfer - asr->transferred);
841 async_socket_io_release(asr);
849 async_socket_io_release(asr);
854 action = _on_async_socket_failure(as, asr);
867 async_socket_io_release(asr);
872 asr->transferred += res;
873 if (asr->transferred == asr->to_transfer) {
878 _async_socket_complete_io(as, asr);
889 async_socket_io_release(asr);
1215 AsyncSocketIO* const asr =
1222 as->readers_head = as->readers_tail = asr;
1224 as->readers_tail->next = asr;
1225 as->readers_tail = asr;
1231 reader_cb(reader_opaque, asr, ASIO_STATE_FAILED);
1232 async_socket_io_release(asr);