Lines Matching refs:node

3395     netq_t *node = netq_head(peer->handshake_params->reorder_queue);  in handle_handshake()  local
3396 while (node) { in handle_handshake()
3397 dtls_handshake_header_t *node_header = DTLS_HANDSHAKE_HEADER(node->data); in handle_handshake()
3402 node = netq_next(node); in handle_handshake()
3432 netq_t *node = netq_head(peer->handshake_params->reorder_queue); in handle_handshake() local
3433 while (node) { in handle_handshake()
3434 dtls_handshake_header_t *node_header = DTLS_HANDSHAKE_HEADER(node->data); in handle_handshake()
3437 netq_remove(peer->handshake_params->reorder_queue, node); in handle_handshake()
3439 … res = handle_handshake_msg(ctx, peer, session, role, peer->state, node->data, node->length); in handle_handshake()
3446 node = netq_next(node); in handle_handshake()
3890 dtls_retransmit(dtls_context_t *context, netq_t *node) { in dtls_retransmit() argument
3891 if (!context || !node) in dtls_retransmit()
3895 if (node->retransmit_cnt < DTLS_DEFAULT_MAX_RETRANSMIT) { in dtls_retransmit()
3899 unsigned char *data = node->data; in dtls_retransmit()
3900 size_t length = node->length; in dtls_retransmit()
3902 dtls_security_parameters_t *security = dtls_security_params_epoch(node->peer, node->epoch); in dtls_retransmit()
3905 node->retransmit_cnt++; in dtls_retransmit()
3906 node->t = now + (node->timeout << node->retransmit_cnt); in dtls_retransmit()
3907 netq_insert_node(context->sendqueue, node); in dtls_retransmit()
3909 if (node->type == DTLS_CT_HANDSHAKE) { in dtls_retransmit()
3918 err = dtls_prepare_record(node->peer, security, node->type, &data, &length, in dtls_retransmit()
3926 dtls_debug_hexdump("retransmit unencrypted", node->data, node->length); in dtls_retransmit()
3928 (void)CALL(context, write, &node->peer->session, sendbuf, len); in dtls_retransmit()
3937 netq_node_free(node); in dtls_retransmit()
3942 netq_t *node; in dtls_stop_retransmission() local
3943 node = list_head(context->sendqueue); in dtls_stop_retransmission()
3945 while (node) { in dtls_stop_retransmission()
3946 if (dtls_session_equals(&node->peer->session, &peer->session)) { in dtls_stop_retransmission()
3947 netq_t *tmp = node; in dtls_stop_retransmission()
3948 node = list_item_next(node); in dtls_stop_retransmission()
3952 node = list_item_next(node); in dtls_stop_retransmission()
3959 netq_t *node = netq_head(context->sendqueue); in dtls_check_retransmit() local
3962 while (node && node->t <= now) { in dtls_check_retransmit()
3964 dtls_retransmit(context, node); in dtls_check_retransmit()
3965 node = netq_head(context->sendqueue); in dtls_check_retransmit()
3968 if (next && node) in dtls_check_retransmit()
3969 *next = node->t; in dtls_check_retransmit()
3979 netq_t *node; in PROCESS_THREAD() local
3990 node = list_head(the_dtls_context.sendqueue); in PROCESS_THREAD()
3993 if (node && node->t <= now) { in PROCESS_THREAD()
3995 node = list_head(the_dtls_context.sendqueue); in PROCESS_THREAD()
3999 if (node) { in PROCESS_THREAD()
4001 node->t <= now ? 1 : node->t - now); in PROCESS_THREAD()