Lines Matching defs:AsyncSocketIO
58 AsyncSocketIO* asio);
64 struct AsyncSocketIO {
66 AsyncSocketIO* next;
93 * Since AsyncSocketIO instances are not that large, it makes sence to recycle
99 static AsyncSocketIO* _asio_recycled = NULL;
109 * opaque - AsyncSocketIO instance representing the timed out I/O.
122 * Initialized AsyncSocketIO instance.
124 static AsyncSocketIO*
134 AsyncSocketIO* asio = _asio_recycled;
170 _async_socket_io_free(AsyncSocketIO* asio)
194 _async_socket_io_finished(AsyncSocketIO* asio)
201 async_socket_io_reference(AsyncSocketIO* asio)
209 async_socket_io_release(AsyncSocketIO* asio)
230 * An initialized AsyncSocketIO intance.
232 static AsyncSocketIO*
240 AsyncSocketIO* const asio = _async_socket_rw_new(as, 1, buffer, len, io_cb,
253 * An initialized AsyncSocketIO intance.
255 static AsyncSocketIO*
263 AsyncSocketIO* const asio = _async_socket_rw_new(as, 0, (void*)buffer, len,
273 AsyncSocketIO* const asio = (AsyncSocketIO*)opaque;
291 async_socket_io_get_socket(const AsyncSocketIO* asio)
298 async_socket_io_cancel_time_out(AsyncSocketIO* asio)
304 async_socket_io_get_io_opaque(const AsyncSocketIO* asio)
310 async_socket_io_get_client_opaque(const AsyncSocketIO* asio)
316 async_socket_io_get_buffer_info(const AsyncSocketIO* asio,
330 async_socket_io_get_buffer(const AsyncSocketIO* asio)
336 async_socket_io_get_transferred(const AsyncSocketIO* asio)
342 async_socket_io_get_to_transfer(const AsyncSocketIO* asio)
348 async_socket_io_is_read(const AsyncSocketIO* asio)
371 AsyncSocketIO* readers_head;
373 AsyncSocketIO* readers_tail;
375 AsyncSocketIO* writers_head;
377 AsyncSocketIO* writers_tail;
408 static AsyncSocketIO*
410 AsyncSocketIO** list_head,
411 AsyncSocketIO** list_tail)
413 AsyncSocketIO* const ret = *list_head;
433 static AsyncSocketIO*
448 static AsyncSocketIO*
464 AsyncSocketIO** list_head,
465 AsyncSocketIO** list_tail,
466 AsyncSocketIO* io)
468 AsyncSocketIO* prev = NULL;
501 AsyncSocketIO** list_head,
502 AsyncSocketIO** list_tail)
504 AsyncSocketIO* first_io = *list_head;
546 _async_socket_complete_io(AsyncSocket* as, AsyncSocketIO* asio)
565 _async_socket_io_timed_out(AsyncSocket* as, AsyncSocketIO* asio)
595 _async_socket_cancel_io(AsyncSocket* as, AsyncSocketIO* asio)
615 _async_socket_io_failure(AsyncSocket* as, AsyncSocketIO* asio, int failure)
636 AsyncSocketIO* const to_cancel = _async_socket_pull_first_reader(as);
652 AsyncSocketIO* const to_cancel = _async_socket_pull_first_writer(as);
774 _on_async_socket_failure(AsyncSocket* as, AsyncSocketIO* asio)
797 AsyncSocketIO* const asr = as->readers_head;
907 AsyncSocketIO* const asw = as->writers_head;
1215 AsyncSocketIO* const asr =
1258 AsyncSocketIO* const asw =
