Lines Matching refs:SDKCtlSocket
32 #define D(...) VERBOSE_PRINT(sdkctlsocket,__VA_ARGS__)
33 #define D_ACTIVE VERBOSE_CHECK(sdkctlsocket)
38 #define T(...) VERBOSE_PRINT(sdkctlsocket,__VA_ARGS__)
136 SDKCtlSocket* sdkctl;
163 /* SDKCtlSocket that owns this packet. */
164 SDKCtlSocket* sdkctl;
214 SDKCtlSocket* sdkctl;
285 /* Enumerates SDKCtlSocket states. */
295 /* Enumerates SDKCtlSocket I/O dispatcher states. */
307 /* SDKCtlSocket I/O dispatcher descriptor. */
309 /* SDKCtlSocket instance for this dispatcher. */
310 SDKCtlSocket* sdkctl;
331 struct SDKCtlSocket {
373 * SDKCtlSocket recycling management
376 /* Gets a recycled block for a given SDKCtlSocket, or allocates new memory
379 _sdkctl_socket_alloc_recycler(SDKCtlSocket* sdkctl, uint32_t size)
412 /* Recycles, or frees a block of memory for a given SDKCtlSocket. */
414 _sdkctl_socket_free_recycler(SDKCtlSocket* sdkctl, void* mem)
431 /* Empties the recycler for a given SDKCtlSocket. */
433 _sdkctl_socket_empty_recycler(SDKCtlSocket* sdkctl)
446 * SDKCtlSocket query list management
451 * sdkctl - SDKCtlSocket instance for the query.
457 SDKCtlSocket* const sdkctl = query->sdkctl;
482 SDKCtlSocket* const sdkctl = query->sdkctl;
531 * sdkctl - SDKCtlSocket instance that owns the query.
540 _sdkctl_socket_remove_query_id(SDKCtlSocket* sdkctl, int query_id)
589 * sdkctl - SDKCtlSocket instance that owns the query.
595 _sdkctl_socket_pull_first_query(SDKCtlSocket* sdkctl)
610 _sdkctl_socket_next_query_id(SDKCtlSocket* sdkctl)
621 _sdkctl_packet_new(SDKCtlSocket* sdkctl, uint32_t size, int type)
633 /* Refence SDKCTlSocket that owns this packet. */
646 SDKCtlSocket* const sdkctl = packet->sdkctl;
653 /* Release SDKCTlSocket that owned this packet. */
755 sdkctl_direct_packet_new(SDKCtlSocket* sdkctl)
763 /* Refence SDKCTlSocket that owns this packet. */
775 SDKCtlSocket* const sdkctl = packet->sdkctl;
782 /* Release SDKCTlSocket that owned this packet. */
891 _sdkctl_message_new(SDKCtlSocket* sdkctl, uint32_t msg_size, int msg_type)
915 sdkctl_message_send(SDKCtlSocket* sdkctl,
955 SDKCtlSocket* const sdkctl = query->sdkctl;
1148 sdkctl_query_new(SDKCtlSocket* sdkctl, int query_type, uint32_t in_data_size)
1182 sdkctl_query_new_ex(SDKCtlSocket* sdkctl,
1217 SDKCtlSocket* const sdkctl = query->sdkctl;
1239 sdkctl_query_build_and_send(SDKCtlSocket* sdkctl,
1300 _on_sdkctl_packet_received(SDKCtlSocket* sdkctl, SDKCtlPacket* packet)
1363 _sdkctl_io_dispatcher_start(SDKCtlSocket* sdkctl) {
1379 _sdkctl_io_dispatcher_reset(SDKCtlSocket* sdkctl) {
1413 SDKCtlSocket* const sdkctl = dispatcher->sdkctl;
1455 SDKCtlSocket* const sdkctl = dispatcher->sdkctl;
1511 SDKCtlSocket* const sdkctl = dispatcher->sdkctl;
1534 SDKCtlSocket* const sdkctl = dispatcher->sdkctl;
1593 SDKCtlSocket* const sdkctl = dispatcher->sdkctl;
1638 SDKCtlSocket* const sdkctl = dispatcher->sdkctl;
1640 /* Reference SDKCtlSocket while we're in this callback. */
1728 * SDKCtlSocket internals.
1733 _sdkctl_socket_cancel_all_queries(SDKCtlSocket* sdkctl)
1758 _sdkctl_socket_cancel_all_packets(SDKCtlSocket* sdkctl)
1764 _sdkctl_socket_cancel_all_io(SDKCtlSocket* sdkctl)
1771 /* Disconnects AsyncSocket for SDKCtlSocket. */
1773 _sdkctl_socket_disconnect_socket(SDKCtlSocket* sdkctl)
1790 /* Frees SDKCtlSocket instance. */
1792 _sdkctl_socket_free(SDKCtlSocket* sdkctl)
1821 static void _sdkctl_do_handshake(SDKCtlSocket* sdkctl);
1827 _on_async_socket_connected(SDKCtlSocket* sdkctl)
1851 _on_async_socket_disconnected(SDKCtlSocket* sdkctl)
1872 * client_opaque - SDKCtlSocket isntance.
1880 SDKCtlSocket* const sdkctl = (SDKCtlSocket*)client_opaque;
1917 SDKCtlSocket*
1925 SDKCtlSocket* sdkctl;
1959 int sdkctl_socket_reference(SDKCtlSocket* sdkctl)
1967 sdkctl_socket_release(SDKCtlSocket* sdkctl)
1980 sdkctl_init_recycler(SDKCtlSocket* sdkctl,
1999 sdkctl_socket_connect(SDKCtlSocket* sdkctl, int port, int retry_to)
2018 sdkctl_socket_reconnect(SDKCtlSocket* sdkctl, int port, int retry_to)
2034 sdkctl_socket_disconnect(SDKCtlSocket* sdkctl)
2042 sdkctl_socket_is_connected(SDKCtlSocket* sdkctl)
2048 sdkctl_socket_is_port_ready(SDKCtlSocket* sdkctl)
2054 sdkctl_socket_get_port_status(SDKCtlSocket* sdkctl)
2060 sdkctl_socket_is_handshake_ok(SDKCtlSocket* sdkctl)
2095 SDKCtlSocket* const sdkctl = (SDKCtlSocket*)query_opaque;
2156 SDKCtlSocket* const sdkctl = (SDKCtlSocket*)io_opaque;
2187 _sdkctl_do_handshake(SDKCtlSocket* sdkctl)
