Lines Matching refs:asio
59 AsyncSocketIO* asio);
135 AsyncSocketIO* asio = _asio_recycled; in _async_socket_rw_new() local
136 if (asio != NULL) { in _async_socket_rw_new()
138 _asio_recycled = asio->next; in _async_socket_rw_new()
142 ANEW0(asio); in _async_socket_rw_new()
145 asio->next = NULL; in _async_socket_rw_new()
146 asio->as = as; in _async_socket_rw_new()
147 asio->is_io_read = is_io_read; in _async_socket_rw_new()
148 asio->buffer = (uint8_t*)buffer; in _async_socket_rw_new()
149 asio->to_transfer = len; in _async_socket_rw_new()
150 asio->transferred = 0; in _async_socket_rw_new()
151 asio->on_io = io_cb; in _async_socket_rw_new()
152 asio->io_opaque = io_opaque; in _async_socket_rw_new()
153 asio->state = ASIO_STATE_QUEUED; in _async_socket_rw_new()
154 asio->ref_count = 1; in _async_socket_rw_new()
155 asio->deadline = deadline; in _async_socket_rw_new()
156 loopTimer_init(asio->timer, _async_socket_get_looper(as), in _async_socket_rw_new()
157 _on_async_socket_io_timed_out, asio); in _async_socket_rw_new()
158 loopTimer_startAbsolute(asio->timer, deadline); in _async_socket_rw_new()
164 _async_socket_string(as), is_io_read ? "READ" : "WRITE", asio, len); in _async_socket_rw_new()
166 return asio; in _async_socket_rw_new()
171 _async_socket_io_free(AsyncSocketIO* asio) in _async_socket_io_free() argument
173 AsyncSocket* const as = asio->as; in _async_socket_io_free()
176 _async_socket_string(as), asio->is_io_read ? "READ" : "WRITE", asio); in _async_socket_io_free()
178 loopTimer_done(asio->timer); in _async_socket_io_free()
182 asio->next = _asio_recycled; in _async_socket_io_free()
183 _asio_recycled = asio; in _async_socket_io_free()
186 AFREE(asio); in _async_socket_io_free()
195 _async_socket_io_finished(AsyncSocketIO* asio) in _async_socket_io_finished() argument
198 asio->on_io(asio->io_opaque, asio, ASIO_STATE_FINISHED); in _async_socket_io_finished()
202 async_socket_io_reference(AsyncSocketIO* asio) in async_socket_io_reference() argument
204 assert(asio->ref_count > 0); in async_socket_io_reference()
205 asio->ref_count++; in async_socket_io_reference()
206 return asio->ref_count; in async_socket_io_reference()
210 async_socket_io_release(AsyncSocketIO* asio) in async_socket_io_release() argument
212 assert(asio->ref_count > 0); in async_socket_io_release()
213 asio->ref_count--; in async_socket_io_release()
214 if (asio->ref_count == 0) { in async_socket_io_release()
215 _async_socket_io_finished(asio); in async_socket_io_release()
217 _async_socket_io_free(asio); in async_socket_io_release()
220 return asio->ref_count; in async_socket_io_release()
241 AsyncSocketIO* const asio = _async_socket_rw_new(as, 1, buffer, len, io_cb, in _async_socket_reader_new() local
243 return asio; in _async_socket_reader_new()
264 AsyncSocketIO* const asio = _async_socket_rw_new(as, 0, (void*)buffer, len, in _async_socket_writer_new() local
267 return asio; in _async_socket_writer_new()
274 AsyncSocketIO* const asio = (AsyncSocketIO*)opaque; in _on_async_socket_io_timed_out() local
275 AsyncSocket* const as = asio->as; in _on_async_socket_io_timed_out()
278 _async_socket_string(as), asio->is_io_read ? "READ" : "WRITE", in _on_async_socket_io_timed_out()
279 asio->deadline, async_socket_deadline(as, 0)); in _on_async_socket_io_timed_out()
282 async_socket_io_reference(asio); in _on_async_socket_io_timed_out()
283 _async_socket_io_timed_out(asio->as, asio); in _on_async_socket_io_timed_out()
284 async_socket_io_release(asio); in _on_async_socket_io_timed_out()
292 async_socket_io_get_socket(const AsyncSocketIO* asio) in async_socket_io_get_socket() argument
294 async_socket_reference(asio->as); in async_socket_io_get_socket()
295 return asio->as; in async_socket_io_get_socket()
299 async_socket_io_cancel_time_out(AsyncSocketIO* asio) in async_socket_io_cancel_time_out() argument
301 loopTimer_stop(asio->timer); in async_socket_io_cancel_time_out()
305 async_socket_io_get_io_opaque(const AsyncSocketIO* asio) in async_socket_io_get_io_opaque() argument
307 return asio->io_opaque; in async_socket_io_get_io_opaque()
311 async_socket_io_get_client_opaque(const AsyncSocketIO* asio) in async_socket_io_get_client_opaque() argument
313 return async_socket_get_client_opaque(asio->as); in async_socket_io_get_client_opaque()
317 async_socket_io_get_buffer_info(const AsyncSocketIO* asio, in async_socket_io_get_buffer_info() argument
322 *transferred = asio->transferred; in async_socket_io_get_buffer_info()
325 *to_transfer = asio->to_transfer; in async_socket_io_get_buffer_info()
327 return asio->buffer; in async_socket_io_get_buffer_info()
331 async_socket_io_get_buffer(const AsyncSocketIO* asio) in async_socket_io_get_buffer() argument
333 return asio->buffer; in async_socket_io_get_buffer()
337 async_socket_io_get_transferred(const AsyncSocketIO* asio) in async_socket_io_get_transferred() argument
339 return asio->transferred; in async_socket_io_get_transferred()
343 async_socket_io_get_to_transfer(const AsyncSocketIO* asio) in async_socket_io_get_to_transfer() argument
345 return asio->to_transfer; in async_socket_io_get_to_transfer()
349 async_socket_io_is_read(const AsyncSocketIO* asio) in async_socket_io_is_read() argument
351 return asio->is_io_read; in async_socket_io_is_read()
547 _async_socket_complete_io(AsyncSocket* as, AsyncSocketIO* asio) in _async_socket_complete_io() argument
550 _async_socket_string(as), asio->is_io_read ? "READ" : "WRITE", asio); in _async_socket_complete_io()
553 async_socket_io_cancel_time_out(asio); in _async_socket_complete_io()
555 return asio->on_io(asio->io_opaque, asio, ASIO_STATE_SUCCEEDED); in _async_socket_complete_io()
566 _async_socket_io_timed_out(AsyncSocket* as, AsyncSocketIO* asio) in _async_socket_io_timed_out() argument
569 _async_socket_string(as), asio->is_io_read ? "READ" : "WRITE", asio, in _async_socket_io_timed_out()
570 asio->deadline, async_socket_deadline(as, 0)); in _async_socket_io_timed_out()
573 const AsyncIOAction action = asio->on_io(asio->io_opaque, asio, in _async_socket_io_timed_out()
578 if (asio->is_io_read) { in _async_socket_io_timed_out()
579 _async_socket_remove_io(as, &as->readers_head, &as->readers_tail, asio); in _async_socket_io_timed_out()
581 _async_socket_remove_io(as, &as->writers_head, &as->writers_tail, asio); in _async_socket_io_timed_out()
596 _async_socket_cancel_io(AsyncSocket* as, AsyncSocketIO* asio) in _async_socket_cancel_io() argument
599 _async_socket_string(as), asio->is_io_read ? "READ" : "WRITE", asio); in _async_socket_cancel_io()
602 async_socket_io_cancel_time_out(asio); in _async_socket_cancel_io()
604 return asio->on_io(asio->io_opaque, asio, ASIO_STATE_CANCELLED); in _async_socket_cancel_io()
616 _async_socket_io_failure(AsyncSocket* as, AsyncSocketIO* asio, int failure) in _async_socket_io_failure() argument
619 _async_socket_string(as), asio->is_io_read ? "READ" : "WRITE", asio, in _async_socket_io_failure()
623 async_socket_io_cancel_time_out(asio); in _async_socket_io_failure()
626 return asio->on_io(asio->io_opaque, asio, ASIO_STATE_FAILED); in _async_socket_io_failure()
775 _on_async_socket_failure(AsyncSocket* as, AsyncSocketIO* asio) in _on_async_socket_failure() argument
778 _async_socket_string(as), asio->is_io_read ? "READ" : "WRITE", in _on_async_socket_failure()
782 return _async_socket_io_failure(as, asio, errno); in _on_async_socket_failure()