Lines Matching defs:SDKCtlSocket
34 #define D(...) VERBOSE_PRINT(sdkctlsocket,__VA_ARGS__)
35 #define D_ACTIVE VERBOSE_CHECK(sdkctlsocket)
40 #define T(...) VERBOSE_PRINT(sdkctlsocket,__VA_ARGS__)
100 SDKCtlSocket* sdkctl;
159 SDKCtlSocket* sdkctl;
201 /* Enumerates SDKCtlSocket states. */
211 /* Enumerates SDKCtlSocket I/O dispatcher states. */
223 /* SDKCtlSocket I/O dispatcher descriptor. */
225 /* SDKCtlSocket instance for this dispatcher. */
226 SDKCtlSocket* sdkctl;
245 struct SDKCtlSocket {
286 * SDKCtlSocket recycling management
289 /* Gets a recycled block for a given SDKCtlSocket, or allocates new memory
292 _sdkctl_socket_alloc_recycler(SDKCtlSocket* sdkctl, uint32_t size)
323 /* Recycles, or frees a block of memory for a given SDKCtlSocket. */
325 _sdkctl_socket_free_recycler(SDKCtlSocket* sdkctl, void* mem)
341 /* Empties the recycler for a given SDKCtlSocket. */
343 _sdkctl_socket_empty_recycler(SDKCtlSocket* sdkctl)
356 * SDKCtlSocket query list management
361 * sdkctl - SDKCtlSocket instance for the query.
367 SDKCtlSocket* const sdkctl = query->sdkctl;
389 SDKCtlSocket* const sdkctl = query->sdkctl;
436 * sdkctl - SDKCtlSocket instance that owns the query.
443 _sdkctl_socket_remove_query_id(SDKCtlSocket* sdkctl, int query_id)
490 * sdkctl - SDKCtlSocket instance that owns the query.
496 _sdkctl_socket_pull_first_query(SDKCtlSocket* sdkctl)
511 _sdkctl_socket_next_query_id(SDKCtlSocket* sdkctl)
522 _sdkctl_packet_new(SDKCtlSocket* sdkctl, int size, int type)
532 /* Refence SDKCTlSocket that owns this packet. */
542 SDKCtlSocket* const sdkctl = packet->sdkctl;
547 /* Release SDKCTlSocket that owned this packet. */
581 SDKCtlSocket* const sdkctl = query->sdkctl;
780 sdkctl_query_new(SDKCtlSocket* sdkctl, int query_type, uint32_t in_data_size)
814 sdkctl_query_new_ex(SDKCtlSocket* sdkctl,
851 SDKCtlSocket* const sdkctl = query->sdkctl;
872 sdkctl_query_build_and_send(SDKCtlSocket* sdkctl,
917 _on_sdkctl_packet_received(SDKCtlSocket* sdkctl, SDKCtlPacket* packet)
943 _sdkctl_io_dispatcher_start(SDKCtlSocket* sdkctl) {
959 _sdkctl_io_dispatcher_reset(SDKCtlSocket* sdkctl) {
991 SDKCtlSocket* const sdkctl = dispatcher->sdkctl;
1033 SDKCtlSocket* const sdkctl = dispatcher->sdkctl;
1077 SDKCtlSocket* const sdkctl = dispatcher->sdkctl;
1099 SDKCtlSocket* const sdkctl = dispatcher->sdkctl;
1160 SDKCtlSocket* const sdkctl = dispatcher->sdkctl;
1205 SDKCtlSocket* const sdkctl = dispatcher->sdkctl;
1207 /* Reference SDKCtlSocket while we're in this callback. */
1295 * SDKCtlSocket internals.
1300 _sdkctl_socket_cancel_all_queries(SDKCtlSocket* sdkctl)
1325 _sdkctl_socket_cancel_all_packets(SDKCtlSocket* sdkctl)
1331 _sdkctl_socket_cancel_all_io(SDKCtlSocket* sdkctl)
1338 /* Disconnects AsyncSocket for SDKCtlSocket. */
1340 _sdkctl_socket_disconnect_socket(SDKCtlSocket* sdkctl)
1356 /* Frees SDKCtlSocket instance. */
1358 _sdkctl_socket_free(SDKCtlSocket* sdkctl)
1385 static void _sdkctl_do_handshake(SDKCtlSocket* sdkctl);
1391 _on_async_socket_connected(SDKCtlSocket* sdkctl)
1415 _on_async_socket_disconnected(SDKCtlSocket* sdkctl)
1436 * client_opaque - SDKCtlSocket isntance.
1444 SDKCtlSocket* const sdkctl = (SDKCtlSocket*)client_opaque;
1481 SDKCtlSocket*
1489 SDKCtlSocket* sdkctl;
1520 int sdkctl_socket_reference(SDKCtlSocket* sdkctl)
1528 sdkctl_socket_release(SDKCtlSocket* sdkctl)
1541 sdkctl_init_recycler(SDKCtlSocket* sdkctl,
1560 sdkctl_socket_connect(SDKCtlSocket* sdkctl, int port, int retry_to)
1579 sdkctl_socket_reconnect(SDKCtlSocket* sdkctl, int port, int retry_to)
1595 sdkctl_socket_disconnect(SDKCtlSocket* sdkctl)
1613 SDKCtlSocket* const sdkctl = (SDKCtlSocket*)query_opaque;
1646 SDKCtlSocket* const sdkctl = (SDKCtlSocket*)io_opaque;
1677 _sdkctl_do_handshake(SDKCtlSocket* sdkctl)
